class.ilAtomQueryTransaction.php

Go to the documentation of this file.

<?php
require_once('./Services/Database/exceptions/exception.ilAtomQueryException.php');
require_once('./Services/Database/interfaces/interface.ilAtomQuery.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);
        }
}