DataUpdate.php

Go to the documentation of this file.

<?php
abstract class DataUpdate implements DeferrableUpdate {
    public function __construct() {
        # noop
    }

    public function beginTransaction() {
        //noop
    }

    public function commitTransaction() {
        //noop
    }

    public function rollbackTransaction() {
        //noop
    }

    public static function runUpdates( $updates ) {
        if ( empty( $updates ) ) {
            return; # nothing to do
        }

        $open_transactions = array();
        $exception = null;

        try {
            // begin transactions
            foreach ( $updates as $update ) {
                $update->beginTransaction();
                $open_transactions[] = $update;
            }

            // do work
            foreach ( $updates as $update ) {
                $update->doUpdate();
            }

            // commit transactions
            while ( count( $open_transactions ) > 0 ) {
                $trans = array_pop( $open_transactions );
                $trans->commitTransaction();
            }
        } catch ( Exception $ex ) {
            $exception = $ex;
            wfDebug( "Caught exception, will rethrow after rollback: " .
                $ex->getMessage() . "\n" );
        }

        // rollback remaining transactions
        while ( count( $open_transactions ) > 0 ) {
            $trans = array_pop( $open_transactions );
            $trans->rollbackTransaction();
        }

        if ( $exception ) {
            throw $exception; // rethrow after cleanup
        }
    }
}