addresslinktable.php

<?php
 
namespace Bitrix\Location\Model;
 
use Bitrix\Main;
use Bitrix\Main\ORM\Fields;
use Bitrix\Main\ORM\Query\Join;
 
class AddressLinkTable extends Main\ORM\Data\DataManager
{
    public static function getTableName()
    {
        return 'b_location_addr_link';
    }
 
    public static function getMap()
    {
        return [
 
            (new Fields\IntegerField('ADDRESS_ID'))
                ->configurePrimary(true),
 
            (new Fields\StringField('ENTITY_ID'))
                ->configurePrimary(true)
                ->addValidator(new Main\ORM\Fields\Validators\LengthValidator(1, 100)),
 
            // todo: int
            (new Fields\StringField('ENTITY_TYPE'))
                ->configurePrimary(true)
                ->addValidator(new Main\ORM\Fields\Validators\LengthValidator(1, 50)),
 
            // Ref
 
            (new Fields\Relations\Reference('ADDRESS', AddressTable::class,
                Join::on('this.ADDRESS_ID', 'ref.ID')))
                ->configureJoinType('inner')
        ];
    }
 
    public static function deleteByAddressId(int $addressId): void
    {
        Main\Application::getConnection()->queryExecute("
            DELETE 
                FROM ".self::getTableName()." 
            WHERE 
                ADDRESS_ID=".(int)$addressId
        );
    }
 
    public static function deleteByEntityType(string $entityType): void
    {
        $connection = Main\Application::getConnection();
        $sqlHelper = $connection->getSqlHelper();
 
        Main\Application::getConnection()->queryExecute("
            DELETE 
                FROM ".self::getTableName()." 
            WHERE               
                ENTITY_TYPE = '".$sqlHelper->forSql($entityType)."'"
        );
    }
}