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() );
                }

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

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

}