From 222b01f5169f1c7e69762e0e8904c24f78f71882 Mon Sep 17 00:00:00 2001 From: Pierre Schmitz Date: Wed, 28 Jul 2010 11:52:48 +0200 Subject: update to MediaWiki 1.16.0 --- maintenance/sql.php | 108 ++++++++++++++++++++++++++++++++-------------------- 1 file changed, 66 insertions(+), 42 deletions(-) (limited to 'maintenance/sql.php') diff --git a/maintenance/sql.php b/maintenance/sql.php index ab6546b9..fd4be19a 100644 --- a/maintenance/sql.php +++ b/maintenance/sql.php @@ -3,42 +3,78 @@ * Send SQL queries from the specified file to the database, performing * variable replacement along the way. * - * @file - * @ingroup Database Maintenance + * 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 + * + * @ingroup Maintenance */ -require_once( dirname(__FILE__) . '/' . 'commandLine.inc' ); +require_once( dirname(__FILE__) . '/Maintenance.php' ); -if ( isset( $options['help'] ) ) { - echo "Send SQL queries to a MediaWiki database.\nUsage: php sql.php []\n"; - exit( 1 ); -} +class MwSql extends Maintenance { + public function __construct() { + parent::__construct(); + $this->mDescription = "Send SQL queries to a MediaWiki database"; + } -if ( isset( $args[0] ) ) { - $fileName = $args[0]; - $file = fopen( $fileName, 'r' ); - $promptCallback = false; -} else { - $file = STDIN; - $promptObject = new SqlPromptPrinter( "> " ); - $promptCallback = $promptObject->cb(); -} + public function execute() { + if ( $this->hasArg() ) { + $fileName = $this->getArg(); + $file = fopen( $fileName, 'r' ); + $promptCallback = false; + } else { + $file = $this->getStdin(); + $promptObject = new SqlPromptPrinter( "> " ); + $promptCallback = $promptObject->cb(); + } + + if ( !$file ) + $this->error( "Unable to open input file", true ); -if ( !$file ) { - echo "Unable to open input file\n"; - exit( 1 ); -} + $dbw = wfGetDB( DB_MASTER ); + $error = $dbw->sourceStream( $file, $promptCallback, array( $this, 'sqlPrintResult' ) ); + if ( $error !== true ) { + $this->error( $error, true ); + } else { + exit( 0 ); + } + } -$dbw =& wfGetDB( DB_MASTER ); -$error = $dbw->sourceStream( $file, $promptCallback, 'sqlPrintResult' ); -if ( $error !== true ) { - echo $error; - exit( 1 ); -} else { - exit( 0 ); + /** + * Print the results, callback for $db->sourceStream() + * @param $res The results object + * @param $db Database object + */ + public function sqlPrintResult( $res, $db ) { + if ( !$res ) { + // Do nothing + } elseif ( is_object( $res ) && $res->numRows() ) { + foreach ( $res as $row ) { + $this->output( print_r( $row, true ) ); + } + } else { + $affected = $db->affectedRows(); + $this->output( "Query OK, $affected row(s) affected\n" ); + } + } + + public function getDbType() { + return Maintenance::DB_ADMIN; + } } -//----------------------------------------------------------------------------- class SqlPromptPrinter { function __construct( $prompt ) { $this->prompt = $prompt; @@ -53,17 +89,5 @@ class SqlPromptPrinter { } } -function sqlPrintResult( $res, $db ) { - if ( !$res ) { - // Do nothing - } elseif ( is_object( $res ) && $res->numRows() ) { - while ( $row = $res->fetchObject() ) { - print_r( $row ); - } - } else { - $affected = $db->affectedRows(); - echo "Query OK, $affected row(s) affected\n"; - } -} - - +$maintClass = "MwSql"; +require_once( DO_MAINTENANCE ); -- cgit v1.2.3-54-g00ecf