class.ilTestProcessLockerDb.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilTestProcessLockerDb extends ilTestProcessLocker
{
    protected $db;

    protected $atom_query;

    public function __construct(ilDBInterface $db)
    {
        $this->db = $db;
        $this->atom_query = $this->db->buildAtomQuery();
    }

    protected function onBeforeExecutingTestStartOperation()
    {
        $this->atom_query->addTableLock('tst_active');
    }

    protected function onBeforeExecutingRandomPassBuildOperation($withTaxonomyTables = false)
    {
        $this->atom_query->addTableLock('tst_rnd_cpy');
        $this->atom_query->addTableLock('qpl_questions');
        $this->atom_query->addTableLock('qpl_qst_type');
        $this->atom_query->addTableLock('tst_test_rnd_qst')->lockSequence(true);
        $this->atom_query->addTableLock('il_plugin');
        $this->atom_query->addTableLock('tst_active');

        if ($withTaxonomyTables) {
            $this->atom_query->addTableLock('tax_tree')->aliasName('s');
            $this->atom_query->addTableLock('tax_tree')->aliasName('t');
            $this->atom_query->addTableLock('tax_node_assignment');
        }
    }

    protected function onBeforeExecutingTestFinishOperation()
    {
        $this->atom_query->addTableLock('tst_active');
    }

    protected function executeOperation(callable $operation)
    {
        $this->atom_query ->addQueryCallable(function (ilDBInterface $ilDB) use ($operation) {
            $operation();
        });
        $this->atom_query->run();
    }

    protected function onBeforeExecutingNamedOperation(string $operationDescriptor): void
    {
        throw new RuntimeException('Operation not supported');
    }

    protected function onAfterExecutingNamedOperation(string $operationDescriptor): void
    {
        throw new RuntimeException('Operation not supported');
    }
}