| Zeile 6 | Zeile 6 |
|---|
* Website: http://www.mybboard.net
* License: http://www.mybboard.net/about/license
*
|
* Website: http://www.mybboard.net
* License: http://www.mybboard.net/about/license
*
|
* $Id: db_mysql.php 4067 2008-08-04 03:59:08Z Tikitiki $
| * $Id: db_mysql.php 5379 2011-02-21 11:06:42Z Tomm $
|
*/
class DB_MySQL
| */
class DB_MySQL
|
| Zeile 143 | Zeile 143 |
|---|
{
$connections['read'][] = $config;
}
|
{
$connections['read'][] = $config;
}
|
| | else
|
// Connecting to more than one server
{
// Specified multiple servers, but no specific read/write servers
| // Connecting to more than one server
{
// Specified multiple servers, but no specific read/write servers
|
| Zeile 157 | Zeile 158 |
|---|
else
{
$connections = $config;
|
else
{
$connections = $config;
|
}
| }
|
}
|
}
|
|
|
$this->db_encoding = $config['encoding'];
// Actually connect to the specified servers
| $this->db_encoding = $config['encoding'];
// Actually connect to the specified servers
|
| Zeile 171 | Zeile 172 |
|---|
}
if(array_key_exists('hostname', $connections[$type]))
|
}
if(array_key_exists('hostname', $connections[$type]))
|
{
| {
|
$details = $connections[$type];
unset($connections);
$connections[$type][] = $details;
| $details = $connections[$type];
unset($connections);
$connections[$type][] = $details;
|
| Zeile 185 | Zeile 186 |
|---|
{
$connect_function = "mysql_connect";
if($single_connection['pconnect'])
|
{
$connect_function = "mysql_connect";
if($single_connection['pconnect'])
|
{
| {
|
$connect_function = "mysql_pconnect";
}
| $connect_function = "mysql_pconnect";
}
|
| Zeile 213 | Zeile 214 |
|---|
// No write server was specified (simple connection or just multiple servers) - mirror write link
if(!array_key_exists('write', $connections))
|
// 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;
|
$this->write_link = &$this->read_link;
|
}
| }
|
// Have no read connection?
if(!$this->read_link)
|
// Have no read connection?
if(!$this->read_link)
|
{
| {
|
$this->error("[READ] Unable to connect to MySQL server");
|
$this->error("[READ] Unable to connect to MySQL server");
|
}
| }
|
// No write?
else if(!$this->write_link)
{
$this->error("[WRITE] Unable to connect to MySQL server");
|
// No write?
else if(!$this->write_link)
{
$this->error("[WRITE] Unable to connect to MySQL server");
|
}
| }
|
// Select databases
|
// Select databases
|
$this->select_db($config['database']);
| if(!$this->select_db($config['database']))
{
return false;
}
|
$this->current_link = &$this->read_link;
return $this->read_link;
|
$this->current_link = &$this->read_link;
return $this->read_link;
|
| Zeile 256 | Zeile 260 |
|---|
else
{
$success = $read_success;
|
else
{
$success = $read_success;
|
}
| }
|
if($success && $this->db_encoding)
{
|
if($success && $this->db_encoding)
{
|
| Zeile 481 | Zeile 485 |
|---|
/**
* Return an error number.
|
/**
* Return an error number.
|
*
| *
|
* @return int The error number of the current error.
*/
function error_number()
| * @return int The error number of the current error.
*/
function error_number()
|
| Zeile 489 | Zeile 493 |
|---|
if($this->current_link)
{
return @mysql_errno($this->current_link);
|
if($this->current_link)
{
return @mysql_errno($this->current_link);
|
}
| }
|
else
{
return @mysql_errno();
|
else
{
return @mysql_errno();
|
}
}
| }
}
|
/**
* Return an error string.
*
| /**
* Return an error string.
*
|
| Zeile 523 | Zeile 527 |
|---|
if($this->error_reporting)
{
if(class_exists("errorHandler"))
|
if($this->error_reporting)
{
if(class_exists("errorHandler"))
|
{
| {
|
global $error_handler;
if(!is_object($error_handler))
| global $error_handler;
if(!is_object($error_handler))
|
| Zeile 543 | Zeile 547 |
|---|
{
trigger_error("<strong>[SQL] [".$this->error_number()."] ".$this->error_string()."</strong><br />{$string}", E_USER_ERROR);
}
|
{
trigger_error("<strong>[SQL] [".$this->error_number()."] ".$this->error_string()."</strong><br />{$string}", E_USER_ERROR);
}
|
| | }
else
{
return false;
|
}
}
|
}
}
|
|
|
/**
* Returns the number of affected rows in a query.
*
* @return int The number of affected rows.
|
/**
* Returns the number of affected rows in a query.
*
* @return int The number of affected rows.
|
*/
| */
|
function affected_rows()
{
return mysql_affected_rows($this->current_link);
| function affected_rows()
{
return mysql_affected_rows($this->current_link);
|
| Zeile 592 | Zeile 600 |
|---|
}
return $tables;
|
}
return $tables;
|
}
| }
|
/**
* Check if a table exists in a database.
*
| /**
* Check if a table exists in a database.
*
|
| Zeile 609 | Zeile 617 |
|---|
$query = $this->write_query("
SHOW TABLES
LIKE '{$this->table_prefix}$table'
|
$query = $this->write_query("
SHOW TABLES
LIKE '{$this->table_prefix}$table'
|
");
$exists = $this->num_rows($query);
$this->error_reporting = $err;
if($exists > 0)
{
return true;
}
else
{
return false;
}
}
| ");
$exists = $this->num_rows($query);
$this->error_reporting = $err;
if($exists > 0)
{
return true;
}
else
{
return false;
}
}
|
/**
* Check if a field exists in a database.
*
| /**
* Check if a field exists in a database.
*
|
| Zeile 691 | Zeile 699 |
|---|
{
$query .= " ".my_strtoupper($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'];
|
$query .= " LIMIT ".$options['limit_start'].", ".$options['limit'];
|
}
| }
|
elseif(isset($options['limit']))
{
$query .= " LIMIT ".$options['limit'];
| elseif(isset($options['limit']))
{
$query .= " LIMIT ".$options['limit'];
|
| Zeile 705 | Zeile 713 |
|---|
/**
* Build an insert query from an array.
|
/**
* Build an insert query from an array.
|
*
| *
|
* @param string The table name to perform the query on.
* @param array An array of fields and their values.
* @return int The insert ID if available
| * @param string The table name to perform the query on.
* @param array An array of fields and their values.
* @return int The insert ID if available
|
| Zeile 734 | Zeile 742 |
|---|
* @return int The insert ID if available
*/
function insert_query_multiple($table, $array)
|
* @return int The insert ID if available
*/
function insert_query_multiple($table, $array)
|
{
| {
|
if(!is_array($array))
{
return false;
| if(!is_array($array))
{
return false;
|
| Zeile 762 | Zeile 770 |
|---|
*
* @param string The table name to perform the query on.
* @param array An array of fields and their values.
|
*
* @param string The table name to perform the query on.
* @param array An array of fields and their values.
|
* @param string An optional where clause for the query.
| * @param string An optional where clause for the query.
|
* @param string An optional limit clause for the query.
* @return resource The query data.
*/
| * @param string An optional limit clause for the query.
* @return resource The query data.
*/
|
| Zeile 776 | Zeile 784 |
|---|
$comma = "";
$query = "";
$quote = "'";
|
$comma = "";
$query = "";
$quote = "'";
|
|
|
if($no_quote == true)
|
if($no_quote == true)
|
{
| {
|
$quote = "";
|
$quote = "";
|
}
| }
|
foreach($array as $field => $value)
|
foreach($array as $field => $value)
|
{
| {
|
$query .= $comma."`".$field."`={$quote}{$value}{$quote}";
$comma = ", ";
}
|
$query .= $comma."`".$field."`={$quote}{$value}{$quote}";
$comma = ", ";
}
|
if(!empty($where))
{
$query .= " WHERE $where";
}
| if(!empty($where))
{
$query .= " WHERE $where";
}
|
if(!empty($limit))
{
$query .= " LIMIT $limit";
| if(!empty($limit))
{
$query .= " LIMIT $limit";
|
| Zeile 818 | Zeile 826 |
|---|
if(!empty($where))
{
$query .= " WHERE $where";
|
if(!empty($where))
{
$query .= " WHERE $where";
|
}
| }
|
if(!empty($limit))
{
$query .= " LIMIT $limit";
| if(!empty($limit))
{
$query .= " LIMIT $limit";
|
| Zeile 830 | Zeile 838 |
|---|
FROM {$this->table_prefix}$table
$query
");
|
FROM {$this->table_prefix}$table
$query
");
|
}
/**
| }
/**
|
* Escape a string according to the MySQL escape format.
*
|
* Escape a string according to the MySQL escape format.
*
|
| Zeile 846 | Zeile 854 |
|---|
$string = mysql_real_escape_string($string, $this->read_link);
}
else
|
$string = mysql_real_escape_string($string, $this->read_link);
}
else
|
{
| {
|
$string = addslashes($string);
}
return $string;
| $string = addslashes($string);
}
return $string;
|
| Zeile 872 | Zeile 880 |
|---|
function escape_string_like($string)
{
return $this->escape_string(str_replace(array('%', '_') , array('\\%' , '\\_') , $string));
|
function escape_string_like($string)
{
return $this->escape_string(str_replace(array('%', '_') , array('\\%' , '\\_') , $string));
|
}
/**
| }
/**
|
* Gets the current version of MySQL.
*
* @return string Version of MySQL.
| * Gets the current version of MySQL.
*
* @return string Version of MySQL.
|
| Zeile 930 | Zeile 938 |
|---|
/**
* Show the "show fields from" command for a specific table.
|
/**
* Show the "show fields from" command for a specific table.
|
*
| *
|
* @param string The name of the table.
* @return string Field info for that table
*/
| * @param string The name of the table.
* @return string Field info for that table
*/
|
| Zeile 942 | Zeile 950 |
|---|
$field_info[] = $field;
}
return $field_info;
|
$field_info[] = $field;
}
return $field_info;
|
}
/**
| }
/**
|
* Returns whether or not the table contains a fulltext index.
*
* @param string The name of the table.
| * Returns whether or not the table contains a fulltext index.
*
* @param string The name of the table.
|
| Zeile 966 | Zeile 974 |
|---|
}
}
if(preg_match('#FULLTEXT KEY#i', $structure))
|
}
}
if(preg_match('#FULLTEXT KEY#i', $structure))
|
{
return true;
}
return false;
}
/**
| {
return true;
}
return false;
}
/**
|
* Returns whether or not this database engine supports fulltext indexing.
*
* @param string The table to be checked.
| * Returns whether or not this database engine supports fulltext indexing.
*
* @param string The table to be checked.
|
| Zeile 1010 | Zeile 1018 |
|---|
$version = $this->get_version();
$supports_fulltext = $this->supports_fulltext($table);
if($version >= '4.0.1' && $supports_fulltext == true)
|
$version = $this->get_version();
$supports_fulltext = $this->supports_fulltext($table);
if($version >= '4.0.1' && $supports_fulltext == true)
|
{
return true;
}
return false;
}
| {
return true;
}
return false;
}
/**
* Creates a fulltext index on the specified column in the specified table with optional index name.
*
* @param string The name of the table.
* @param string Name of the column to be indexed.
* @param string The index name, optional.
*/
function create_fulltext_index($table, $column, $name="")
{
$this->write_query("
ALTER TABLE {$this->table_prefix}$table
ADD FULLTEXT $name ($column)
");
}
|
/**
|
/**
|
* Creates a fulltext index on the specified column in the specified table with optional index name.
| * Drop an index with the specified name from the specified table
|
*
* @param string The name of the table.
|
*
* @param string The name of the table.
|
* @param string Name of the column to be indexed.
* @param string The index name, optional.
| * @param string The name of the index.
|
*/
|
*/
|
function create_fulltext_index($table, $column, $name="")
| function drop_index($table, $name)
|
{
$this->write_query("
ALTER TABLE {$this->table_prefix}$table
|
{
$this->write_query("
ALTER TABLE {$this->table_prefix}$table
|
ADD FULLTEXT $name ($column)
| DROP INDEX $name
|
");
}
|
");
}
|
|
|
/**
|
/**
|
* Drop an index with the specified name from the specified table
| * Checks to see if an index exists on a specified table
|
*
* @param string The name of the table.
* @param string The name of the index.
*/
|
*
* @param string The name of the table.
* @param string The name of the index.
*/
|
function drop_index($table, $name)
| function index_exists($table, $index)
|
{
|
{
|
$this->write_query("
ALTER TABLE {$this->table_prefix}$table
DROP INDEX $name
");
| $index_exists = false;
$query = $this->write_query("SHOW INDEX FROM {$this->table_prefix}{$table}");
while($ukey = $this->fetch_array($query))
{
if($ukey['Key_name'] == $index)
{
$index_exists = true;
break;
}
}
if($index_exists)
{
return true;
}
return false;
|
}
/**
| }
/**
|
| Zeile 1138 | Zeile 1173 |
|---|
*/
function fetch_db_charsets()
{
|
*/
function fetch_db_charsets()
{
|
if($this_link && $this->get_version() < 4.1)
| if($this->link && version_compare($this->get_version(), "4.1", "<"))
|
{
return false;
}
| {
return false;
}
|