DealContactTable::upsert

static function upsert(array $data)
{
	$dealID = isset($data['DEAL_ID']) ? (int)$data['DEAL_ID'] : 0;
	if($dealID <= 0)
	{
		throw new Main\ArgumentException('Must contains DEAL_ID field.', 'data');
	}

	$contactID = isset($data['CONTACT_ID']) ? (int)$data['CONTACT_ID'] : 0;
	if($contactID <= 0)
	{
		throw new Main\ArgumentException('Must contains CONTACT_ID field.', 'data');
	}

	$sort = isset($data['SORT']) ? (int)$data['SORT'] : 0;
	$roleID = isset($data['ROLE_ID']) ? (int)$data['ROLE_ID'] : 0;
	$primary = isset($data['IS_PRIMARY']) && mb_strtoupper($data['IS_PRIMARY']) === 'Y' ? 'Y' : 'N';

	$connection = Main\Application::getConnection();
	$queries = $connection->getSqlHelper()->prepareMerge(
		'b_crm_deal_contact',
		array('DEAL_ID', 'CONTACT_ID'),
		array('DEAL_ID' => $dealID, 'CONTACT_ID' => $contactID, 'SORT' => $sort, 'ROLE_ID' => $roleID, 'IS_PRIMARY' => $primary),
		array('SORT' => $sort, 'ROLE_ID' => $roleID, 'IS_PRIMARY' => $primary)
	);

	foreach($queries as $query)
	{
		$connection->queryExecute($query);
	}
}