class.ilAtomQueryLock.php

Go to the documentation of this file.

<?php
require_once('./Services/Database/interfaces/interface.ilAtomQuery.php');
 
class ilAtomQueryLock extends ilAtomQueryBase implements ilAtomQuery {
 
        protected $locked_table_full_names = array();
        protected $locked_table_names = array();
 
 
        public function run() {
                $this->checkBeforeRun();
                $this->runWithLocks();
        }
 
 
        protected function runWithLocks() {
                $this->ilDBInstance->lockTables($this->getLocksForDBInstance());
                try {
                        $this->runQueries();
                } catch (Exception $e) {
                        $this->ilDBInstance->unlockTables();
                        throw $e;
                }
                $this->ilDBInstance->unlockTables();
        }
 
 
        protected function getLocksForDBInstance() {
                $locks = array();
                foreach ($this->tables as $table) {
                        $full_name = $table->getTableName() . $table->getAlias();
                        if (in_array($full_name, $this->locked_table_full_names)) {
                                throw new ilAtomQueryException('', ilAtomQueryException::DB_ATOM_IDENTICAL_TABLES);
                        }
                        $this->locked_table_full_names[] = $full_name;
 
                        if (!in_array($table->getTableName(), $this->locked_table_names)) {
                                $locks[] = array( 'name' => $table->getTableName(), 'type' => $table->getLockLevel() );
                                $this->locked_table_names[] = $table->getTableName();
                                if ($table->isLockSequence() && $this->ilDBInstance->sequenceExists($table->getTableName())) {
                                        $locks[] = array( 'name' => $table->getTableName(), 'type' => $table->getLockLevel(), 'sequence' => true );
                                }
                        }
                        if ($table->getAlias()) {
                                $locks[] = array( 'name' => $table->getTableName(), 'type' => $table->getLockLevel(), 'alias' => $table->getAlias() );
                        }
                }
 
                return $locks;
        }
}