ilAtomQueryLock Class Reference

Class ilAtomQueryLock. More...

Inheritance diagram for ilAtomQueryLock:

Collaboration diagram for ilAtomQueryLock:

Public Member Functions
	run ()
	Fire your Queries. More...
Public Member Functions inherited from ilAtomQueryBase
	__construct (ilDBInterface $ilDBInstance, $isolation_level=ilAtomQuery::ISOLATION_SERIALIZABLE)
	ilAtomQuery constructor. More...
	getRisks ()
	addTableLock ($table_name)
	Add table-names which are influenced by your queries, MyISAm has to lock those tables. More...
	addQueryCallable (callable $query)
	All action on the database during this isolation has to be passed as Callable to ilAtomQuery. More...
	replaceQueryCallable (callable $query)
	run ()
	Fire your Queries. More...
	getIsolationLevel ()
	checkCallable (callable $query)

Protected Member Functions
	runWithLocks ()
	getLocksForDBInstance ()
Protected Member Functions inherited from ilAtomQueryBase
	getDeterminedLockLevel ()
	checkQueries ()
	runQueries ()
	checkBeforeRun ()

Protected Attributes
	$locked_table_full_names = array()
	$locked_table_names = array()
Protected Attributes inherited from ilAtomQueryBase
	$isolation_level = ilAtomQuery::ISOLATION_SERIALIZABLE
	$tables = array()
	$query = null
	$ilDBInstance

Additional Inherited Members
Static Public Member Functions inherited from ilAtomQueryBase
static	isThereRiskThat ($isolation_level, $anomaly)
static	getPossibleAnomalies ($isolation_level)
static	checkIsolationLevel ($isolation_level)
static	checkAnomaly ($anomalie)
Data Fields inherited from ilAtomQueryBase
const	ITERATIONS = 10
Data Fields inherited from ilAtomQuery
const	LOCK_WRITE = 1
const	LOCK_READ = 2
const	ISOLATION_READ_UNCOMMITED = 1
const	ISOLATION_READ_COMMITED = 2
const	ISOLATION_REPEATED_READ = 3
const	ISOLATION_SERIALIZABLE = 4
const	ANO_LOST_UPDATES = 1
const	ANO_DIRTY_READ = 2
const	ANO_NON_REPEATED_READ = 3
const	ANO_PHANTOM = 4
Static Protected Attributes inherited from ilAtomQueryBase
static	$available_isolations_levels
static	$possible_anomalies
static	$anomalies_map

Detailed Description

Class ilAtomQueryLock.

Author

Fabian Schmid fs@st.nosp@m.uder.nosp@m.-raim.nosp@m.ann..nosp@m.ch

    Implements Atom-Queries with Table Locks, currently used in all other implementations than Galera

Definition at line 11 of file class.ilAtomQueryLock.php.

Member Function Documentation

getLocksForDBInstance()

ilAtomQueryLock::getLocksForDBInstance ( )

protected

Returns

array

Exceptions

Definition at line 56 of file class.ilAtomQueryLock.php.

References $locked_table_names, $table, and ilAtomQueryException\DB_ATOM_IDENTICAL_TABLES.

Referenced by runWithLocks().

    {
        $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;
    }

Here is the caller graph for this function:

run()

ilAtomQueryLock::run

(

)

Fire your Queries.

Exceptions

Implements ilAtomQuery.

Definition at line 29 of file class.ilAtomQueryLock.php.

References ilAtomQueryBase\checkBeforeRun(), and runWithLocks().

    {
        $this->checkBeforeRun();
        $this->runWithLocks();
    }

Here is the call graph for this function:

runWithLocks()

ilAtomQueryLock::runWithLocks ( )

protected

Exceptions

Definition at line 39 of file class.ilAtomQueryLock.php.

References getLocksForDBInstance(), and ilAtomQueryBase\runQueries().

Referenced by run().

    {
        $this->ilDBInstance->lockTables($this->getLocksForDBInstance());
        try {
            $this->runQueries();
        } catch (Exception $e) {
            $this->ilDBInstance->unlockTables();
            throw $e;
        }
        $this->ilDBInstance->unlockTables();
    }

Here is the call graph for this function:

Here is the caller graph for this function:

Field Documentation

$locked_table_full_names

ilAtomQueryLock::$locked_table_full_names = array()

protected

Definition at line 17 of file class.ilAtomQueryLock.php.

$locked_table_names

ilAtomQueryLock::$locked_table_names = array()

protected

Definition at line 21 of file class.ilAtomQueryLock.php.

Referenced by getLocksForDBInstance().

---

The documentation for this class was generated from the following file:

• Services/Database/classes/Atom/class.ilAtomQueryLock.php