sql.php

Go to the documentation of this file.

<?php
require_once( __DIR__ . '/Maintenance.php' );

class MwSql extends Maintenance {
        public function __construct() {
                parent::__construct();
                $this->mDescription = "Send SQL queries to a MediaWiki database";
        }

        public function execute() {
                $dbw = wfGetDB( DB_MASTER );
                if ( $this->hasArg() ) {
                        $fileName = $this->getArg();
                        $file = fopen( $fileName, 'r' );
                        if ( !$file ) {
                                $this->error( "Unable to open input file", true );
                        }

                        $error = $dbw->sourceStream( $file, false, array( $this, 'sqlPrintResult' ) );
                        if ( $error !== true ) {
                                $this->error( $error, true );
                        } else {
                                exit( 0 );
                        }
                }

                $useReadline = function_exists( 'readline_add_history' )
                                && Maintenance::posix_isatty( 0 /*STDIN*/ );

                if ( $useReadline ) {
                        global $IP;
                        $historyFile = isset( $_ENV['HOME'] ) ?
                                        "{$_ENV['HOME']}/.mwsql_history" : "$IP/maintenance/.mwsql_history";
                        readline_read_history( $historyFile );
                }

                $wholeLine = '';
                while ( ( $line = Maintenance::readconsole() ) !== false ) {
                        $done = $dbw->streamStatementEnd( $wholeLine, $line );

                        $wholeLine .= $line;

                        if ( !$done ) {
                                continue;
                        }
                        if ( $useReadline ) {
                                readline_add_history( $wholeLine );
                                readline_write_history( $historyFile );
                        }
                        try{
                                $res = $dbw->query( $wholeLine );
                                $this->sqlPrintResult( $res, $dbw );
                                $wholeLine = '';
                        } catch (DBQueryError $e) {
                                $this->error( $e, true );
                        }
                }
        }

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

$maintClass = "MwSql";
require_once( RUN_MAINTENANCE_IF_MAIN );