class.arConnectorSession.php

Go to the documentation of this file.

<?php

class arConnectorSession extends arConnector
{
    public const AR_CONNECTOR_SESSION = 'arConnectorSession';

    public static function resetSession(): void
    {
        $_SESSION[self::AR_CONNECTOR_SESSION] = [];
    }

    public static function getSession(): array
    {
        if (!$_SESSION[self::AR_CONNECTOR_SESSION]) {
            self::resetSession();
        }

        return $_SESSION[self::AR_CONNECTOR_SESSION];
    }

    public static function getSessionForActiveRecord(ActiveRecord $activeRecord): array
    {
        $session = self::getSession();
        $ar_session = $session[$activeRecord::returnDbTableName()];
        if (!is_array($ar_session)) {
            return [];
        }

        return $ar_session;
    }

    public function checkConnection(ActiveRecord $activeRecord): bool
    {
        return is_array(self::getSession());
    }

    public function nextID(ActiveRecord $activeRecord): int
    {
        return count(self::getSessionForActiveRecord($activeRecord)) + 1;
    }

    public function installDatabase(ActiveRecord $activeRecord, array $fields): bool
    {
        return $this->resetDatabase($activeRecord);
    }

    public function updateDatabase(ActiveRecord $activeRecord): bool
    {
        return true;
    }

    public function resetDatabase(ActiveRecord $activeRecord): bool
    {
        $_SESSION[self::AR_CONNECTOR_SESSION][$activeRecord::returnDbTableName()] = [];

        return true;
    }

    public function truncateDatabase(ActiveRecord $activeRecord): bool
    {
        return $this->resetDatabase($activeRecord);
    }

    public function checkTableExists(ActiveRecord $activeRecord): bool
    {
        return is_array(self::getSessionForActiveRecord($activeRecord));
    }

    public function checkFieldExists(ActiveRecord $activeRecord, string $field_name): bool
    {
        $session = self::getSessionForActiveRecord($activeRecord);

        return array_key_exists($field_name, $session[0]);
    }

    public function removeField(ActiveRecord $activeRecord, string $field_name): bool
    {
        return true;
    }

    public function renameField(ActiveRecord $activeRecord, string $old_name, string $new_name): bool
    {
        return true;
    }

    public function create(ActiveRecord $activeRecord): void
    {
        $_SESSION[self::AR_CONNECTOR_SESSION][$activeRecord::returnDbTableName()][$activeRecord->getPrimaryFieldValue(
        )] = $activeRecord->asStdClass();
    }

    public function read(ActiveRecord $activeRecord): array
    {
        $session = self::getSessionForActiveRecord($activeRecord);

        return [$session[$activeRecord->getPrimaryFieldValue()]];
    }

    public function update(ActiveRecord $activeRecord): void
    {
        $this->create($activeRecord);
    }

    public function delete(ActiveRecord $activeRecord): void
    {
        unset(
            $_SESSION[self::AR_CONNECTOR_SESSION][$activeRecord::returnDbTableName(
            )][$activeRecord->getPrimaryFieldValue()]
        );
    }

    public function readSet(ActiveRecordList $activeRecordList): array
    {
        $session = self::getSessionForActiveRecord($activeRecordList->getAR());
        foreach ($session as $i => $s) {
            $session[$i] = (array) $s;
        }
        foreach ($activeRecordList->getArWhereCollection()->getWheres() as $arWhere) {
            $fieldname = $arWhere->getFieldname();
            $v = $arWhere->getValue();
            $operator = $arWhere->getOperator();

            foreach ($session as $i => $s) {
                $session[$i] = (array) $s;
                if ($operator !== '=') {
                    continue;
                }
                if ($s[$fieldname] === $v) {
                    continue;
                }
                unset($session[$i]);
            }
        }

        return $session;
    }

    public function affectedRows(ActiveRecordList $activeRecordList): int
    {
        return count($this->readSet($activeRecordList));
    }

    public function quote($value, string $type): string
    {
        return $value;
    }

    public function updateIndices(ActiveRecord $activeRecord): void
    {
        // TODO: Implement updateIndices() method.
    }
}