messageclosure.php

<?php
 
namespace Bitrix\Mail\Internals;
 
use Bitrix\Main\Entity;
 
class MessageClosureTable extends Entity\DataManager
{
 
    public static function getFilePath()
    {
        return __FILE__;
    }
 
    public static function getTableName()
    {
        return 'b_mail_message_closure';
    }
 
    public static function getMap()
    {
        return array(
            'MESSAGE_ID' => array(
                'data_type' => 'integer',
                'primary'   => true,
            ),
            'PARENT_ID' => array(
                'data_type' => 'integer',
                'primary'   => true,
            ),
        );
    }
 
    public static function insertIgnoreFromSelect(string $fromSelect): int
    {
        return self::insertIgnoreFromSql("($fromSelect)");
    }
 
    public static function insertIgnoreFromSql(string $sql): int
    {
        $connection = \Bitrix\Main\Application::getConnection();
        $sql = $connection->getSqlHelper()
            ->getInsertIgnore(self::getTableName(), ' (MESSAGE_ID, PARENT_ID) ', $sql);
        $connection->query($sql);
 
        return $connection->getAffectedRowsCount();
    }
 
}