* wpdb::prepare( "SELECT * FROM `table` WHERE `column` = %s AND `field` = %d", "foo", 1337 )
*
*
* @link http://php.net/sprintf Description of syntax.
* @since 2.3.0
*
* @param string $query Query statement with sprintf()-like placeholders
* @param array|mixed $args The array of variables to substitute into the query's placeholders if being called like {@link http://php.net/vsprintf vsprintf()}, or the first variable to substitute into the query's placeholders if being called like {@link http://php.net/sprintf sprintf()}.
* @param mixed $args,... further variables to substitute into the query's placeholders if being called like {@link http://php.net/sprintf sprintf()}.
* @return null|string Sanitized query string
*/
function prepare($query = null) { // ( $query, *$args )
if ( is_null( $query ) )
return;
$args = func_get_args();
array_shift($args);
// If args were passed as an array (as in vsprintf), move them up
if ( isset($args[0]) && is_array($args[0]) )
$args = $args[0];
$query = str_replace("'%s'", '%s', $query); // in case someone mistakenly already singlequoted it
$query = str_replace('"%s"', '%s', $query); // doublequote unquoting
$query = str_replace('%s', "'%s'", $query); // quote the strings
array_walk($args, array(&$this, 'escape_by_ref'));
return @vsprintf($query, $args);
}
/**
* Get SQL/DB error
* @param string $str Error string
*/
function get_error( $str = '' ) {
if ( empty($str) ) {
if ( $this->last_error )
$str = $this->last_error;
else
return false;
}
$error_str = "WordPress database error $str for query $this->last_query";
if ( $caller = $this->get_caller() )
$error_str .= " made by $caller";
if ( class_exists( 'WP_Error' ) )
return new WP_Error( 'db_query', $error_str, array( 'query' => $this->last_query, 'error' => $str, 'caller' => $caller ) );
else
return array( 'query' => $this->last_query, 'error' => $str, 'caller' => $caller, 'error_str' => $error_str );
}
/**
* Print SQL/DB error
* @param string $str Error string
*/
function print_error($str = '') {
if ( $this->suppress_errors )
return false;
$error = $this->get_error( $str );
if ( is_object( $error ) && is_a( $error, 'WP_Error' ) ) {
$err = $error->get_error_data();
$err['error_str'] = $error->get_error_message();
} else {
$err =& $error;
}
$log_file = ini_get('error_log');
if ( !empty($log_file) && ('syslog' != $log_file) && !is_writable($log_file) && function_exists( 'error_log' ) )
error_log($err['error_str'], 0);
// Is error output turned on or not
if ( !$this->show_errors )
return false;
$str = htmlspecialchars($err['str'], ENT_QUOTES);
$query = htmlspecialchars($err['query'], ENT_QUOTES);
// If there is an error then take note of it
print "Database error: [$str]
$query
* wpdb::insert( 'table', array( 'column' => 'foo', 'field' => 1337 ), array( '%s', '%d' ) )
*
*
* @since 2.5.0
* @see wpdb::prepare()
*
* @param string $table table name
* @param array $data Data to insert (in column => value pairs). Both $data columns and $data values should be "raw" (neither should be SQL escaped).
* @param array|string $format (optional) An array of formats to be mapped to each of the value in $data. If string, that format will be used for all of the values in $data. A format is one of '%d', '%s' (decimal number, string). If omitted, all values in $data will be treated as strings.
* @return int|false The number of rows inserted, or false on error.
*/
function insert($table, $data, $format = null) {
$formats = $format = (array) $format;
$fields = array_keys($data);
$formatted_fields = array();
foreach ( $fields as $field ) {
if ( !empty($format) )
$form = ( $form = array_shift($formats) ) ? $form : $format[0];
elseif ( isset($this->field_types[$field]) )
$form = $this->field_types[$field];
else
$form = '%s';
$formatted_fields[] = $form;
}
$sql = "INSERT INTO `$table` (`" . implode( '`,`', $fields ) . "`) VALUES ('" . implode( "','", $formatted_fields ) . "')";
return $this->query( $this->prepare( $sql, $data) );
}
/**
* Update a row in the table
*
*
* wpdb::update( 'table', array( 'column' => 'foo', 'field' => 1337 ), array( 'ID' => 1 ), array( '%s', '%d' ), array( '%d' ) )
*
*
* @since 2.5.0
* @see wpdb::prepare()
*
* @param string $table table name
* @param array $data Data to update (in column => value pairs). Both $data columns and $data values should be "raw" (neither should be SQL escaped).
* @param array $where A named array of WHERE clauses (in column => value pairs). Multiple clauses will be joined with ANDs. Both $where columns and $where values should be "raw".
* @param array|string $format (optional) An array of formats to be mapped to each of the values in $data. If string, that format will be used for all of the values in $data. A format is one of '%d', '%s' (decimal number, string). If omitted, all values in $data will be treated as strings.
* @param array|string $format_where (optional) An array of formats to be mapped to each of the values in $where. If string, that format will be used for all of the items in $where. A format is one of '%d', '%s' (decimal number, string). If omitted, all values in $where will be treated as strings.
* @return int|false The number of rows updated, or false on error.
*/
function update($table, $data, $where, $format = null, $where_format = null) {
if ( !is_array( $where ) )
return false;
$formats = $format = (array) $format;
$bits = $wheres = array();
foreach ( (array) array_keys($data) as $field ) {
if ( !empty($format) )
$form = ( $form = array_shift($formats) ) ? $form : $format[0];
elseif ( isset($this->field_types[$field]) )
$form = $this->field_types[$field];
else
$form = '%s';
$bits[] = "`$field` = {$form}";
}
$where_formats = $where_format = (array) $where_format;
foreach ( (array) array_keys($where) as $field ) {
if ( !empty($where_format) )
$form = ( $form = array_shift($where_formats) ) ? $form : $where_format[0];
elseif ( isset($this->field_types[$field]) )
$form = $this->field_types[$field];
else
$form = '%s';
$wheres[] = "`$field` = {$form}";
}
$sql = "UPDATE `$table` SET " . implode( ', ', $bits ) . ' WHERE ' . implode( ' AND ', $wheres );
return $this->query( $this->prepare( $sql, array_merge(array_values($data), array_values($where))) );
}
/**
* Retrieve one variable from the database.
*
* Executes a SQL query and returns the value from the SQL result.
* If the SQL result contains more than one column and/or more than one row, this function returns the value in the column and row specified.
* If $query is null, this function returns the value in the specified column and row from the previous SQL result.
*
* @since 0.71
*
* @param string|null $query SQL query. If null, use the result from the previous query.
* @param int $x (optional) Column of value to return. Indexed from 0.
* @param int $y (optional) Row of value to return. Indexed from 0.
* @return string Database query result
*/
function get_var($query=null, $x = 0, $y = 0) {
$this->func_call = "\$db->get_var(\"$query\",$x,$y)";
if ( $query )
$this->query($query);
// Extract var out of cached results based x,y vals
if ( !empty( $this->last_result[$y] ) ) {
$values = array_values(get_object_vars($this->last_result[$y]));
}
// If there is a value return it else return null
return (isset($values[$x]) && $values[$x]!=='') ? $values[$x] : null;
}
/**
* Retrieve one row from the database.
*
* Executes a SQL query and returns the row from the SQL result.
*
* @since 0.71
*
* @param string|null $query SQL query.
* @param string $output (optional) one of ARRAY_A | ARRAY_N | OBJECT constants. Return an associative array (column => value, ...), a numerically indexed array (0 => value, ...) or an object ( ->column = value ), respectively.
* @param int $y (optional) Row to return. Indexed from 0.
* @return mixed Database query result in format specifed by $output
*/
function get_row($query = null, $output = OBJECT, $y = 0) {
$this->func_call = "\$db->get_row(\"$query\",$output,$y)";
if ( $query )
$this->query($query);
else
return null;
if ( !isset($this->last_result[$y]) )
return null;
if ( $output == OBJECT ) {
return $this->last_result[$y] ? $this->last_result[$y] : null;
} elseif ( $output == ARRAY_A ) {
return $this->last_result[$y] ? get_object_vars($this->last_result[$y]) : null;
} elseif ( $output == ARRAY_N ) {
return $this->last_result[$y] ? array_values(get_object_vars($this->last_result[$y])) : null;
} else {
$this->print_error(/*WP_I18N_DB_GETROW_ERROR*/" \$db->get_row(string query, output type, int offset) -- Output type must be one of: OBJECT, ARRAY_A, ARRAY_N"/*/WP_I18N_DB_GETROW_ERROR*/);
}
}
/**
* Retrieve one column from the database.
*
* Executes a SQL query and returns the column from the SQL result.
* If the SQL result contains more than one column, this function returns the column specified.
* If $query is null, this function returns the specified column from the previous SQL result.
*
* @since 0.71
*
* @param string|null $query SQL query. If null, use the result from the previous query.
* @param int $x Column to return. Indexed from 0.
* @return array Database query result. Array indexed from 0 by SQL result row number.
*/
function get_col($query = null , $x = 0) {
if ( $query )
$this->query($query);
$new_array = array();
// Extract the column values
for ( $i=0; $i < count($this->last_result); $i++ ) {
$new_array[$i] = $this->get_var(null, $x, $i);
}
return $new_array;
}
/**
* Retrieve an entire SQL result set from the database (i.e., many rows)
*
* Executes a SQL query and returns the entire SQL result.
*
* @since 0.71
*
* @param string $query SQL query.
* @param string $output (optional) ane of ARRAY_A | ARRAY_N | ARRAY_K | OBJECT | OBJECT_K constants. With one of the first three, return an array of rows indexed from 0 by SQL result row number. Each row is an associative array (column => value, ...), a numerically indexed array (0 => value, ...), or an object. ( ->column = value ), respectively. With OBJECT_K, return an associative array of row objects keyed by the value of each row's first column's value. Duplicate keys are discarded.
* @return mixed Database query results
*/
function get_results($query = null, $output = OBJECT) {
$this->func_call = "\$db->get_results(\"$query\", $output)";
if ( $query )
$this->query($query);
else
return null;
if ( $output == OBJECT ) {
// Return an integer-keyed array of row objects
return $this->last_result;
} elseif ( $output == OBJECT_K || $output == ARRAY_K ) {
// Return an array of row objects with keys from column 1
// (Duplicates are discarded)
$key = $this->col_info[0]->name;
foreach ( (array) $this->last_result as $row )
if ( !isset( $new_array[ $row->$key ] ) )
$new_array[ $row->$key ] = $row;
if ( $output == ARRAY_K )
return array_map('get_object_vars', $new_array);
return $new_array;
} elseif ( $output == ARRAY_A || $output == ARRAY_N ) {
// Return an integer-keyed array of...
if ( $this->last_result ) {
$i = 0;
foreach( (array) $this->last_result as $row ) {
if ( $output == ARRAY_N ) {
// ...integer-keyed row arrays
$new_array[$i] = array_values( get_object_vars( $row ) );
} else {
// ...column name-keyed row arrays
$new_array[$i] = get_object_vars( $row );
}
++$i;
}
return $new_array;
}
}
}
/**
* Retrieve column metadata from the last query.
*
* @since 0.71
*
* @param string $info_type one of name, table, def, max_length, not_null, primary_key, multiple_key, unique_key, numeric, blob, type, unsigned, zerofill
* @param int $col_offset 0: col name. 1: which table the col's in. 2: col's max length. 3: if the col is numeric. 4: col's type
* @return mixed Column Results
*/
function get_col_info($info_type = 'name', $col_offset = -1) {
if ( $this->col_info ) {
if ( $col_offset == -1 ) {
$i = 0;
foreach( (array) $this->col_info as $col ) {
$new_array[$i] = $col->{$info_type};
$i++;
}
return $new_array;
} else {
return $this->col_info[$col_offset]->{$info_type};
}
}
}
/**
* Starts the timer, for debugging purposes.
*
* @since 1.5.0
*
* @return true
*/
function timer_start() {
$mtime = microtime();
$mtime = explode(' ', $mtime);
$this->time_start = $mtime[1] + $mtime[0];
return true;
}
/**
* Stops the debugging timer.
*
* @since 1.5.0
*
* @return int Total time spent on the query, in milliseconds
*/
function timer_stop() {
$mtime = microtime();
$mtime = explode(' ', $mtime);
$time_end = $mtime[1] + $mtime[0];
$time_total = $time_end - $this->time_start;
return $time_total;
}
/**
* Wraps errors in a nice header and footer and dies.
*
* Will not die if wpdb::$show_errors is true
*
* @since 1.5.0
*
* @param string $message
* @return false|void
*/
function bail($message, $error_code = '500') {
if ( !$this->show_errors ) {
if ( class_exists('WP_Error') )
$this->error = new WP_Error($error_code, $message);
else
$this->error = $message;
return false;
}
wp_die($message);
}
/**
* Whether or not MySQL database is at least the required minimum version.
*
* @since 2.5.0
* @uses $wp_version
*
* @return WP_Error
*/
function check_database_version( $dbh_or_table = false ) {
global $wp_version;
// Make sure the server has MySQL 4.1.2
$mysql_version = preg_replace( '|[^0-9\.]|', '', $this->db_version( $dbh_or_table ) );
if ( version_compare($mysql_version, '4.1.2', '<') )
return new WP_Error( 'database_version', sprintf(__('ERROR: WordPress %s requires MySQL 4.1.2 or higher'), $wp_version) );
}
/**
* This function is called when WordPress is generating the table schema to determine wether or not the current database
* supports or needs the collation statements.
* @return bool
*/
function supports_collation() {
return $this->has_cap( 'collation' );
}
/**
* Generic function to determine if a database supports a particular feature
* @param string $db_cap the feature
* @param false|string|resource $dbh_or_table the databaese (the current database, the database housing the specified table, or the database of the mysql resource)
* @return bool
*/
function has_cap( $db_cap, $dbh_or_table = false ) {
$version = $this->db_version( $dbh_or_table );
switch ( strtolower( $db_cap ) ) :
case 'collation' :
case 'group_concat' :
case 'subqueries' :
return version_compare($version, '4.1', '>=');
break;
endswitch;
return false;
}
/**
* The database version number
* @param false|string|resource $dbh_or_table the databaese (the current database, the database housing the specified table, or the database of the mysql resource)
* @return false|string false on failure, version number on success
*/
function db_version( $dbh_or_table = false ) {
if ( !$dbh_or_table && $this->dbh )
$dbh =& $this->dbh;
elseif ( is_resource( $dbh_or_table ) )
$dbh =& $dbh_or_table;
else
$dbh = $this->db_connect( "SELECT FROM $dbh_or_table $this->users" );
if ( $dbh )
return preg_replace('/[^0-9.].*/', '', mysql_get_server_info( $dbh ));
return false;
}
/**
* Get the name of the function that called wpdb.
* @return string the name of the calling function
*/
function get_caller() {
// requires PHP 4.3+
if ( !is_callable('debug_backtrace') )
return '';
$bt = debug_backtrace();
$caller = '';
foreach ( (array) $bt as $trace ) {
if ( isset($trace['class']) && is_a( $this, $trace['class'] ) )
continue;
elseif ( !isset($trace['function']) )
continue;
elseif ( strtolower($trace['function']) == 'call_user_func_array' )
continue;
elseif ( strtolower($trace['function']) == 'apply_filters' )
continue;
elseif ( strtolower($trace['function']) == 'do_action' )
continue;
if ( isset($trace['class']) )
$caller = $trace['class'] . '::' . $trace['function'];
else
$caller = $trace['function'];
break;
}
return $caller;
}
/**
* Check the responsiveness of a tcp/ip daemon
* @return (bool) true when $host:$post responds within $float_timeout seconds, else (bool) false
*/
function check_tcp_responsiveness($host, $port, $float_timeout) {
if ( 1 == 2 && function_exists('apc_store') ) {
$use_apc = true;
$apc_key = "{$host}{$port}";
$apc_ttl = 10;
} else {
$use_apc = false;
}
if ( $use_apc ) {
$cached_value=apc_fetch($apc_key);
switch ( $cached_value ) {
case 'up':
$this->tcp_responsive = 'true';
return true;
case 'down':
$this->tcp_responsive = 'false';
return false;
}
}
$socket = fsockopen($host, $port, $errno, $errstr, $float_timeout);
if ( $socket === false ) {
if ( $use_apc )
apc_store($apc_key, 'down', $apc_ttl);
$this->tcp_responsive = "false [ > $float_timeout] ($errno) '$errstr'";
return false;
}
fclose($socket);
if ( $use_apc )
apc_store($apc_key, 'up', $apc_ttl);
$this->tcp_responsive = 'true';
return true;
}
} // class db
endif;
if ( defined( 'BACKPRESS_PATH' ) ) :
class BPDB_Hyper extends db {
function BPDB_Hyper() {
$args = func_get_args();
return call_user_func_array( array(&$this, '__construct'), $args );
}
function __construct( $args ) { // no private _init method
if ( 4 == func_num_args() )
$args = array( 'user' => $args, 'password' => func_get_arg(1), 'name' => func_get_arg(2), 'host' => func_get_arg(3) );
$defaults = array(
'user' => false,
'password' => false,
'name' => false,
'host' => 'localhost',
'charset' => false,
'collate' => false,
'errors' => false
);
$args = wp_parse_args( $args, $defaults );
$hyper = array();
switch ( $args['errors'] ) :
case 'show' :
$hyper['show_errors'] = true;
break;
case 'suppress' :
$hyper['suppress_errors'] = true;
break;
endswitch;
if ( $args['name'] ) {
$hyper['db_server'] = array(
'user' => $args['user'],
'password' => $args['password'],
'name' => $args['name'],
'host' => $args['host']
);
}
$hyper['save_queries'] = (bool) @constant('SAVEQUERIES');
// HyperDB does not support per-table charsets, collations
foreach ( array( 'charset', 'collate' ) as $arg )
if ( isset($args[$arg]) )
$hyper[$arg] = $args[$arg];
return parent::__construct($hyper);
}
/**
* Sets the prefix of the database tables
* @param string prefix
* @param false|array tables (optional: false)
* table identifiers are array keys
* array values
* empty: set prefix: array( 'posts' => false, 'users' => false, ... )
* string: set to that array value: array( 'posts' => 'my_posts', 'users' => 'my_users' )
* array: array[0] is DB identifier, array[1] is table name: array( 'posts' => array( 'global', 'my_posts' ), 'users' => array( 'users', 'my_users' ) )
* OR array values (with numeric keys): array( 'posts', 'users', ... )
*
* @return string the previous prefix (mostly only meaningful if all $table parameter was false)
*/
// Combines BPDB::set_prefix and BPDB_Multi::set_prefix
function set_prefix( $prefix, $tables = false ) {
if ( !$prefix )
return false;
if ( preg_match('|[^a-z0-9_]|i', $prefix) )
return new WP_Error('invalid_db_prefix', 'Invalid database prefix'); // No gettext here
$old_prefix = $this->prefix;
if ( $tables && is_array($tables) ) {
$_tables =& $tables;
} else {
$_tables =& $this->tables;
$this->prefix = $prefix;
}
foreach ( $_tables as $key => $value ) {
if ( is_numeric( $key ) ) { // array( 'posts', 'users', ... )
$this->$value = $prefix . $value;
} elseif ( !$value ) { // array( 'posts' => false, 'users' => false, ... )
$this->$key = $prefix . $key;
} elseif ( is_string($value) ) { // array( 'posts' => 'my_posts', 'users' => 'my_users' )
$this->$key = $value;
} elseif ( is_array($value) ) { // array( 'posts' => array( 'global', 'my_posts' ), 'users' => array( 'users', 'my_users' ) )
$this->add_db_table( $value[0], $value[1] );
$this->$key = $value[1];
}
}
return $old_prefix;
}
/**
* Print SQL/DB error
* @param string $str Error string
*/
function print_error($str = '') {
if ( $this->suppress_errors )
return false;
$error = $this->get_error( $str );
if ( is_object( $error ) && is_a( $error, 'WP_Error' ) ) {
$err = $error->get_error_data();
$err['error_str'] = sprintf( BPDB__ERROR_STRING, $err['str'], $err['query'], $err['caller'] );
} else {
$err =& $error;
}
$log_file = ini_get('error_log');
if ( !empty($log_file) && ('syslog' != $log_file) && !is_writable($log_file) && function_exists( 'error_log' ) )
error_log($err['error_str'], 0);
// Is error output turned on or not
if ( !$this->show_errors )
return false;
$str = htmlspecialchars($err['str'], ENT_QUOTES);
$query = htmlspecialchars($err['query'], ENT_QUOTES);
$caller = htmlspecialchars($err['caller'], ENT_QUOTES);
// If there is an error then take note of it
printf( BPDB__ERROR_HTML, $str, $query, $caller );
}
/**
* Add a database server's information. Does not automatically connect.
* @param string $ds Dataset: the name of the dataset.
* @param array $args
* ds => string Dataset: the name of the dataset. Just use "global" if you don't need horizontal partitioning.
* part => string Partition: the vertical partition number (1, 2, 3, etc.). Use "0" if you don't need vertical partitioning.
* dc => string Datacenter: where the database server is located. Airport codes are convenient. Use whatever.
* read => int Read order: lower number means use this for more reads. Zero means no reads (e.g. for masters).
* write => int Write flag: is this server writable?
* host => string Internet address: host:port of server on internet.
* lhost => string Local address: host:port of server for use when in same datacenter. Leave empty if no local address exists.
* name => string Database name.
* user => string Database user.
* password => string Database password.
* charset => string Database default charset. Used in a SET NAMES query. (optional) (ignored)
* collate => string Database default collation. If charset supplied, optionally added to the SET NAMES query (optional) (ignored)
*/
function add_db_server( $ds, $args = null ) {
$defaults = array(
'part' => 0,
'dc' => '',
'read' => 1,
'write' => 1,
'host' => 'localhost',
'lhost' => '',
'name' => false,
'user' => false,
'password' => false,
'charset' => false,
'collate' => false
);
// We're adding another DB so we're no longer single_db. Put single_db data into db_servers
// during the load procedure, bbPress starts out single but may end up multi
// (at the moment, bbPress stores the multi info in the global "single" DB)
if ( $this->single_db ) {
$this->single_db = false;
$this->add_db_server( 'global', $this->db_server );
$this->db_server = array();
$this->dbhs['global'] =& $this->dbh;
$this->db_servers =& $GLOBALS['db_servers'];
}
extract( wp_parse_args( $args, $defaults ), EXTR_SKIP );
add_db_server( $ds, $part, $dc, $read, $write, $host, $lhost, $name, $user, $password );
}
/**
* Maps a table to a dataset.
* @param string $ds Dataset: the name of the dataset.
* @param string $table
*/
function add_db_table( $ds, $table ) {
add_db_table( $ds, $table );
if ( empty( $this->db_tables ) )
$this->db_tables =& $GLOBALS['db_tables'];
}
}
// BackPress creates the DB object on its own. Do not create one here
else : // BackPress
if ( !class_exists( 'wpdb' ) ) :
if ( defined('WPMU') ) :
class wpdb extends db {
var $prefix = '';
var $ready = true;
var $blogid = 0;
var $siteid = 0;
var $global_tables = array('blogs', 'signups', 'site', 'sitemeta', 'users', 'usermeta', 'sitecategories', 'registration_log', 'blog_versions');
var $blog_tables = array('posts', 'categories', 'post2cat', 'comments', 'links', 'link2cat', 'options',
'postmeta', 'terms', 'term_taxonomy', 'term_relationships', 'commentmeta');
var $old_tables = array('categories', 'post2cat', 'link2cat');
var $blogs, $signups, $site, $sitemeta, $users, $usermeta, $sitecategories, $registration_log, $blog_versions, $posts, $categories, $post2cat, $comments, $links, $link2cat, $options, $postmeta, $terms, $term_taxonomy, $term_relationships, $commentmeta;
function wpdb($dbuser, $dbpassword, $dbname, $dbhost) {
return $this->__construct($dbuser, $dbpassword, $dbname, $dbhost);
}
function __construct($dbuser, $dbpassword, $dbname, $dbhost) {
$args = array();
if ( defined('WP_DEBUG') and WP_DEBUG == true )
$args['show_errors'] = true;
if ( defined('DB_CHARSET') )
$args['charset'] = DB_CHARSET;
else
$args['charset'] = 'utf8';
if ( defined('DB_COLLATE') )
$args['collate'] = DB_COLLATE;
elseif ( $args['charset'] == 'utf8' )
$args['collate'] = 'utf8_general_ci';
$this->dbuser = $dbuser;
$args['save_queries'] = (bool) constant('SAVEQUERIES');
$args['db_server'] = array(
'user' => $dbuser,
'password' => $dbpassword,
'name' => $dbname,
'host' => $dbhost
);
return parent::__construct($args);
}
function set_prefix($prefix) {
if ( preg_match('|[^a-z0-9_]|i', $prefix) )
return new WP_Error('invalid_db_prefix', /*WP_I18N_DB_BAD_PREFIX*/'Invalid database prefix'/*/WP_I18N_DB_BAD_PREFIX*/);
$old_prefix = $this->base_prefix;
$this->base_prefix = $prefix;
foreach ( $this->global_tables as $table )
$this->$table = $prefix . $table;
if ( empty($this->blogid) )
return $old_prefix;
$this->prefix = $this->get_blog_prefix( $this->blogid );
foreach ( $this->blog_tables as $table )
$this->$table = $this->prefix . $table;
if ( defined('CUSTOM_USER_TABLE') )
$this->users = CUSTOM_USER_TABLE;
if ( defined('CUSTOM_USER_META_TABLE') )
$this->usermeta = CUSTOM_USER_META_TABLE;
return $old_prefix;
}
function set_blog_id($blog_id, $site_id = '') {
if ( !empty($site_id) )
$this->siteid = $site_id;
$old_blog_id = $this->blogid;
$this->blogid = $blog_id;
$this->prefix = $this->get_blog_prefix( $this->blogid );
foreach ( $this->blog_tables as $table )
$this->$table = $this->prefix . $table;
return $old_blog_id;
}
function get_blog_prefix( $blog_id = '' ) {
if ( $blog_id ) {
return $this->base_prefix . $blog_id . '_';
} else {
return $this->prefix;
}
}
function print_error($str = '') {
global $EZSQL_ERROR;
if (!$str) $str = mysql_error($this->dbh);
$EZSQL_ERROR[] = array ('query' => $this->last_query, 'error_str' => $str);
if ( $this->suppress_errors )
return false;
if ( $caller = $this->get_caller() )
$error_str = sprintf(/*WP_I18N_DB_QUERY_ERROR_FULL*/'WordPress database error %1$s for query %2$s made by %3$s'/*/WP_I18N_DB_QUERY_ERROR_FULL*/, $str, $this->last_query, $caller);
else
$error_str = sprintf(/*WP_I18N_DB_QUERY_ERROR*/'WordPress database error %1$s for query %2$s'/*/WP_I18N_DB_QUERY_ERROR*/, $str, $this->last_query);
$log_error = true;
if ( ! function_exists('error_log') )
$log_error = false;
$log_file = @ini_get('error_log');
if ( !empty($log_file) && ('syslog' != $log_file) && !is_writable($log_file) )
$log_error = false;
if ( $log_error )
@error_log($error_str, 0);
// Is error output turned on or not..
if ( !$this->show_errors )
return false;
// If there is an error then take note of it
$msg = "WordPress database error: [$str]\n{$this->query}\n";
if( defined( 'ERRORLOGFILE' ) )
error_log( $msg, 3, CONSTANT( 'ERRORLOGFILE' ) );
if( defined( 'DIEONDBERROR' ) )
die( $msg );
}
}
else :
class wpdb extends db {
var $prefix = '';
var $tables = array('users', 'usermeta', 'posts', 'categories', 'post2cat', 'comments', 'links', 'link2cat', 'options',
'postmeta', 'terms', 'term_taxonomy', 'term_relationships');
var $users, $usermeta, $posts, $categories, $post2cat, $comments, $links, $link2cat, $options, $postmeta, $terms, $term_taxonomy, $term_relationships;
var $ready = true;
function wpdb($dbuser, $dbpassword, $dbname, $dbhost) {
return $this->__construct($dbuser, $dbpassword, $dbname, $dbhost);
}
function __construct($dbuser, $dbpassword, $dbname, $dbhost) {
$args = array();
if ( defined('WP_DEBUG') and WP_DEBUG == true )
$args['show_errors'] = true;
if ( defined('DB_CHARSET') )
$args['charset'] = DB_CHARSET;
if ( defined('DB_COLLATE') )
$args['collate'] = DB_COLLATE;
$args['save_queries'] = (bool) constant('SAVEQUERIES');
$args['db_server'] = array(
'user' => $dbuser,
'password' => $dbpassword,
'name' => $dbname,
'host' => $dbhost
);
return parent::__construct($args);
}
function set_prefix($prefix) {
if ( preg_match('|[^a-z0-9_]|i', $prefix) )
return new WP_Error('invalid_db_prefix', 'Invalid database prefix'); // No gettext here
$old_prefix = $this->prefix;
$this->prefix = $prefix;
foreach ( $this->tables as $table )
$this->$table = $this->prefix . $table;
if ( defined('CUSTOM_USER_TABLE') )
$this->users = CUSTOM_USER_TABLE;
if ( defined('CUSTOM_USER_META_TABLE') )
$this->usermeta = CUSTOM_USER_META_TABLE;
return $old_prefix;
}
function print_error($str = '') {
global $EZSQL_ERROR;
if (!$str) $str = mysql_error($this->dbh);
$EZSQL_ERROR[] = array ('query' => $this->last_query, 'error_str' => $str);
if ( $this->suppress_errors )
return false;
if ( $caller = $this->get_caller() )
$error_str = sprintf(/*WP_I18N_DB_QUERY_ERROR_FULL*/'WordPress database error %1$s for query %2$s made by %3$s'/*/WP_I18N_DB_QUERY_ERROR_FULL*/, $str, $this->last_query, $caller);
else
$error_str = sprintf(/*WP_I18N_DB_QUERY_ERROR*/'WordPress database error %1$s for query %2$s'/*/WP_I18N_DB_QUERY_ERROR*/, $str, $this->last_query);
$log_error = true;
if ( ! function_exists('error_log') )
$log_error = false;
$log_file = @ini_get('error_log');
if ( !empty($log_file) && ('syslog' != $log_file) && !is_writable($log_file) )
$log_error = false;
if ( $log_error )
@error_log($error_str, 0);
// Is error output turned on or not..
if ( !$this->show_errors )
return false;
$str = htmlspecialchars($str, ENT_QUOTES);
$query = htmlspecialchars($this->last_query, ENT_QUOTES);
// If there is an error then take note of it
print "WordPress database error: [$str]
$query