class SessionHandler

Same name in other branches
  1. 9 core/lib/Drupal/Core/Session/SessionHandler.php \Drupal\Core\Session\SessionHandler
  2. 8.9.x core/lib/Drupal/Core/Session/SessionHandler.php \Drupal\Core\Session\SessionHandler
  3. 10 core/lib/Drupal/Core/Session/SessionHandler.php \Drupal\Core\Session\SessionHandler

Default session handler.

Hierarchy

Expanded class hierarchy of SessionHandler

File

core/lib/Drupal/Core/Session/SessionHandler.php, line 16

Namespace

Drupal\Core\Session
View source
class SessionHandler extends AbstractProxy implements \SessionHandlerInterface {
    use DependencySerializationTrait;
    
    /**
     * Constructs a new SessionHandler instance.
     *
     * @param \Symfony\Component\HttpFoundation\RequestStack $requestStack
     *   The request stack.
     * @param \Drupal\Core\Database\Connection $connection
     *   The database connection.
     * @param \Drupal\Component\Datetime\TimeInterface $time
     *   The time service.
     */
    public function __construct(RequestStack $requestStack, Connection $connection, TimeInterface $time) {
    }
    
    /**
     * {@inheritdoc}
     */
    public function open(string $save_path, string $name) : bool {
        return TRUE;
    }
    
    /**
     * {@inheritdoc}
     */
    public function read(string $sid) : string|false {
        $data = '';
        if (!empty($sid)) {
            try {
                // Read the session data from the database.
                $query = $this->connection
                    ->queryRange('SELECT [session] FROM {sessions} WHERE [sid] = :sid', 0, 1, [
                    ':sid' => Crypt::hashBase64($sid),
                ]);
                $data = (string) $query->fetchField();
            } catch (\Exception) {
            }
        }
        return $data;
    }
    
    /**
     * {@inheritdoc}
     */
    public function write(string $sid, string $value) : bool {
        $try_again = FALSE;
        $request = $this->requestStack
            ->getCurrentRequest();
        $fields = [
            'uid' => $request->getSession()
                ->get('uid', 0),
            'hostname' => $request->getClientIP(),
            'session' => $value,
            'timestamp' => $this->time
                ->getRequestTime(),
        ];
        $doWrite = fn() => $this->connection
            ->merge('sessions')
            ->keys([
            'sid' => Crypt::hashBase64($sid),
        ])
            ->fields($fields)
            ->execute();
        try {
            $doWrite();
        } catch (\Exception $e) {
            // If there was an exception, try to create the table.
            if (!($try_again = $this->ensureTableExists())) {
                // If the exception happened for other reason than the missing
                // table, propagate the exception.
                throw $e;
            }
        }
        // Now that the bin has been created, try again if necessary.
        if ($try_again) {
            $doWrite();
        }
        return TRUE;
    }
    
    /**
     * {@inheritdoc}
     */
    public function close() : bool {
        return TRUE;
    }
    
    /**
     * {@inheritdoc}
     */
    public function destroy(string $sid) : bool {
        try {
            // Delete session data.
            $this->connection
                ->delete('sessions')
                ->condition('sid', Crypt::hashBase64($sid))
                ->execute();
        } catch (\Exception) {
        }
        return TRUE;
    }
    
    /**
     * {@inheritdoc}
     */
    public function gc(int $lifetime) : int|false {
        // Be sure to adjust 'php_value session.gc_maxlifetime' to a large enough
        // value. For example, if you want user sessions to stay in your database
        // for three weeks before deleting them, you need to set gc_maxlifetime
        // to '1814400'. At that value, only after a user doesn't log in after
        // three weeks (1814400 seconds) will their session be removed.
        try {
            return $this->connection
                ->delete('sessions')
                ->condition('timestamp', $this->time
                ->getRequestTime() - $lifetime, '<')
                ->execute();
        } catch (\Exception) {
        }
        return FALSE;
    }
    
    /**
     * Defines the schema for the session table.
     *
     * @internal
     */
    protected function schemaDefinition() : array {
        $schema = [
            'description' => "Drupal's session handlers read and write into the sessions table. Each record represents a user session, either anonymous or authenticated.",
            'fields' => [
                'uid' => [
                    'description' => 'The {users}.uid corresponding to a session, or 0 for anonymous user.',
                    'type' => 'int',
                    'unsigned' => TRUE,
                    'not null' => TRUE,
                ],
                'sid' => [
                    'description' => "A session ID (hashed). The value is generated by Drupal's session handlers.",
                    'type' => 'varchar_ascii',
                    'length' => 128,
                    'not null' => TRUE,
                ],
                'hostname' => [
                    'description' => 'The IP address that last used this session ID (sid).',
                    'type' => 'varchar_ascii',
                    'length' => 128,
                    'not null' => TRUE,
                    'default' => '',
                ],
                'timestamp' => [
                    'description' => 'The Unix timestamp when this session last requested a page. Old records are purged by PHP automatically.',
                    'type' => 'int',
                    'not null' => TRUE,
                    'default' => 0,
                    'size' => 'big',
                ],
                'session' => [
                    'description' => 'The serialized contents of the user\'s session, an array of name/value pairs that persists across page requests by this session ID. Drupal loads the user\'s session from here   at the start of each request and saves it at the end.',
                    'type' => 'blob',
                    'not null' => FALSE,
                    'size' => 'big',
                ],
            ],
            'primary key' => [
                'sid',
            ],
            'indexes' => [
                'timestamp' => [
                    'timestamp',
                ],
                'uid' => [
                    'uid',
                ],
            ],
            'foreign keys' => [
                'session_user' => [
                    'table' => 'users',
                    'columns' => [
                        'uid' => 'uid',
                    ],
                ],
            ],
        ];
        return $schema;
    }
    
    /**
     * Check if the session table exists and create it if not.
     *
     * @return bool
     *   TRUE if the table already exists or was created, FALSE if creation fails.
     */
    protected function ensureTableExists() : bool {
        try {
            $database_schema = $this->connection
                ->schema();
            $schema_definition = $this->schemaDefinition();
            $database_schema->createTable('sessions', $schema_definition);
        } catch (DatabaseException) {
        } catch (\Exception) {
            return FALSE;
        }
        return TRUE;
    }

}

Members

Title Sort descending Modifiers Object type Summary Overrides
DependencySerializationTrait::$_entityStorages protected property
DependencySerializationTrait::$_serviceIds protected property
DependencySerializationTrait::__sleep public function 1
DependencySerializationTrait::__wakeup public function 2
SessionHandler::close public function
SessionHandler::destroy public function
SessionHandler::ensureTableExists protected function Check if the session table exists and create it if not.
SessionHandler::gc public function
SessionHandler::open public function
SessionHandler::read public function
SessionHandler::schemaDefinition protected function Defines the schema for the session table.
SessionHandler::write public function
SessionHandler::__construct public function Constructs a new SessionHandler instance.

Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.