class.ilSessionIStorage.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
class ilSessionIStorage
{
    private string $session_id;
    private string $component_id;
    private static array $values = [];
 
    public function __construct(string $a_component_id, string $a_sess_id = '')
    {
        $this->component_id = $a_component_id;
        if ($a_sess_id !== '') {
            $this->session_id = $a_sess_id;
        } else {
            $this->session_id = session_id();
        }
    }
 
    private function initComponentCacheIfNotExists(): void
    {
        if (!isset(self::$values[$this->component_id]) || !is_array(self::$values[$this->component_id])) {
            self::$values[$this->component_id] = [];
        }
    }
 
    public function set(string $a_key, string $a_val): void
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $this->initComponentCacheIfNotExists();
 
        self::$values[$this->component_id][$a_key] = $a_val;
        $ilDB->replace(
            'usr_sess_istorage',
            [
                'session_id' => ['text', $this->session_id],
                'component_id' => ['text', $this->component_id],
                'vkey' => ['text', $a_key]
            ],
            ['value' => ['text', $a_val]]
        );
    }
 
    public function get(string $a_key): string
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        if (isset(self::$values[$this->component_id][$a_key]) && is_array(self::$values[$this->component_id])) {
            return self::$values[$this->component_id][$a_key];
        }
 
        $set = $ilDB->query(
            'SELECT value FROM usr_sess_istorage ' .
            ' WHERE session_id = ' . $ilDB->quote($this->session_id, 'text') .
            ' AND component_id = ' . $ilDB->quote($this->component_id, 'text') .
            ' AND vkey = ' . $ilDB->quote($a_key, 'text')
        );
        $rec = $ilDB->fetchAssoc($set);
        $value = (string) ($rec['value'] ?? '');
 
        $this->initComponentCacheIfNotExists();
 
        self::$values[$this->component_id][$a_key] = $value;
 
        return $value;
    }
 
    public static function destroySession($a_session_id): void
    {
        global $DIC;
 
        if (is_array($a_session_id)) {
            $chunk_size = 500;
            $batches = array_chunk($a_session_id, $chunk_size);
            foreach ($batches as $batch) {
                $q = 'DELETE FROM usr_sess_istorage WHERE ' .
                    $DIC->database()->in('session_id', $batch, false, ilDBConstants::T_TEXT);
                $DIC->database()->manipulate($q);
            }
        } else {
            $q = 'DELETE FROM usr_sess_istorage WHERE session_id = ' .
                $DIC->database()->quote($a_session_id, ilDBConstants::T_TEXT);
            $DIC->database()->manipulate($q);
        }
    }
}