include_once( "FulltextStoplist.php" );
include_once( "CacheManager.php" );
define( "DB_READ", -1 );
define( "DB_WRITE", -2 );
define( "DB_LAST", -3 );
$wgLastDatabaseQuery = "";
function wfGetDB( $altuser = "", $altpassword = "", $altserver = "", $altdb = "" )
{
global $wgDBserver, $wgDBuser, $wgDBpassword;
global $wgDBname, $wgDBconnection, $wgEmergencyContact;
$noconn = wfMsgNoDB( "noconnect", $wgDBserver );
$nodb = wfMsgNoDB( "nodb", $wgDBname );
$helpme = "\n
If this error persists after reloading and clearing " .
"your browser cache, please notify the Wikipedia developers.
";
if ( $altuser != "" ) {
$serve = ($altserver ? $altserver : $wgDBserver );
$db = ($altdb ? $altdb : $wgDBname );
$wgDBconnection = mysql_connect( $serve, $altuser, $altpassword )
or die( "bad sql user" );
mysql_select_db( $db, $wgDBconnection ) or die(
htmlspecialchars(mysql_error()) );
}
if ( ! $wgDBconnection ) {
@$wgDBconnection = mysql_pconnect( $wgDBserver, $wgDBuser, $wgDBpassword )
or wfEmergencyAbort();
if( !mysql_select_db( $wgDBname, $wgDBconnection ) ) {
/* Persistent connections may become stuck in an unusable state */
wfDebug( "Persistent connection is broken?\n", true );
@$wgDBconnection = mysql_connect( $wgDBserver, $wgDBuser, $wgDBpassword )
or wfEmergencyAbort();
@mysql_select_db( $wgDBname, $wgDBconnection )
or wfEmergencyAbort();
}
}
# mysql_ping( $wgDBconnection );
return $wgDBconnection;
}
/* Call this function if we couldn't contact the database...
We'll try to use the cache to display something in the meantime */
function wfEmergencyAbort( $msg = "" ) {
global $wgTitle, $wgUseFileCache, $title, $wgOutputEncoding;
header( "Content-type: text/html; charset=$wgOutputEncoding" );
if($msg == "") $msg = wfMsgNoDB( "noconnect" );
$text = $msg;
if($wgUseFileCache) {
if($wgTitle) {
$t =& $wgTitle;
} else {
if($title) {
$t = Title::newFromURL( $title );
} else {
$t = Title::newFromText( wfMsgNoDB( "mainpage" ) );
}
}
$cache = new CacheManager( $t );
if( $cache->isFileCached() ) {
$msg = "$msg
\n" .
wfMsgNoDB( "cachederror" ) . "
\n";
$tag = "";
$text = str_replace(
$tag,
$tag . $msg,
$cache->fetchPageText() );
}
}
/* Don't cache error pages! They cause no end of trouble... */
header( "Cache-control: none" );
header( "Pragma: nocache" );
echo $text;
exit;
}
# $db: DB_READ = -1 read from slave (or only server)
# DB_WRITE = -2 write to master (or only server)
# 0,1,2,... query a database with a specific index
# Replication is not actually implemented just yet
function wfQuery( $sql, $db, $fname = "" )
{
global $wgLastDatabaseQuery, $wgOut, $wgDebugDumpSql;
global $wgProfiling;
if ( $wgProfiling ) {
# wfGeneralizeSQL will probably cut down the query to reasonable
# logging size most of the time. The substr is really just a sanity check.
$profName = "wfQuery: " . substr( wfGeneralizeSQL( $sql ), 0, 255 );
wfProfileIn( $profName );
}
if ( !is_numeric( $db ) ) {
# Someone has tried to call this the old way
$wgOut->fatalError( wfMsgNoDB( "wrong_wfQuery_params", $db, $sql ) );
}
$wgLastDatabaseQuery = $sql;
if( $wgDebugDumpSql ) {
$sqlx = substr( $sql, 0, 500 );
$sqlx = wordwrap(strtr($sqlx,"\t\n"," "));
wfDebug( "SQL: $sqlx\n" );
}
$conn = wfGetDB();
$ret = mysql_query( $sql, $conn );
if ( false === $ret ) {
$wgOut->databaseError( $fname );
exit;
}
if ( $wgProfiling ) {
wfProfileOut( $profName );
}
return $ret;
}
function wfFreeResult( $res ) { mysql_free_result( $res ); }
function wfFetchObject( $res ) { return mysql_fetch_object( $res ); }
function wfNumRows( $res ) { return mysql_num_rows( $res ); }
function wfNumFields( $res ) { return mysql_num_fields( $res ); }
function wfFieldName( $res, $n ) { return mysql_field_name( $res, $n ); }
function wfInsertId() { return mysql_insert_id( wfGetDB() ); }
function wfDataSeek( $res, $row ) { return mysql_data_seek( $res, $row ); }
function wfLastErrno() { return mysql_errno(); }
function wfLastError() { return mysql_error(); }
function wfAffectedRows() { return mysql_affected_rows( wfGetDB() ); }
function wfLastDBquery()
{
global $wgLastDatabaseQuery;
return $wgLastDatabaseQuery;
}
function wfSetSQL( $table, $var, $value, $cond )
{
$sql = "UPDATE $table SET $var = '" .
wfStrencode( $value ) . "' WHERE ($cond)";
wfQuery( $sql, DB_WRITE, "wfSetSQL" );
}
function wfGetSQL( $table, $var, $cond )
{
$sql = "SELECT $var FROM $table WHERE ($cond)";
$result = wfQuery( $sql, DB_READ, "wfGetSQL" );
$ret = "";
if ( mysql_num_rows( $result ) > 0 ) {
$s = mysql_fetch_object( $result );
$ret = $s->$var;
mysql_free_result( $result );
}
return $ret;
}
function wfStrencode( $s )
{
return addslashes( $s );
}
# Ideally we'd be using actual time fields in the db
function wfTimestamp2Unix( $ts ) {
return gmmktime( ( (int)substr( $ts, 8, 2) ),
(int)substr( $ts, 10, 2 ), (int)substr( $ts, 12, 2 ),
(int)substr( $ts, 4, 2 ), (int)substr( $ts, 6, 2 ),
(int)substr( $ts, 0, 4 ) );
}
function wfUnix2Timestamp( $unixtime ) {
return gmdate( "YmdHis", $unixtime );
}
function wfTimestampNow() {
# return NOW
return gmdate( "YmdHis" );
}
# Sorting hack for MySQL 3, which doesn't use index sorts for DESC
function wfInvertTimestamp( $ts ) {
return strtr(
$ts,
"0123456789",
"9876543210"
);
}
# Removes most variables from an SQL query and replaces them with X or N for numbers.
# It's only slightly flawed. Don't use for anything important.
function wfGeneralizeSQL( $sql )
{
# This could be done faster with some arrays and a single preg_replace,
# but this show more clearly what's going on. Which may be a good thing.
$sql = preg_replace( "/'.*?[^\\\\]'/", "'X'", $sql );
$sql = preg_replace ( "/-?\d+/" , "N", $sql);
$sql = preg_replace ( "/\s+/", " ", $sql);
return $sql;
}
function wfFieldExists( $table, $field )
{
$fname = "wfFieldExists";
$res = wfQuery( "DESCRIBE $table", DB_READ, $fname );
$found = false;
while ( $row = wfFetchObject( $res ) ) {
if ( $row->Field == $field ) {
$found = true;
break;
}
}
return $found;
}
function wfIndexExists( $table, $index )
{
global $wgDBname;
$fname = "wfIndexExists";
$sql = "SHOW INDEXES FROM $table";
$res = wfQuery( $sql, DB_READ, $fname );
$found = false;
while ( $row = wfFetchObject( $res ) ) {
if ( $row->Key_name == $index ) {
$found = true;
break;
}
}
return $found;
}
?>