class.ilAtomQueryLock.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilAtomQueryLock extends ilAtomQueryBase implements ilAtomQuery
{
    protected array $locked_table_full_names = [];
    protected array $locked_table_names = [];


    public function run(): void
    {
        $this->checkBeforeRun();
        $this->runWithLocks();
    }


    protected function runWithLocks(): void
    {
        $this->ilDBInstance->lockTables($this->getLocksForDBInstance());
        try {
            $this->runQueries();
        } catch (Exception $e) {
            $this->ilDBInstance->unlockTables();
            throw $e;
        }
        $this->ilDBInstance->unlockTables();
    }


    protected function getLocksForDBInstance(): array
    {
        $locks = [];
        foreach ($this->tables as $table) {
            $full_name = $table->getTableName() . $table->getAlias();
            if (in_array($full_name, $this->locked_table_full_names, true)) {
                throw new ilAtomQueryException('', ilAtomQueryException::DB_ATOM_IDENTICAL_TABLES);
            }
            $this->locked_table_full_names[] = $full_name;

            if (!in_array($table->getTableName(), $this->locked_table_names, true)) {
                $locks[] = [ 'name' => $table->getTableName(), 'type' => $table->getLockLevel() ];
                $this->locked_table_names[] = $table->getTableName();
                if ($table->isLockSequence() && $this->ilDBInstance->sequenceExists($table->getTableName())) {
                    $locks[] = [ 'name' => $table->getTableName(), 'type' => $table->getLockLevel(), 'sequence' => true ];
                }
            }
            if ($table->getAlias() !== '') {
                $locks[] = [ 'name' => $table->getTableName(), 'type' => $table->getLockLevel(), 'alias' => $table->getAlias() ];
            }
        }

        return $locks;
    }
}