locker.php

<?
namespace Bitrix\Main\Composite\Internals;
 
use Bitrix\Main\Application;
use Bitrix\Main\DB\MysqlCommonConnection;
 
class Locker
{
    const CONNECTION_NAME = "composite";
 
    public static function lock($id)
    {
        $result = true;
        $connection = static::getConnection();
        if ($connection instanceof MysqlCommonConnection)
        {
            $result = $connection->lock($id);
        }
 
        return $result;
    }
 
    public static function unlock($id)
    {
        $connection = static::getConnection();
        if ($connection instanceof MysqlCommonConnection)
        {
            $connection->unlock($id);
        }
 
        return true;
    }
 
    private static function getConnection()
    {
        $pool = Application::getInstance()->getConnectionPool();
        $connection = $pool->getConnection(static::CONNECTION_NAME);
        if (!$connection)
        {
            $connection = $pool->cloneConnection(
                $pool::DEFAULT_CONNECTION_NAME,
                static::CONNECTION_NAME
            );
        }
 
        return $connection;
    }
 
}