summaryrefslogtreecommitdiff
path: root/maintenance/runBatchedQuery.php
diff options
context:
space:
mode:
authorPierre Schmitz <pierre@archlinux.de>2010-07-28 11:52:48 +0200
committerPierre Schmitz <pierre@archlinux.de>2010-07-28 11:52:48 +0200
commit222b01f5169f1c7e69762e0e8904c24f78f71882 (patch)
tree8e932e12546bb991357ec48eb1638d1770be7a35 /maintenance/runBatchedQuery.php
parent00ab76a6b686e98a914afc1975812d2b1aaa7016 (diff)
update to MediaWiki 1.16.0
Diffstat (limited to 'maintenance/runBatchedQuery.php')
-rw-r--r--maintenance/runBatchedQuery.php60
1 files changed, 60 insertions, 0 deletions
diff --git a/maintenance/runBatchedQuery.php b/maintenance/runBatchedQuery.php
new file mode 100644
index 00000000..03c56aa9
--- /dev/null
+++ b/maintenance/runBatchedQuery.php
@@ -0,0 +1,60 @@
+<?php
+/**
+ * Run a database query in batches and wait for slaves. This is used on large
+ * wikis to prevent replication lag from going through the roof when executing
+ * large write queries.
+ *
+ * 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__) . '/Maintenance.php' );
+
+class BatchedQueryRunner extends Maintenance {
+ public function __construct() {
+ parent::__construct();
+ $this->mDescription = "Run a query repeatedly until it affects 0 rows, and wait for slaves in between.\n" .
+ "NOTE: You need to set a LIMIT clause yourself.";
+ $this->addOption( 'wait', "Wait for replication lag to go down to this value. Default: 5", false, true );
+ }
+
+ public function execute() {
+ if ( !$this->hasArg() )
+ $this->error( "No query specified. Specify the query as a command line parameter.", true );
+
+ $query = $this->getArg();
+ $wait = $this->getOption( 'wait', 5 );
+ $n = 1;
+ $dbw = wfGetDb( DB_MASTER );
+ do {
+ $this->output( "Batch $n: " );
+ $n++;
+ $dbw->query( $query );
+ $affected = $dbw->affectedRows();
+ $this->output( "$affected rows\n" );
+ wfWaitForSlaves( $wait );
+ } while ( $affected > 0 );
+ }
+
+ public function getDbType() {
+ return Maintenance::DB_ADMIN;
+ }
+}
+
+
+$maintClass = "BatchedQueryRunner";
+require_once( DO_MAINTENANCE );