From 2da522bc46101ec52079b7a98cd999abbc1adda5 Mon Sep 17 00:00:00 2001
From: Tim Starling <tstarling@users.mediawiki.org>
Date: Sun, 25 Feb 2007 23:54:24 +0000
Subject: [PATCH] Job queue utility, currently Wikimedia-specific

---
 maintenance/nextJobDB.php | 65 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 maintenance/nextJobDB.php

diff --git a/maintenance/nextJobDB.php b/maintenance/nextJobDB.php
new file mode 100644
index 0000000000..f67b0266a3
--- /dev/null
+++ b/maintenance/nextJobDB.php
@@ -0,0 +1,65 @@
+<?php
+
+$user = 'wikiuser';
+$password = `/home/wikipedia/bin/wikiuser_pass`;
+$availableDBs = array_map( 'trim', file( "/home/wikipedia/common/pmtpa.dblist" ) );
+shuffle( $availableDBs );
+
+$dbs = array();
+
+# Connect to enwiki
+mysql_connect( 'db4', $user, $password ) || myerror();
+mysql_select_db( 'enwiki' ) || myerror();
+( $res = mysql_query( 'SELECT 1 FROM job LIMIT 1' ) ) || myerror();
+$enwikiHasJobs = ( mysql_num_rows( $res ) != 0 );
+mysql_free_result( $res );
+mysql_close();
+
+
+# Now try the rest
+mysql_connect( 'ixia', $user, $password ) || myerror();
+
+$sql = "(SELECT '-------------------------------------------')";
+foreach ( $availableDBs as $db ) {
+	if ( $db == 'enwiki' ) {
+		continue;
+	}
+	if ( $sql != '' ) {
+		$sql .= ' UNION ';
+	}
+	$sql .= "(SELECT '$db' FROM `$db`.job)";
+}
+$sql .= ' LIMIT 1,1';
+( $res = mysql_query( $sql ) ) || myerror();
+$row = mysql_fetch_row( $res );
+if ( $row ) {
+	$db = $row[0];
+} else {
+	$db = false;
+}
+
+mysql_free_result( $res );
+mysql_close();
+
+
+if ( $enwikiHasJobs ) {
+	if ( $db ) {
+		# Choose enwiki with arbitrary constant probability
+		if ( mt_rand( 0, 4 ) == 0 ) {
+			$db = 'enwiki';
+		}
+	} else {
+		$db = 'enwiki';
+	}
+}
+
+if ( $db ) {
+	echo $db;
+}
+
+function myerror() {
+	$f = fopen( 'php://stderr', 'w' );
+	fwrite( $f, mysql_error() . "\n" );
+	exit(1);
+}
+?>
-- 
2.20.1