usersessiontable.php

<?php
namespace Bitrix\Main\Session\Handlers\Table;
 
 
use Bitrix\Main\Application;
use Bitrix\Main\DB\MysqlCommonConnection;
use Bitrix\Main\Entity;
use Bitrix\Main\Type;
 
class UserSessionTable extends Entity\DataManager
{
    public const CONNECTION_NAME = 'user_session';
 
    public static function getTableName()
    {
        return 'b_user_session';
    }
 
    public static function getConnectionName()
    {
        $pool = Application::getInstance()->getConnectionPool();
        $isConnectionExists = $pool->getConnection(static::CONNECTION_NAME) !== null;
        if (!$isConnectionExists)
        {
            $pool->cloneConnection(
                $pool::DEFAULT_CONNECTION_NAME,
                static::CONNECTION_NAME
            );
        }
 
        return static::CONNECTION_NAME;
    }
 
    public static function getMap()
    {
        return [
            new Entity\StringField('SESSION_ID', [
                'primary' => true,
                'format' => '#^[0-9a-z\-,]{6,250}$#iD'
            ]),
            new Entity\DatetimeField('TIMESTAMP_X', [
                'default_value' => new Type\DateTime
            ]),
            new Entity\TextField('SESSION_DATA', [
                'default_value' => '',
                'save_data_modification' => function() {
                    return [
                        function($data) {
                            return base64_encode($data);
                        }
                    ];
                },
                'fetch_data_modification' => function() {
                    return [
                        function($data) {
                            return base64_decode($data);
                        }
                    ];
                },
            ])
        ];
    }
 
    public static function lock($id, $timeout = 60)
    {
        $result = true;
 
        $pool = Application::getInstance()->getConnectionPool();
        $pool->useMasterOnly(true);
 
        $connection = static::getEntity()->getConnection();
        if ($connection instanceof MysqlCommonConnection)
        {
            $result = $connection->lock($id, (int)$timeout);
        }
        else
        {
            trigger_error(sprintf('SessionTable::lock not supported for connection of type "%s"', get_class($connection)), E_USER_WARNING);
        }
 
        $pool->useMasterOnly(false);
 
        return $result;
    }
 
    public static function unlock($id)
    {
        $pool = Application::getInstance()->getConnectionPool();
        $pool->useMasterOnly(true);
 
        $connection = static::getEntity()->getConnection();
        if ($connection instanceof MysqlCommonConnection)
        {
            $connection->unlock($id);
        }
        else
        {
            trigger_error(sprintf('SessionTable::unlock not supported for connection of type "%s"', get_class($connection)), E_USER_WARNING);
        }
 
        $pool->useMasterOnly(false);
 
        return true;
    }
 
    public static function deleteOlderThan($sec)
    {
        $pool = Application::getInstance()->getConnectionPool();
        $pool->useMasterOnly(true);
 
        $tableName = static::getTableName();
        $connection = static::getEntity()->getConnection();
        $connection->queryExecute(
            sprintf("delete from {$tableName} where TIMESTAMP_X < %s",
                $connection->getSqlHelper()->addSecondsToDateTime('-'.$sec))
        );
        $pool->useMasterOnly(false);
    }
}