Vergleich inc/db_mysqli.php - 1.8.5 - 1.8.11

	/**
	 * The read database connection resource.
	 *

	/**
	 * The read database connection resource.
	 *

	 */
	public $read_link;

	/**
	 * The write database connection resource
	 *

	 */
	public $read_link;

	/**
	 * The write database connection resource
	 *

	 */
	public $write_link;

	/**
	 * Reference to the last database connection resource used.
	 *

	 */
	public $write_link;

	/**
	 * Reference to the last database connection resource used.
	 *

	 */
	public $current_link;

	/**

	 */
	public $current_link;

	/**

	 *

	 *

	public $explain;

	/**

	public $explain;

	/**

	 * @var string
	 */
	public $version;

	 * @var string
	 */
	public $version;

	 * The current table type in use (myisam/innodb)

	 * The current table type in use (myisam/innodb)

	public $table_type = "myisam";

	/**

	public $table_type = "myisam";

	/**

	 * @var string
	 */
	public $table_prefix;

	 * @var string
	 */
	public $table_prefix;

	 * The extension used to run the SQL database

	 * The extension used to run the SQL database

	 * @var string

	 * @var string

	public $engine = "mysqli";

	/**

	public $engine = "mysqli";

	/**

	 * @var boolean
	 */
	public $can_search = true;

	 * @var boolean
	 */
	public $can_search = true;

	 * The database encoding currently in use (if supported)

	 * The database encoding currently in use (if supported)

	 * @var string

	 * @var string

	public $db_encoding = "utf8";

	/**

	public $db_encoding = "utf8";

	/**

	 * @var float
	 */
	public $query_time = 0;

	 * @var float
	 */
	public $query_time = 0;

	 * Stores previous run query type: 1 => write; 0 => read
	 *
	 * @var int

	 * Stores previous run query type: 1 => write; 0 => read
	 *
	 * @var int

	/**
	 * Connect to the database server.
	 *

	/**
	 * Connect to the database server.
	 *

	 */
	function connect($config)
	{

	 */
	function connect($config)
	{

				$details = $connections[$type];
				unset($connections);
				$connections[$type][] = $details;

				$details = $connections[$type];
				unset($connections);
				$connections[$type][] = $details;

			// Shuffle the connections
			shuffle($connections[$type]);

			// Shuffle the connections
			shuffle($connections[$type]);

			// Loop-de-loop
			foreach($connections[$type] as $single_connection)
			{

			// Loop-de-loop
			foreach($connections[$type] as $single_connection)
			{

				if(!empty($single_connection['pconnect']) && version_compare(PHP_VERSION, '5.3.0', '>='))
				{
					$persist = 'p:';

				if(!empty($single_connection['pconnect']) && version_compare(PHP_VERSION, '5.3.0', '>='))
				{
					$persist = 'p:';

				get_execution_time();

				// Specified a custom port for this connection?
				$port = 0;
				if(strstr($single_connection['hostname'],':'))

				get_execution_time();

				// Specified a custom port for this connection?
				$port = 0;
				if(strstr($single_connection['hostname'],':'))

					list($hostname, $port) = explode(":", $single_connection['hostname'], 2);
				}

				if($port)
				{
					$this->$link = @$connect_function($persist.$hostname, $single_connection['username'], $single_connection['password'], "", $port);

					list($hostname, $port) = explode(":", $single_connection['hostname'], 2);
				}

				if($port)
				{
					$this->$link = @$connect_function($persist.$hostname, $single_connection['username'], $single_connection['password'], "", $port);

				else

				else

					$this->$link = @$connect_function($persist.$single_connection['hostname'], $single_connection['username'], $single_connection['password']);
				}

					$this->$link = @$connect_function($persist.$single_connection['hostname'], $single_connection['username'], $single_connection['password']);
				}

				{
					$this->connections[] = "[".strtoupper($type)."] {$single_connection['username']}@{$single_connection['hostname']} (Connected in ".format_time_duration($time_spent).")";
					break;

				{
					$this->connections[] = "[".strtoupper($type)."] {$single_connection['username']}@{$single_connection['hostname']} (Connected in ".format_time_duration($time_spent).")";
					break;

				else
				{
					$this->connections[] = "<span style=\"color: red\">[FAILED] [".strtoupper($type)."] {$single_connection['username']}@{$single_connection['hostname']}</span>";
				}
			}

				else
				{
					$this->connections[] = "<span style=\"color: red\">[FAILED] [".strtoupper($type)."] {$single_connection['username']}@{$single_connection['hostname']}</span>";
				}
			}

		// No write server was specified (simple connection or just multiple servers) - mirror write link
		if(!array_key_exists('write', $connections))
		{
			$this->write_link = &$this->read_link;

		// No write server was specified (simple connection or just multiple servers) - mirror write link
		if(!array_key_exists('write', $connections))
		{
			$this->write_link = &$this->read_link;

		// Have no read connection?
		if(!$this->read_link)
		{

		// Have no read connection?
		if(!$this->read_link)
		{

	/**
	 * Selects the database to use.
	 *

	/**
	 * Selects the database to use.
	 *

	 * @return boolean True when successfully connected, false if not.
	 */
	function select_db($database)
	{

	 * @return boolean True when successfully connected, false if not.
	 */
	function select_db($database)
	{

		$master_success = @mysqli_select_db($this->read_link, $database) or $this->error("[READ] Unable to select database", $this->read_link);
		if($this->write_link)

		$master_success = @mysqli_select_db($this->read_link, $database) or $this->error("[READ] Unable to select database", $this->read_link);
		if($this->write_link)

			}
		}
		return $success;

			}
		}
		return $success;

	/**
	 * Query the database.
	 *

	/**
	 * Query the database.
	 *

	 */
	function query($string, $hide_errors=0, $write_query=0)
	{

	 */
	function query($string, $hide_errors=0, $write_query=0)
	{

		get_execution_time();

		get_execution_time();

		{
			$this->error($string);
			exit;

		{
			$this->error($string);
			exit;

		if($write_query)
		{
			$this->last_query_type = 1;

		if($write_query)
		{
			$this->last_query_type = 1;

	/**
	 * Execute a write query on the master database
	 *

	/**
	 * Execute a write query on the master database
	 *

	 */
	function write_query($query, $hide_errors=0)
	{

	 */
	function write_query($query, $hide_errors=0)
	{

	/**
	 * Explain a query on the database.
	 *

	/**
	 * Explain a query on the database.
	 *

	 */
	function explain_query($string, $qtime)
	{

	 */
	function explain_query($string, $qtime)
	{

			$this->explain .=
				"<tr>\n".
				"<td colspan=\"8\" style=\"background-color: #fff;\">Query Time: ".format_time_duration($qtime)."</td>\n".

			$this->explain .=
				"<tr>\n".
				"<td colspan=\"8\" style=\"background-color: #fff;\">Query Time: ".format_time_duration($qtime)."</td>\n".

				"<br />\n";
		}
		else

				"<br />\n";
		}
		else

	/**
	 * Return a result array for a query.
	 *

	/**
	 * Return a result array for a query.
	 *

	 * @return array The array of results.
	 */
	function fetch_array($query, $resulttype=MYSQLI_ASSOC)

	 * @return array The array of results.
	 */
	function fetch_array($query, $resulttype=MYSQLI_ASSOC)

			default:
				$resulttype = MYSQLI_ASSOC;
				break;

			default:
				$resulttype = MYSQLI_ASSOC;
				break;

		$array = mysqli_fetch_array($query, $resulttype);

		return $array;

		$array = mysqli_fetch_array($query, $resulttype);

		return $array;

	/**
	 * Return a specific field from a query.
	 *

	/**
	 * Return a specific field from a query.
	 *

	 */
	function fetch_field($query, $field, $row=false)
	{

	 */
	function fetch_field($query, $field, $row=false)
	{

	/**
	 * Moves internal row pointer to the next row
	 *

	/**
	 * Moves internal row pointer to the next row
	 *

	 */
	function data_seek($query, $row)
	{
		return mysqli_data_seek($query, $row);

	 */
	function data_seek($query, $row)
	{
		return mysqli_data_seek($query, $row);

	/**
	 * Return the number of rows resulting from a query.
	 *

	/**
	 * Return the number of rows resulting from a query.
	 *

	 * @return int The number of rows in the result.
	 */
	function num_rows($query)

	 * @return int The number of rows in the result.
	 */
	function num_rows($query)

	/**
	 * Return the last id number of inserted data.

	/**
	 * Return the last id number of inserted data.

	 * @return int The id number.
	 */
	function insert_id()

	 * @return int The id number.
	 */
	function insert_id()

	 *
	 */
	function close()

	 *
	 */
	function close()

		@mysqli_close($this->read_link);
		if($this->write_link)
		{

		@mysqli_close($this->read_link);
		if($this->write_link)
		{

	 * @return int The error number of the current error.
	 */
	function error_number()

	 * @return int The error number of the current error.
	 */
	function error_number()

			return mysqli_errno($this->current_link);

			return mysqli_errno($this->current_link);

		else
		{
			return mysqli_connect_errno();

		else
		{
			return mysqli_connect_errno();

	 * Return an error string.
	 *
	 * @return string The explanation for the current error.

	 * Return an error string.
	 *
	 * @return string The explanation for the current error.

	function error_string()
	{
		if($this->current_link)

	function error_string()
	{
		if($this->current_link)

			return mysqli_error($this->current_link);

			return mysqli_error($this->current_link);

		else
		{
			return mysqli_connect_error();

		else
		{
			return mysqli_connect_error();

	/**
	 * Output a database error.
	 *

	/**
	 * Output a database error.
	 *

	 */
	function error($string="")
	{

	 */
	function error($string="")
	{

					"query" => $string
				);
				$error_handler->error(MYBB_SQL, $error);

					"query" => $string
				);
				$error_handler->error(MYBB_SQL, $error);

			else
			{
				trigger_error("<strong>[SQL] [".$this->error_number()."] ".$this->error_string()."</strong><br />{$string}", E_USER_ERROR);
			}

			else
			{
				trigger_error("<strong>[SQL] [".$this->error_number()."] ".$this->error_string()."</strong><br />{$string}", E_USER_ERROR);
			}

		}
		else
		{

		}
		else
		{

	/**
	 * Return the number of fields.
	 *

	/**
	 * Return the number of fields.
	 *

	 * @return int The number of fields.
	 */
	function num_fields($query)

	 * @return int The number of fields.
	 */
	function num_fields($query)

	/**
	 * Lists all tables in the database.
	 *

	/**
	 * Lists all tables in the database.
	 *

	 * @return array The table list.
	 */
	function list_tables($database, $prefix='')
	{
		if($prefix)
		{

	 * @return array The table list.
	 */
	function list_tables($database, $prefix='')
	{
		if($prefix)
		{

		}
		else

		}
		else

		$tables = array();
		while(list($table) = mysqli_fetch_array($query))
		{
			$tables[] = $table;
		}

		$tables = array();
		while(list($table) = mysqli_fetch_array($query))
		{
			$tables[] = $table;
		}

		return $tables;
	}

	/**
	 * Check if a table exists in a database.
	 *

		return $tables;
	}

	/**
	 * Check if a table exists in a database.
	 *

	 * @return boolean True when exists, false if not.
	 */
	function table_exists($table)
	{
		// Execute on master server to ensure if we've just created a table that we get the correct result

	 * @return boolean True when exists, false if not.
	 */
	function table_exists($table)
	{
		// Execute on master server to ensure if we've just created a table that we get the correct result

			return false;
		}
	}

			return false;
		}
	}

	/**
	 * Check if a field exists in a database.
	 *

	/**
	 * Check if a field exists in a database.
	 *

	 * @return boolean True when exists, false if not.
	 */
	function field_exists($field, $table)

	 * @return boolean True when exists, false if not.
	 */
	function field_exists($field, $table)

		if($exists > 0)
		{
			return true;

		if($exists > 0)
		{
			return true;

	}

	/**
	 * Add a shutdown query.
	 *

	}

	/**
	 * Add a shutdown query.
	 *

	 */

	 */

	{
		global $shutdown_queries;
		if($name)
		{
			$shutdown_queries[$name] = $query;

	{
		global $shutdown_queries;
		if($name)
		{
			$shutdown_queries[$name] = $query;

		else
		{
			$shutdown_queries[] = $query;

		else
		{
			$shutdown_queries[] = $query;

	/**
	 * Performs a simple select query.
	 *

	/**
	 * Performs a simple select query.
	 *

	 */
	function simple_select($table, $fields="*", $conditions="", $options=array())
	{

	 */
	function simple_select($table, $fields="*", $conditions="", $options=array())
	{

		}

		if(isset($options['order_by']))

		}

		if(isset($options['order_by']))

			$query .= " ORDER BY ".$options['order_by'];
			if(isset($options['order_dir']))
			{
				$query .= " ".my_strtoupper($options['order_dir']);
			}

			$query .= " ORDER BY ".$options['order_by'];
			if(isset($options['order_dir']))
			{
				$query .= " ".my_strtoupper($options['order_dir']);
			}

		if(isset($options['limit_start']) && isset($options['limit']))

		if(isset($options['limit_start']) && isset($options['limit']))

			$query .= " LIMIT ".$options['limit_start'].", ".$options['limit'];
		}
		else if(isset($options['limit']))

			$query .= " LIMIT ".$options['limit_start'].", ".$options['limit'];
		}
		else if(isset($options['limit']))

			$query .= " LIMIT ".$options['limit'];

			$query .= " LIMIT ".$options['limit'];

		return $this->query($query);
	}

		return $this->query($query);
	}

	/**
	 * Build an insert query from an array.
	 *

	/**
	 * Build an insert query from an array.
	 *

	 * @return int The insert ID if available
	 */
	function insert_query($table, $array)

	 * @return int The insert ID if available
	 */
	function insert_query($table, $array)

			{
				if($value[0] != 'X') // Not escaped?
				{

			{
				if($value[0] != 'X') // Not escaped?
				{

				$array[$field] = $this->quote_val($value);
			}
		}

				$array[$field] = $this->quote_val($value);
			}
		}

		$fields = "`".implode("`,`", array_keys($array))."`";
		$values = implode(",", $array);
		$this->write_query("

		$fields = "`".implode("`,`", array_keys($array))."`";
		$values = implode(",", $array);
		$this->write_query("

	/**
	 * Build one query for multiple inserts from a multidimensional array.
	 *

	/**
	 * Build one query for multiple inserts from a multidimensional array.
	 *

	 */
	function insert_query_multiple($table, $array)
	{

	 */
	function insert_query_multiple($table, $array)
	{

		if(!is_array($array))
		{

		if(!is_array($array))
		{

		}
		// Field names
		$fields = array_keys($array[0]);

		}
		// Field names
		$fields = array_keys($array[0]);

	/**
	 * Build an update query from an array.
	 *

	/**
	 * Build an update query from an array.
	 *

	 */
	function update_query($table, $array, $where="", $limit="", $no_quote=false)
	{

	 */
	function update_query($table, $array, $where="", $limit="", $no_quote=false)
	{

		");
	}

		");
	}

	private function quote_val($value, $quote="'")
	{
		if(is_int($value))

	private function quote_val($value, $quote="'")
	{
		if(is_int($value))

	/**
	 * Build a delete query.
	 *

	/**
	 * Build a delete query.
	 *

	 */
	function delete_query($table, $where="", $limit="")
	{
		$query = "";
		if(!empty($where))

	 */
	function delete_query($table, $where="", $limit="")
	{
		$query = "";
		if(!empty($where))

			$query .= " WHERE $where";

			$query .= " WHERE $where";

		if(!empty($limit))
		{
			$query .= " LIMIT $limit";

		if(!empty($limit))
		{
			$query .= " LIMIT $limit";

	/**
	 * Escape a string according to the MySQL escape format.

	/**
	 * Escape a string according to the MySQL escape format.

	 * @return string The escaped string.
	 */
	function escape_string($string)
	{
		if($this->db_encoding == 'utf8')

	 * @return string The escaped string.
	 */
	function escape_string($string)
	{
		if($this->db_encoding == 'utf8')

			$string = validate_utf8_string($string, false);
		}

			$string = validate_utf8_string($string, false);
		}

		if(function_exists("mysqli_real_escape_string") && $this->read_link)
		{

		if(function_exists("mysqli_real_escape_string") && $this->read_link)
		{

	/**
	 * Frees the resources of a MySQLi query.
	 *

	/**
	 * Frees the resources of a MySQLi query.
	 *

	 */
	function free_result($query)
	{

	 */
	function free_result($query)
	{

	}

	/**
	 * Escape a string used within a like command.
	 *

	}

	/**
	 * Escape a string used within a like command.
	 *

	 * @return string The escaped string.
	 */
	function escape_string_like($string)

	 * @return string The escaped string.
	 */
	function escape_string_like($string)

			return $this->version;
		}

			return $this->version;
		}

		if($version)
		{

		if($version)
		{

	/**
	 * Optimizes a specific table.
	 *

	/**
	 * Optimizes a specific table.
	 *

	 */
	function optimize_table($table)
	{

	 */
	function optimize_table($table)
	{

	/**
	 * Analyzes a specific table.
	 *

	/**
	 * Analyzes a specific table.
	 *

	 */
	function analyze_table($table)
	{

	 */
	function analyze_table($table)
	{

	/**
	 * Show the "create table" command for a specific table.
	 *

	/**
	 * Show the "create table" command for a specific table.
	 *

	 * @return string The MySQL command to create the specified table.
	 */
	function show_create_table($table)

	 * @return string The MySQL command to create the specified table.
	 */
	function show_create_table($table)

	/**
	 * Show the "show fields from" command for a specific table.
	 *

	/**
	 * Show the "show fields from" command for a specific table.
	 *

	 */
	function show_fields_from($table)
	{
		$query = $this->write_query("SHOW FIELDS FROM ".$this->table_prefix.$table."");

	 */
	function show_fields_from($table)
	{
		$query = $this->write_query("SHOW FIELDS FROM ".$this->table_prefix.$table."");

		while($field = $this->fetch_array($query))
		{
			$field_info[] = $field;

		while($field = $this->fetch_array($query))
		{
			$field_info[] = $field;

	/**
	 * Returns whether or not the table contains a fulltext index.
	 *

	/**
	 * Returns whether or not the table contains a fulltext index.
	 *

	 * @return boolean True or false if the table has a fulltext index or not.
	 */
	function is_fulltext($table, $index="")

	 * @return boolean True or false if the table has a fulltext index or not.
	 */
	function is_fulltext($table, $index="")

	/**
	 * Returns whether or not this database engine supports fulltext indexing.
	 *

	/**
	 * Returns whether or not this database engine supports fulltext indexing.
	 *

	 * @return boolean True or false if supported or not.
	 */

	 * @return boolean True or false if supported or not.
	 */

	/**
	 * Returns whether or not this database engine supports boolean fulltext matching.
	 *

	/**
	 * Returns whether or not this database engine supports boolean fulltext matching.
	 *

	 * @return boolean True or false if supported or not.
	 */
	function supports_fulltext_boolean($table)

	 * @return boolean True or false if supported or not.
	 */
	function supports_fulltext_boolean($table)

	/**
	 * Checks to see if an index exists on a specified table
	 *

	/**
	 * Checks to see if an index exists on a specified table
	 *

	 */
	function index_exists($table, $index)
	{

	 */
	function index_exists($table, $index)
	{

	/**
	 * Creates a fulltext index on the specified column in the specified table with optional index name.
	 *

	/**
	 * Creates a fulltext index on the specified column in the specified table with optional index name.
	 *

	 */
	function create_fulltext_index($table, $column, $name="")
	{

	 */
	function create_fulltext_index($table, $column, $name="")
	{

	/**
	 * Drop an index with the specified name from the specified table
	 *

	/**
	 * Drop an index with the specified name from the specified table
	 *

	 */
	function drop_index($table, $name)
	{

	 */
	function drop_index($table, $name)
	{

	/**
	 * Drop an table with the specified table
	 *

	/**
	 * Drop an table with the specified table
	 *

	 */
	function drop_table($table, $hard=false, $table_prefix=true)
	{

	 */
	function drop_table($table, $hard=false, $table_prefix=true)
	{

	/**
	 * Renames a table
	 *

	/**
	 * Renames a table
	 *

	 */
	function rename_table($old_table, $new_table, $table_prefix=true)
	{

	 */
	function rename_table($old_table, $new_table, $table_prefix=true)
	{

	/**
	 * Replace contents of table with values
	 *

	/**
	 * Replace contents of table with values
	 *

	 */
	function replace_query($table, $replacements=array())
	{

	 */
	function replace_query($table, $replacements=array())
	{

	/**
	 * Drops a column
	 *

	/**
	 * Drops a column
	 *

	 */
	function drop_column($table, $column)
	{

	 */
	function drop_column($table, $column)
	{

	/**
	 * Adds a column
	 *

	/**
	 * Adds a column
	 *

	 */
	function add_column($table, $column, $definition)
	{

	 */
	function add_column($table, $column, $definition)
	{

	/**
	 * Modifies a column
	 *

	/**
	 * Modifies a column
	 *

	 */
	function modify_column($table, $column, $new_definition)
	{

	 */
	function modify_column($table, $column, $new_definition)
	{

	/**
	 * Renames a column
	 *

	/**
	 * Renames a column
	 *

	 */
	function rename_column($table, $old_column, $new_column, $new_definition)
	{

	 */
	function rename_column($table, $old_column, $new_column, $new_definition)
	{

	/**
	 * Sets the table prefix used by the simple select, insert, update and delete functions
	 *

	/**
	 * Sets the table prefix used by the simple select, insert, update and delete functions
	 *

	 */
	function set_table_prefix($prefix)
	{

	 */
	function set_table_prefix($prefix)
	{

	/**
	 * Fetched the total size of all mysql tables or a specific table
	 *

	/**
	 * Fetched the total size of all mysql tables or a specific table
	 *

	 * @return integer the total size of all mysql tables or a specific table
	 */
	function fetch_size($table='')

	 * @return integer the total size of all mysql tables or a specific table
	 */
	function fetch_size($table='')

	/**
	 * Fetch a list of database character sets this DBMS supports
	 *

	/**
	 * Fetch a list of database character sets this DBMS supports
	 *

	 */
	function fetch_db_charsets()
	{

	 */
	function fetch_db_charsets()
	{

			'cp850' => 'DOS West European',
			'hp8' => 'HP West European',
			'koi8r' => 'KOI8-R Relcom Russian',

			'cp850' => 'DOS West European',
			'hp8' => 'HP West European',
			'koi8r' => 'KOI8-R Relcom Russian',

			'latin2' => 'ISO 8859-2 Central European',
			'swe7' => '7bit Swedish',
			'ascii' => 'US ASCII',

			'latin2' => 'ISO 8859-2 Central European',
			'swe7' => '7bit Swedish',
			'ascii' => 'US ASCII',

			'cp1251' => 'Windows Cyrillic',
			'cp1256' => 'Windows Arabic',
			'cp1257' => 'Windows Baltic',

			'cp1251' => 'Windows Cyrillic',
			'cp1256' => 'Windows Arabic',
			'cp1257' => 'Windows Baltic',

			'geostd8' => 'GEOSTD8 Georgian',
			'cp932' => 'SJIS for Windows Japanese',
			'eucjpms' => 'UJIS for Windows Japanese',

			'geostd8' => 'GEOSTD8 Georgian',
			'cp932' => 'SJIS for Windows Japanese',
			'eucjpms' => 'UJIS for Windows Japanese',

	/**
	 * Fetch a database collation for a particular database character set
	 *

	/**
	 * Fetch a database collation for a particular database character set
	 *

	 */
	function fetch_charset_collation($charset)
	{

	 */
	function fetch_charset_collation($charset)
	{

			'cp1251' => 'cp1251_general_ci',
			'cp1256' => 'cp1256_general_ci',
			'cp1257' => 'cp1257_general_ci',

			'cp1251' => 'cp1251_general_ci',
			'cp1256' => 'cp1256_general_ci',
			'cp1257' => 'cp1257_general_ci',

			'geostd8' => 'geostd8_general_ci',
			'cp932' => 'cp932_japanese_ci',
			'eucjpms' => 'eucjpms_japanese_ci',

			'geostd8' => 'geostd8_general_ci',
			'cp932' => 'cp932_japanese_ci',
			'eucjpms' => 'eucjpms_japanese_ci',

	/**
	 * Binary database fields require special attention.
	 *

	/**
	 * Binary database fields require special attention.
	 *

	 * @return string Encoded binary value
	 */
	function escape_binary($string)

	 * @return string Encoded binary value
	 */
	function escape_binary($string)

	/**
	 * Unescape binary data.
	 *

	/**
	 * Unescape binary data.
	 *

	 * @return string Encoded binary value
	 */
	function unescape_binary($string)

	 * @return string Encoded binary value
	 */
	function unescape_binary($string)