class.ilAssQuestionProcessLockerDb.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2013 ILIAS open source, Extended GPL, see docs/LICENSE */

require_once 'Modules/TestQuestionPool/classes/class.ilAssQuestionProcessLocker.php';

class ilAssQuestionProcessLockerDb extends ilAssQuestionProcessLocker
{
        protected $db;

        protected $atom_query;

        private $assessmentLogEnabled = false;

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

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

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

        private function getTablesUsedDuringAssessmentLog()
        {
                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()
        {
                return array(
                        array('name' => 'tst_solutions', 'sequence' => true)
                );
        }

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

        protected function onBeforeExecutingUserSolutionUpdateOperation()
        {
                $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()
        {
                $this->atom_query = $this->db->buildAtomQuery();
                foreach($this->getTablesUsedDuringResultUpdate() as $table)
                {
                        $this->atom_query->addTableLock($table['name'])->lockSequence((bool)$table['sequence']);
                }
        }

        protected function onBeforeExecutingUserSolutionAdoptOperation()
        {
                $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()
        {
                $this->atom_query = $this->db->buildAtomQuery();
                $this->atom_query->addTableLock('tst_result_cache');
        }

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

                $this->atom_query = null;
        }
}