class.ilAtomQueryTransaction.php

Go to the documentation of this file.

<?php

class ilAtomQueryTransaction extends ilAtomQueryBase implements ilAtomQuery
{

    public function run()
    {
        $this->checkBeforeRun();
        $this->runWithTransactions();
    }


    protected function runWithTransactions()
    {
        $i = 0;
        do {
            $e = null;
            try {
                $this->ilDBInstance->beginTransaction();
                $this->runQueries();
                $this->ilDBInstance->commit();
            } catch (ilDatabaseException $e) {
                $this->ilDBInstance->rollback();
                if ($i >= self::ITERATIONS - 1) {
                    throw $e;
                }
            }
            $i++;
        } while ($e instanceof ilDatabaseException);
    }
}