class.ilAssQuestionProcessLockerDb.php

Go to the documentation of this file.

<?php

class ilAssQuestionProcessLockerDb extends ilAssQuestionProcessLocker
{
    protected $db;

    protected $atom_query;

    private $assessmentLogEnabled = false;

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

    public function isAssessmentLogEnabled(): bool
    {
        return $this->assessmentLogEnabled;
    }

    public function setAssessmentLogEnabled($assessmentLogEnabled): void
    {
        $this->assessmentLogEnabled = $assessmentLogEnabled;
    }

    private function getTablesUsedDuringAssessmentLog(): array
    {
        return array(
            array('name' => 'qpl_questions', 'sequence' => false),
            array('name' => 'tst_tests', 'sequence' => false),
            array('name' => 'tst_active', 'sequence' => false),
            array('name' => 'ass_log', 'sequence' => true)
        );
    }

    private function getTablesUsedDuringSolutionUpdate(): array
    {
        return [
            ['name' => 'tst_solutions', 'sequence' => true],
            ['name' => PassPresentedVariablesRepo::TABLE_NAME, 'sequence' => false]
        ];
    }

    private function getTablesUsedDuringResultUpdate(): array
    {
        return array(
            array('name' => 'tst_test_result', 'sequence' => true)
        );
    }

    protected function onBeforeExecutingUserSolutionUpdateOperation(): void
    {
        $tables = $this->getTablesUsedDuringSolutionUpdate();

        if ($this->isAssessmentLogEnabled()) {
            $tables = array_merge($tables, $this->getTablesUsedDuringAssessmentLog());
        }

        $this->atom_query = $this->db->buildAtomQuery();
        foreach ($tables as $table) {
            $this->atom_query->addTableLock($table['name'])->lockSequence((bool) $table['sequence']);
        }
    }

    protected function onBeforeExecutingUserQuestionResultUpdateOperation(): void
    {
        $this->atom_query = $this->db->buildAtomQuery();
        foreach ($this->getTablesUsedDuringResultUpdate() as $table) {
            $this->atom_query->addTableLock($table['name'])->lockSequence((bool) $table['sequence']);
        }
    }

    protected function onBeforeExecutingUserSolutionAdoptOperation(): void
    {
        $this->atom_query = $this->db->buildAtomQuery();
        foreach (array_merge(
            $this->getTablesUsedDuringSolutionUpdate(),
            $this->getTablesUsedDuringResultUpdate()
        ) as $table) {
            $this->atom_query->addTableLock($table['name'])->lockSequence((bool) $table['sequence']);
        }
    }

    protected function onBeforeExecutingUserTestResultUpdateOperation(): void
    {
        $this->atom_query = $this->db->buildAtomQuery();
        $this->atom_query->addTableLock('tst_result_cache');
        $this->atom_query->addTableLock('tst_test_result')->lockSequence(true);
        $this->atom_query->addTableLock('tst_solutions')->lockSequence(true);
    }

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

        $this->atom_query = null;
    }
}