class.ilAtomQueryTransaction.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilAtomQueryTransaction extends ilAtomQueryBase implements ilAtomQuery
{
    public function run(): void
    {
        $this->checkBeforeRun();
        $this->runWithTransactions();
    }


    protected function runWithTransactions(): void
    {
        $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);
    }
}