Merge "Added a Redis client for object cache storage"
[lhc/web/wiklou.git] / includes / installer / DatabaseInstaller.php
index 67f2479..0beedfa 100644 (file)
@@ -1,39 +1,60 @@
 <?php
+/**
+ * DBMS-specific installation helper.
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ * http://www.gnu.org/copyleft/gpl.html
+ *
+ * @file
+ * @ingroup Deployment
+ */
 
 /**
  * Base class for DBMS-specific installation helper classes.
- * 
+ *
  * @ingroup Deployment
  * @since 1.17
  */
 abstract class DatabaseInstaller {
-       
+
        /**
         * The Installer object.
-        * 
+        *
         * TODO: naming this parent is confusing, 'installer' would be clearer.
-        * 
-        * @var Installer
+        *
+        * @var WebInstaller
         */
        public $parent;
 
        /**
         * The database connection.
-        * 
+        *
         * @var DatabaseBase
         */
-       public $db;
+       public $db = null;
 
        /**
         * Internal variables for installation.
-        * 
+        *
         * @var array
         */
        protected $internalDefaults = array();
 
        /**
         * Array of MW configuration globals this class uses.
-        * 
+        *
         * @var array
         */
        protected $globalNames = array();
@@ -44,13 +65,22 @@ abstract class DatabaseInstaller {
        public abstract function getName();
 
        /**
-        * @return true if the client library is compiled in.
+        * @return bool Returns true if the client library is compiled in.
         */
        public abstract function isCompiled();
 
+       /**
+        * Checks for installation prerequisites other than those checked by isCompiled()
+        * @since 1.19
+        * @return Status
+        */
+       public function checkPrerequisites() {
+               return Status::newGood();
+       }
+
        /**
         * Get HTML for a web form that configures this database. Configuration
-        * at this time should be the minimum needed to connect and test 
+        * at this time should be the minimum needed to connect and test
         * whether install or upgrade is required.
         *
         * If this is called, $this->parent can be assumed to be a WebInstaller.
@@ -59,7 +89,7 @@ abstract class DatabaseInstaller {
 
        /**
         * Set variables based on the request array, assuming it was submitted
-        * via the form returned by getConnectForm(). Validate the connection 
+        * via the form returned by getConnectForm(). Validate the connection
         * settings by attempting to connect with them.
         *
         * If this is called, $this->parent can be assumed to be a WebInstaller.
@@ -71,28 +101,34 @@ abstract class DatabaseInstaller {
        /**
         * Get HTML for a web form that retrieves settings used for installation.
         * $this->parent can be assumed to be a WebInstaller.
-        * If the DB type has no settings beyond those already configured with 
+        * If the DB type has no settings beyond those already configured with
         * getConnectForm(), this should return false.
+        * @return bool
         */
-       public abstract function getSettingsForm();
+       public function getSettingsForm() {
+               return false;
+       }
 
        /**
         * Set variables based on the request array, assuming it was submitted via
         * the form return by getSettingsForm().
-        * 
+        *
         * @return Status
         */
-       public abstract function submitSettingsForm();
+       public function submitSettingsForm() {
+               return Status::newGood();
+       }
 
        /**
-        * Connect to the database using the administrative user/password currently
-        * defined in the session. On success, return the connection, on failure, 
-        * return a Status object.
+        * Open a connection to the database using the administrative user/password
+        * currently defined in the session, without any caching. Returns a status
+        * object. On success, the status object will contain a Database object in
+        * its value member.
         *
-        * This may be called multiple times, so the result should be cached.
+        * @return Status
         */
-       public abstract function getConnection();
-       
+       public abstract function openConnection();
+
        /**
         * Create the database and return a Status object indicating success or
         * failure.
@@ -101,57 +137,178 @@ abstract class DatabaseInstaller {
         */
        public abstract function setupDatabase();
 
+       /**
+        * Connect to the database using the administrative user/password currently
+        * defined in the session. Returns a status object. On success, the status
+        * object will contain a Database object in its value member.
+        *
+        * This will return a cached connection if one is available.
+        *
+        * @return Status
+        */
+       public function getConnection() {
+               if ( $this->db ) {
+                       return Status::newGood( $this->db );
+               }
+
+               $status = $this->openConnection();
+               if ( $status->isOK() ) {
+                       $this->db = $status->value;
+                       // Enable autocommit
+                       $this->db->clearFlag( DBO_TRX );
+                       $this->db->commit( __METHOD__ );
+               }
+               return $status;
+       }
+
        /**
         * Create database tables from scratch.
-        * 
+        *
         * @return Status
         */
-       public abstract function createTables();
+       public function createTables() {
+               $status = $this->getConnection();
+               if ( !$status->isOK() ) {
+                       return $status;
+               }
+               $this->db->selectDB( $this->getVar( 'wgDBname' ) );
+
+               if( $this->db->tableExists( 'archive', __METHOD__ ) ) {
+                       $status->warning( 'config-install-tables-exist' );
+                       $this->enableLB();
+                       return $status;
+               }
+
+               $this->db->setFlag( DBO_DDLMODE ); // For Oracle's handling of schema files
+               $this->db->begin( __METHOD__ );
+
+               $error = $this->db->sourceFile( $this->db->getSchemaPath() );
+               if( $error !== true ) {
+                       $this->db->reportQueryError( $error, 0, '', __METHOD__ );
+                       $this->db->rollback( __METHOD__ );
+                       $status->fatal( 'config-install-tables-failed', $error );
+               } else {
+                       $this->db->commit( __METHOD__ );
+               }
+               // Resume normal operations
+               if( $status->isOk() ) {
+                       $this->enableLB();
+               }
+               return $status;
+       }
+
+       /**
+        * Create the tables for each extension the user enabled
+        * @return Status
+        */
+       public function createExtensionTables() {
+               $status = $this->getConnection();
+               if ( !$status->isOK() ) {
+                       return $status;
+               }
+
+               // Now run updates to create tables for old extensions
+               DatabaseUpdater::newForDB( $this->db )->doUpdates( array( 'extensions' ) );
+
+               return $status;
+       }
 
        /**
         * Get the DBMS-specific options for LocalSettings.php generation.
-        * 
+        *
         * @return String
         */
-       public abstract function getLocalSettings();    
-       
+       public abstract function getLocalSettings();
+
+       /**
+        * Override this to provide DBMS-specific schema variables, to be
+        * substituted into tables.sql and other schema files.
+        * @return array
+        */
+       public function getSchemaVars() {
+               return array();
+       }
+
+       /**
+        * Set appropriate schema variables in the current database connection.
+        *
+        * This should be called after any request data has been imported, but before
+        * any write operations to the database.
+        */
+       public function setupSchemaVars() {
+               $status = $this->getConnection();
+               if ( $status->isOK() ) {
+                       $status->value->setSchemaVars( $this->getSchemaVars() );
+               } else {
+                       throw new MWException( __METHOD__.': unexpected DB connection error' );
+               }
+       }
+
+       /**
+        * Set up LBFactory so that wfGetDB() etc. works.
+        * We set up a special LBFactory instance which returns the current
+        * installer connection.
+        */
+       public function enableLB() {
+               $status = $this->getConnection();
+               if ( !$status->isOK() ) {
+                       throw new MWException( __METHOD__.': unexpected DB connection error' );
+               }
+               LBFactory::setInstance( new LBFactory_Single( array(
+                       'connection' => $status->value ) ) );
+       }
+
        /**
         * Perform database upgrades
-        * @todo make abstract
+        *
+        * @return Boolean
         */
-       /*abstract*/ function doUpgrade() {
-               return false;
+       public function doUpgrade() {
+               $this->setupSchemaVars();
+               $this->enableLB();
+
+               $ret = true;
+               ob_start( array( $this, 'outputHandler' ) );
+               try {
+                       $up = DatabaseUpdater::newForDB( $this->db );
+                       $up->doUpdates();
+               } catch ( MWException $e ) {
+                       echo "\nAn error occurred:\n";
+                       echo $e->getText();
+                       $ret = false;
+               }
+               ob_end_flush();
+               return $ret;
        }
-       
+
        /**
         * Allow DB installers a chance to make last-minute changes before installation
         * occurs. This happens before setupDatabase() or createTables() is called, but
         * long after the constructor. Helpful for things like modifying setup steps :)
         */
        public function preInstall() {
-       
+
        }
 
        /**
-        * Get an array of MW configuration globals that will be configured by this class.
+        * Allow DB installers a chance to make checks before upgrade.
         */
-       public function getGlobalNames() {
-               return $this->globalNames;
-       }               
+       public function preUpgrade() {
+
+       }
 
        /**
-        * Return any table options to be applied to all tables that don't
-        * override them.
-        * 
-        * @return Array
+        * Get an array of MW configuration globals that will be configured by this class.
+        * @return array
         */
-       public function getTableOptions() {
-               return array();
+       public function getGlobalNames() {
+               return $this->globalNames;
        }
 
-       /** 
+       /**
         * Construct and initialise parent.
         * This is typically only called from Installer::getDBInstaller()
+        * @param $parent
         */
        public function __construct( $parent ) {
                $this->parent = $parent;
@@ -160,8 +317,10 @@ abstract class DatabaseInstaller {
        /**
         * Convenience function.
         * Check if a named extension is present.
-        * 
+        *
         * @see wfDl
+        * @param $name
+        * @return bool
         */
        protected static function checkExtension( $name ) {
                wfSuppressWarnings();
@@ -172,14 +331,16 @@ abstract class DatabaseInstaller {
 
        /**
         * Get the internationalised name for this DBMS.
+        * @return String
         */
        public function getReadableName() {
                return wfMsg( 'config-type-' . $this->getName() );
        }
-       
+
        /**
         * Get a name=>value map of MW configuration globals that overrides.
         * DefaultSettings.php
+        * @return array
         */
        public function getGlobalDefaults() {
                return array();
@@ -187,6 +348,7 @@ abstract class DatabaseInstaller {
 
        /**
         * Get a name=>value map of internal variables used during installation.
+        * @return array
         */
        public function getInternalDefaults() {
                return $this->internalDefaults;
@@ -194,6 +356,9 @@ abstract class DatabaseInstaller {
 
        /**
         * Get a variable, taking local defaults into account.
+        * @param $var string
+        * @param $default null
+        * @return mixed
         */
        public function getVar( $var, $default = null ) {
                $defaults = $this->getGlobalDefaults();
@@ -208,6 +373,8 @@ abstract class DatabaseInstaller {
 
        /**
         * Convenience alias for $this->parent->setVar()
+        * @param $name string
+        * @param $value mixed
         */
        public function setVar( $name, $value ) {
                $this->parent->setVar( $name, $value );
@@ -215,39 +382,61 @@ abstract class DatabaseInstaller {
 
        /**
         * Get a labelled text box to configure a local variable.
+        *
+        * @param $var string
+        * @param $label string
+        * @param $attribs array
+        * @param $helpData string
+        * @return string
         */
-       public function getTextBox( $var, $label, $attribs = array() ) {
+       public function getTextBox( $var, $label, $attribs = array(), $helpData = "" ) {
                $name = $this->getName() . '_' . $var;
                $value = $this->getVar( $var );
+               if ( !isset( $attribs ) ) {
+                       $attribs = array();
+               }
                return $this->parent->getTextBox( array(
                        'var' => $var,
                        'label' => $label,
                        'attribs' => $attribs,
                        'controlName' => $name,
-                       'value' => $value
+                       'value' => $value,
+                       'help' => $helpData
                ) );
        }
 
        /**
         * Get a labelled password box to configure a local variable.
         * Implements password hiding.
+        *
+        * @param $var string
+        * @param $label string
+        * @param $attribs array
+        * @param $helpData string
+        * @return string
         */
-       public function getPasswordBox( $var, $label, $attribs = array() ) {
+       public function getPasswordBox( $var, $label, $attribs = array(), $helpData = "" ) {
                $name = $this->getName() . '_' . $var;
                $value = $this->getVar( $var );
+               if ( !isset( $attribs ) ) {
+                       $attribs = array();
+               }
                return $this->parent->getPasswordBox( array(
                        'var' => $var,
                        'label' => $label,
                        'attribs' => $attribs,
                        'controlName' => $name,
-                       'value' => $value
+                       'value' => $value,
+                       'help' => $helpData
                ) );
        }
 
        /**
         * Get a labelled checkbox to configure a local boolean variable.
+        *
+        * @return string
         */
-       public function getCheckBox( $var, $label, $attribs = array() ) {
+       public function getCheckBox( $var, $label, $attribs = array(), $helpData = "" ) {
                $name = $this->getName() . '_' . $var;
                $value = $this->getVar( $var );
                return $this->parent->getCheckBox( array(
@@ -256,6 +445,7 @@ abstract class DatabaseInstaller {
                        'attribs' => $attribs,
                        'controlName' => $name,
                        'value' => $value,
+                       'help' => $helpData
                ));
        }
 
@@ -270,6 +460,7 @@ abstract class DatabaseInstaller {
         *      values:         List of allowed values (required)
         *      itemAttribs     Array of attribute arrays, outer key is the value name (optional)
         *
+        * @return string
         */
        public function getRadioSet( $params ) {
                $params['controlName'] = $this->getName() . '_' . $params['var'];
@@ -282,17 +473,18 @@ abstract class DatabaseInstaller {
         * Assumes that variables containing "password" in the name are (potentially
         * fake) passwords.
         * @param $varNames Array
+        * @return array
         */
        public function setVarsFromRequest( $varNames ) {
                return $this->parent->setVarsFromRequest( $varNames, $this->getName() . '_' );
        }
 
        /**
-        * Determine whether an existing installation of MediaWiki is present in 
-        * the configured administrative connection. Returns true if there is 
+        * Determine whether an existing installation of MediaWiki is present in
+        * the configured administrative connection. Returns true if there is
         * such a wiki, false if the database doesn't exist.
         *
-        * Traditionally, this is done by testing for the existence of either 
+        * Traditionally, this is done by testing for the existence of either
         * the revision table or the cur table.
         *
         * @return Boolean
@@ -306,24 +498,26 @@ abstract class DatabaseInstaller {
                if ( !$this->db->selectDB( $this->getVar( 'wgDBname' ) ) ) {
                        return false;
                }
-               return $this->db->tableExists( 'cur' ) || $this->db->tableExists( 'revision' );
+               return $this->db->tableExists( 'cur', __METHOD__ ) || $this->db->tableExists( 'revision', __METHOD__ );
        }
 
        /**
         * Get a standard install-user fieldset.
+        *
+        * @return String
         */
        public function getInstallUserBox() {
                return
-                       Xml::openElement( 'fieldset' ) .
-                       Xml::element( 'legend', array(), wfMsg( 'config-db-install-account' ) ) .
-                       $this->getTextBox( '_InstallUser', 'config-db-username' ) .
-                       $this->getPasswordBox( '_InstallPassword', 'config-db-password' ) .
-                       $this->parent->getHelpBox( 'config-db-install-help' ) .
-                       Xml::closeElement( 'fieldset' );
+                       Html::openElement( 'fieldset' ) .
+                       Html::element( 'legend', array(), wfMsg( 'config-db-install-account' ) ) .
+                       $this->getTextBox( '_InstallUser', 'config-db-username', array( 'dir' => 'ltr' ), $this->parent->getHelpBox( 'config-db-install-username' ) ) .
+                       $this->getPasswordBox( '_InstallPassword', 'config-db-password', array( 'dir' => 'ltr' ), $this->parent->getHelpBox( 'config-db-install-password' ) ) .
+                       Html::closeElement( 'fieldset' );
        }
 
        /**
         * Submit a standard install user fieldset.
+        * @return Status
         */
        public function submitInstallUserBox() {
                $this->setVarsFromRequest( array( '_InstallUser', '_InstallPassword' ) );
@@ -334,16 +528,18 @@ abstract class DatabaseInstaller {
         * Get a standard web-user fieldset
         * @param $noCreateMsg String: Message to display instead of the creation checkbox.
         *   Set this to false to show a creation checkbox.
+        *
+        * @return String
         */
        public function getWebUserBox( $noCreateMsg = false ) {
-               $name = $this->getName();
-               $s = Xml::openElement( 'fieldset' ) .
-                       Xml::element( 'legend', array(), wfMsg( 'config-db-web-account' ) ) .
-                       $this->getCheckBox( 
+               $wrapperStyle = $this->getVar( '_SameAccount' ) ? 'display: none' : '';
+               $s = Html::openElement( 'fieldset' ) .
+                       Html::element( 'legend', array(), wfMsg( 'config-db-web-account' ) ) .
+                       $this->getCheckBox(
                                '_SameAccount', 'config-db-web-account-same',
                                array( 'class' => 'hideShowRadio', 'rel' => 'dbOtherAccount' )
                        ) .
-                       Xml::openElement( 'div', array( 'id' => 'dbOtherAccount', 'style' => 'display: none;' ) ) .
+                       Html::openElement( 'div', array( 'id' => 'dbOtherAccount', 'style' => $wrapperStyle ) ) .
                        $this->getTextBox( 'wgDBuser', 'config-db-username' ) .
                        $this->getPasswordBox( 'wgDBpassword', 'config-db-password' ) .
                        $this->parent->getHelpBox( 'config-db-web-help' );
@@ -352,30 +548,36 @@ abstract class DatabaseInstaller {
                } else {
                        $s .= $this->getCheckBox( '_CreateDBAccount', 'config-db-web-create' );
                }
-               $s .= Xml::closeElement( 'div' ) . Xml::closeElement( 'fieldset' );
+               $s .= Html::closeElement( 'div' ) . Html::closeElement( 'fieldset' );
                return $s;
        }
 
        /**
         * Submit the form from getWebUserBox().
-        * 
+        *
         * @return Status
         */
        public function submitWebUserBox() {
                $this->setVarsFromRequest(
                        array( 'wgDBuser', 'wgDBpassword', '_SameAccount', '_CreateDBAccount' )
                );
-               
+
                if ( $this->getVar( '_SameAccount' ) ) {
                        $this->setVar( 'wgDBuser', $this->getVar( '_InstallUser' ) );
                        $this->setVar( 'wgDBpassword', $this->getVar( '_InstallPassword' ) );
                }
-               
+
+               if( $this->getVar( '_CreateDBAccount' ) && strval( $this->getVar( 'wgDBpassword' ) ) == '' ) {
+                       return Status::newFatal( 'config-db-password-empty', $this->getVar( 'wgDBuser' ) );
+               }
+
                return Status::newGood();
        }
 
        /**
         * Common function for databases that don't understand the MySQLish syntax of interwiki.sql.
+        *
+        * @return Status
         */
        public function populateInterwikiTable() {
                $status = $this->getConnection();
@@ -389,11 +591,13 @@ abstract class DatabaseInstaller {
                        return $status;
                }
                global $IP;
+               wfSuppressWarnings();
                $rows = file( "$IP/maintenance/interwiki.list",
                        FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES );
+               wfRestoreWarnings();
                $interwikis = array();
                if ( !$rows ) {
-                       return Status::newFatal( 'config-install-interwiki-sql' );
+                       return Status::newFatal( 'config-install-interwiki-list' );
                }
                foreach( $rows as $row ) {
                        $row = preg_replace( '/^\s*([^#]*?)\s*(#.*)?$/', '\\1', $row ); // strip comments - whee
@@ -408,4 +612,7 @@ abstract class DatabaseInstaller {
                return Status::newGood();
        }
 
-}
\ No newline at end of file
+       public function outputHandler( $string ) {
+               return htmlspecialchars( $string );
+       }
+}