Further categorylinks schema changes

[lhc/web/wiklou.git] / includes / installer / DatabaseUpdater.php

diff --git a/includes/installer/DatabaseUpdater.php b/includes/installer/DatabaseUpdater.php
index e3baaaa..0dc50b1 100644 (file)
--- a/includes/installer/DatabaseUpdater.php
+++ b/includes/installer/DatabaseUpdater.php
@@ -1,5 +1,11 @@
 <?php
-
+/**
+ * DBMS-specific updater helper.
+ *
+ * @file
+ * @ingroup Deployment
+ */
+ 
 /*
  * Class for handling database updates. Roughly based off of updaters.inc, with
  * a few improvements :)
@@ -52,6 +58,9 @@ abstract class DatabaseUpdater {
                        $this->getOldGlobalUpdates() );
                foreach ( $this->updates as $params ) {
                        $func = array_shift( $params );
+                       if( !is_array( $func ) && method_exists( $this, $func ) ) {
+                               $func = array( $this, $func );
+                       }
                        call_user_func_array( $func, $params );
                        flush();
                }
@@ -89,7 +98,7 @@ abstract class DatabaseUpdater {
         * version these like we do with our core updates, so they have to go
         * in 'always'
         */
-       private function getOldGlobalUpdates() {
+       protected function getOldGlobalUpdates() {
                global $wgUpdates, $wgExtNewFields, $wgExtNewTables,
                        $wgExtModifiedFields, $wgExtNewIndexes, $wgSharedDB, $wgSharedTables;
 
@@ -107,14 +116,14 @@ abstract class DatabaseUpdater {
 
                foreach ( $wgExtNewTables as $tableRecord ) {
                        $updates[] = array(
-                               'add_table', $tableRecord[0], $tableRecord[1], true
+                               'addTable', $tableRecord[0], $tableRecord[1], true
                        );
                }
 
                foreach ( $wgExtNewFields as $fieldRecord ) {
                        if ( $fieldRecord[0] != 'user' || $doUser ) {
                                $updates[] = array(
-                                       'add_field', $fieldRecord[0], $fieldRecord[1],
+                                       'addField', $fieldRecord[0], $fieldRecord[1],
                                                $fieldRecord[2], true
                                );
                        }
@@ -122,7 +131,7 @@ abstract class DatabaseUpdater {
 
                foreach ( $wgExtNewIndexes as $fieldRecord ) {
                        $updates[] = array(
-                               'add_index', $fieldRecord[0], $fieldRecord[1],
+                               'addIndex', $fieldRecord[0], $fieldRecord[1],
                                        $fieldRecord[2], true
                        );
                }
@@ -146,10 +155,87 @@ abstract class DatabaseUpdater {
         * @return Array
         */
        protected abstract function getCoreUpdateList();
-}
 
-class OracleUpdater extends DatabaseUpdater {
-       protected function getCoreUpdateList() {
-               return array();
+       /**
+        * Applies a SQL patch
+        * @param $path String Path to the patch file
+        * @param $isFullPath Boolean Whether to treat $path as a relative or not
+        */
+       protected function applyPatch( $path, $isFullPath = false ) {
+               if ( $isFullPath ) {
+                       $this->db->sourceFile( $path );
+               } else {
+                       $this->db->sourceFile( DatabaseBase::patchPath( $path ) );
+               }
+       }
+
+       /**
+        * Add a new table to the database
+        * @param $name String Name of the new table
+        * @param $patch String Path to the patch file
+        * @param $fullpath Boolean Whether to treat $patch path as a relative or not
+        */
+       protected function addTable( $name, $patch, $fullpath = false ) {
+               if ( $this->db->tableExists( $name ) ) {
+                       wfOut( "...$name table already exists.\n" );
+               } else {
+                       wfOut( "Creating $name table..." );
+                       $this->applyPatch( $patch, $fullpath );
+                       wfOut( "ok\n" );
+               }
+       }
+
+       /**
+        * Add a new field to an existing table
+        * @param $table String Name of the table to modify
+        * @param $field String Name of the new field
+        * @param $patch String Path to the patch file
+        * @param $fullpath Boolean Whether to treat $patch path as a relative or not
+        */
+       protected function addField( $table, $field, $patch, $fullpath = false ) {
+               if ( !$this->db->tableExists( $table ) ) {
+                       wfOut( "...$table table does not exist, skipping new field patch\n" );
+               } elseif ( $this->db->fieldExists( $table, $field ) ) {
+                       wfOut( "...have $field field in $table table.\n" );
+               } else {
+                       wfOut( "Adding $field field to table $table..." );
+                       $this->applyPatch( $patch, $fullpath );
+                       wfOut( "ok\n" );
+               }
+       }
+
+       /**
+        * Add a new index to an existing table
+        * @param $table String Name of the table to modify
+        * @param $index String Name of the new index
+        * @param $patch String Path to the patch file
+        * @param $fullpath Boolean Whether to treat $patch path as a relative or not
+        */
+       function addIndex( $table, $index, $patch, $fullpath = false ) {
+               if ( $this->db->indexExists( $table, $index ) ) {
+                       wfOut( "...$index key already set on $table table.\n" );
+               } else {
+                       wfOut( "Adding $index key to table $table... " );
+                       $this->applyPatch( $patch, $fullpath );
+                       wfOut( "ok\n" );
+               }
+       }
+
+       /**
+        * Drop a field from an existing table
+        *
+        * @param $table String Name of the table to modify
+        * @param $field String Name of the old field
+        * @param $patch String Path to the patch file
+        * @param $fullpath Boolean Whether to treat $patch path as a relative or not
+        */
+       function dropField( $table, $field, $patch, $fullpath = false ) {
+               if ( $this->db->fieldExists( $table, $field ) ) {
+                       wfOut( "Table $table contains $field field. Dropping... " );
+                       $this->applyPatch( $patch, $fullpath );
+                       wfOut( "ok\n" );
+               } else {
+                       wfOut( "...$table table does not contain $field field.\n" );
+               }
        }
 }