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;

        private $assessmentLogEnabled = false;

        public function __construct(ilDB $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', 'type' => ilDB::LOCK_WRITE),
                        array('name' => 'tst_tests', 'type' => ilDB::LOCK_WRITE),
                        array('name' => 'tst_active', 'type' => ilDB::LOCK_WRITE),
                        array('name' => 'ass_log', 'type' => ilDB::LOCK_WRITE),
                        array('name' => 'ass_log', 'type' => ilDB::LOCK_WRITE, 'sequence' => true)
                );
        }

        private function getTablesUsedDuringSolutionUpdate()
        {
                return array(
                        array('name' => 'tst_solutions', 'type' => ilDB::LOCK_WRITE),
                        array('name' => 'tst_solutions', 'type' => ilDB::LOCK_WRITE, 'sequence' => true)
                );
        }

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

        public function requestUserSolutionUpdateLock()
        {
                $tables = $this->getTablesUsedDuringSolutionUpdate();
                
                if( $this->isAssessmentLogEnabled() )
                {
                        $tables = array_merge($tables, $this->getTablesUsedDuringAssessmentLog());
                }
                
                $this->db->lockTables($tables);
        }

        public function releaseUserSolutionUpdateLock()
        {
                $this->db->unlockTables();
        }

        public function requestUserSolutionAdoptLock()
        {
                $this->db->lockTables(array_merge(
                        $this->getTablesUsedDuringSolutionUpdate(), $this->getTablesUsedDuringResultUpdate()
                ));
        }

        public function releaseUserSolutionAdoptLock()
        {
                $this->db->unlockTables();
        }

        public function requestUserQuestionResultUpdateLock()
        {
                $this->db->lockTables(
                        $this->getTablesUsedDuringResultUpdate()
                );
        }

        public function releaseUserQuestionResultUpdateLock()
        {
                $this->db->unlockTables();
        }

        public function requestUserPassResultUpdateLock()
        {
                // no lock neccessary, because a single replace query is used
                
                //$this->db->lockTables(array(
                //      array('name' => 'tst_pass_result', 'type' => ilDB::LOCK_WRITE)
                //));
        }

        public function releaseUserPassResultUpdateLock()
        {
                // no lock neccessary, because a single replace query is used

                //$this->db->unlockTables();
        }

        public function requestUserTestResultUpdateLock()
        {
                $this->db->lockTables(array(
                        array('name' => 'tst_result_cache', 'type' => ilDB::LOCK_WRITE)
                ));
        }

        public function releaseUserTestResultUpdateLock()
        {
                $this->db->unlockTables();
        }
}