You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
336 lines
9.2 KiB
336 lines
9.2 KiB
<?php |
|
/** |
|
* CodeIgniter |
|
* |
|
* An open source application development framework for PHP |
|
* |
|
* This content is released under the MIT License (MIT) |
|
* |
|
* Copyright (c) 2014 - 2016, British Columbia Institute of Technology |
|
* |
|
* Permission is hereby granted, free of charge, to any person obtaining a copy |
|
* of this software and associated documentation files (the "Software"), to deal |
|
* in the Software without restriction, including without limitation the rights |
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell |
|
* copies of the Software, and to permit persons to whom the Software is |
|
* furnished to do so, subject to the following conditions: |
|
* |
|
* The above copyright notice and this permission notice shall be included in |
|
* all copies or substantial portions of the Software. |
|
* |
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, |
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE |
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER |
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN |
|
* THE SOFTWARE. |
|
* |
|
* @package CodeIgniter |
|
* @author EllisLab Dev Team |
|
* @copyright Copyright (c) 2008 - 2014, EllisLab, Inc. (https://ellislab.com/) |
|
* @copyright Copyright (c) 2014 - 2016, British Columbia Institute of Technology (http://bcit.ca/) |
|
* @license http://opensource.org/licenses/MIT MIT License |
|
* @link https://codeigniter.com |
|
* @since Version 3.0.0 |
|
* @filesource |
|
*/ |
|
defined('BASEPATH') OR exit('No direct script access allowed'); |
|
|
|
/** |
|
* PDO MySQL Database Adapter Class |
|
* |
|
* Note: _DB is an extender class that the app controller |
|
* creates dynamically based on whether the query builder |
|
* class is being used or not. |
|
* |
|
* @package CodeIgniter |
|
* @subpackage Drivers |
|
* @category Database |
|
* @author EllisLab Dev Team |
|
* @link https://codeigniter.com/user_guide/database/ |
|
*/ |
|
class CI_DB_pdo_mysql_driver extends CI_DB_pdo_driver { |
|
|
|
/** |
|
* Sub-driver |
|
* |
|
* @var string |
|
*/ |
|
public $subdriver = 'mysql'; |
|
|
|
/** |
|
* Compression flag |
|
* |
|
* @var bool |
|
*/ |
|
public $compress = FALSE; |
|
|
|
/** |
|
* Strict ON flag |
|
* |
|
* Whether we're running in strict SQL mode. |
|
* |
|
* @var bool |
|
*/ |
|
public $stricton; |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Identifier escape character |
|
* |
|
* @var string |
|
*/ |
|
protected $_escape_char = '`'; |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Class constructor |
|
* |
|
* Builds the DSN if not already set. |
|
* |
|
* @param array $params |
|
* @return void |
|
*/ |
|
public function __construct($params) |
|
{ |
|
parent::__construct($params); |
|
|
|
if (empty($this->dsn)) |
|
{ |
|
$this->dsn = 'mysql:host='.(empty($this->hostname) ? '127.0.0.1' : $this->hostname); |
|
|
|
empty($this->port) OR $this->dsn .= ';port='.$this->port; |
|
empty($this->database) OR $this->dsn .= ';dbname='.$this->database; |
|
empty($this->char_set) OR $this->dsn .= ';charset='.$this->char_set; |
|
} |
|
elseif ( ! empty($this->char_set) && strpos($this->dsn, 'charset=', 6) === FALSE && is_php('5.3.6')) |
|
{ |
|
$this->dsn .= ';charset='.$this->char_set; |
|
} |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Database connection |
|
* |
|
* @param bool $persistent |
|
* @return object |
|
*/ |
|
public function db_connect($persistent = FALSE) |
|
{ |
|
/* Prior to PHP 5.3.6, even if the charset was supplied in the DSN |
|
* on connect - it was ignored. This is a work-around for the issue. |
|
* |
|
* Reference: http://www.php.net/manual/en/ref.pdo-mysql.connection.php |
|
*/ |
|
if ( ! is_php('5.3.6') && ! empty($this->char_set)) |
|
{ |
|
$this->options[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET NAMES '.$this->char_set |
|
.(empty($this->dbcollat) ? '' : ' COLLATE '.$this->dbcollat); |
|
} |
|
|
|
if (isset($this->stricton)) |
|
{ |
|
if ($this->stricton) |
|
{ |
|
$sql = 'CONCAT(@@sql_mode, ",", "STRICT_ALL_TABLES")'; |
|
} |
|
else |
|
{ |
|
$sql = 'REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE( |
|
@@sql_mode, |
|
"STRICT_ALL_TABLES,", ""), |
|
",STRICT_ALL_TABLES", ""), |
|
"STRICT_ALL_TABLES", ""), |
|
"STRICT_TRANS_TABLES,", ""), |
|
",STRICT_TRANS_TABLES", ""), |
|
"STRICT_TRANS_TABLES", "")'; |
|
} |
|
|
|
if ( ! empty($sql)) |
|
{ |
|
if (empty($this->options[PDO::MYSQL_ATTR_INIT_COMMAND])) |
|
{ |
|
$this->options[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET SESSION sql_mode = '.$sql; |
|
} |
|
else |
|
{ |
|
$this->options[PDO::MYSQL_ATTR_INIT_COMMAND] .= ', @@session.sql_mode = '.$sql; |
|
} |
|
} |
|
} |
|
|
|
if ($this->compress === TRUE) |
|
{ |
|
$this->options[PDO::MYSQL_ATTR_COMPRESS] = TRUE; |
|
} |
|
|
|
// SSL support was added to PDO_MYSQL in PHP 5.3.7 |
|
if (is_array($this->encrypt) && is_php('5.3.7')) |
|
{ |
|
$ssl = array(); |
|
empty($this->encrypt['ssl_key']) OR $ssl[PDO::MYSQL_ATTR_SSL_KEY] = $this->encrypt['ssl_key']; |
|
empty($this->encrypt['ssl_cert']) OR $ssl[PDO::MYSQL_ATTR_SSL_CERT] = $this->encrypt['ssl_cert']; |
|
empty($this->encrypt['ssl_ca']) OR $ssl[PDO::MYSQL_ATTR_SSL_CA] = $this->encrypt['ssl_ca']; |
|
empty($this->encrypt['ssl_capath']) OR $ssl[PDO::MYSQL_ATTR_SSL_CAPATH] = $this->encrypt['ssl_capath']; |
|
empty($this->encrypt['ssl_cipher']) OR $ssl[PDO::MYSQL_ATTR_SSL_CIPHER] = $this->encrypt['ssl_cipher']; |
|
|
|
// DO NOT use array_merge() here! |
|
// It re-indexes numeric keys and the PDO_MYSQL_ATTR_SSL_* constants are integers. |
|
empty($ssl) OR $this->options += $ssl; |
|
} |
|
|
|
// Prior to version 5.7.3, MySQL silently downgrades to an unencrypted connection if SSL setup fails |
|
if ( |
|
($pdo = parent::db_connect($persistent)) !== FALSE |
|
&& ! empty($ssl) |
|
&& version_compare($pdo->getAttribute(PDO::ATTR_CLIENT_VERSION), '5.7.3', '<=') |
|
&& empty($pdo->query("SHOW STATUS LIKE 'ssl_cipher'")->fetchObject()->Value) |
|
) |
|
{ |
|
$message = 'PDO_MYSQL was configured for an SSL connection, but got an unencrypted connection instead!'; |
|
log_message('error', $message); |
|
return ($this->db->db_debug) ? $this->db->display_error($message, '', TRUE) : FALSE; |
|
} |
|
|
|
return $pdo; |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Select the database |
|
* |
|
* @param string $database |
|
* @return bool |
|
*/ |
|
public function db_select($database = '') |
|
{ |
|
if ($database === '') |
|
{ |
|
$database = $this->database; |
|
} |
|
|
|
if (FALSE !== $this->simple_query('USE '.$this->escape_identifiers($database))) |
|
{ |
|
$this->database = $database; |
|
return TRUE; |
|
} |
|
|
|
return FALSE; |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Show table query |
|
* |
|
* Generates a platform-specific query string so that the table names can be fetched |
|
* |
|
* @param bool $prefix_limit |
|
* @return string |
|
*/ |
|
protected function _list_tables($prefix_limit = FALSE) |
|
{ |
|
$sql = 'SHOW TABLES'; |
|
|
|
if ($prefix_limit === TRUE && $this->dbprefix !== '') |
|
{ |
|
return $sql." LIKE '".$this->escape_like_str($this->dbprefix)."%'"; |
|
} |
|
|
|
return $sql; |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Show column query |
|
* |
|
* Generates a platform-specific query string so that the column names can be fetched |
|
* |
|
* @param string $table |
|
* @return string |
|
*/ |
|
protected function _list_columns($table = '') |
|
{ |
|
return 'SHOW COLUMNS FROM '.$this->protect_identifiers($table, TRUE, NULL, FALSE); |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Returns an object with field data |
|
* |
|
* @param string $table |
|
* @return array |
|
*/ |
|
public function field_data($table) |
|
{ |
|
if (($query = $this->query('SHOW COLUMNS FROM '.$this->protect_identifiers($table, TRUE, NULL, FALSE))) === FALSE) |
|
{ |
|
return FALSE; |
|
} |
|
$query = $query->result_object(); |
|
|
|
$retval = array(); |
|
for ($i = 0, $c = count($query); $i < $c; $i++) |
|
{ |
|
$retval[$i] = new stdClass(); |
|
$retval[$i]->name = $query[$i]->Field; |
|
|
|
sscanf($query[$i]->Type, '%[a-z](%d)', |
|
$retval[$i]->type, |
|
$retval[$i]->max_length |
|
); |
|
|
|
$retval[$i]->default = $query[$i]->Default; |
|
$retval[$i]->primary_key = (int) ($query[$i]->Key === 'PRI'); |
|
} |
|
|
|
return $retval; |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* Truncate statement |
|
* |
|
* Generates a platform-specific truncate string from the supplied data |
|
* |
|
* If the database does not support the TRUNCATE statement, |
|
* then this method maps to 'DELETE FROM table' |
|
* |
|
* @param string $table |
|
* @return string |
|
*/ |
|
protected function _truncate($table) |
|
{ |
|
return 'TRUNCATE '.$table; |
|
} |
|
|
|
// -------------------------------------------------------------------- |
|
|
|
/** |
|
* FROM tables |
|
* |
|
* Groups tables in FROM clauses if needed, so there is no confusion |
|
* about operator precedence. |
|
* |
|
* @return string |
|
*/ |
|
protected function _from_tables() |
|
{ |
|
if ( ! empty($this->qb_join) && count($this->qb_from) > 1) |
|
{ |
|
return '('.implode(', ', $this->qb_from).')'; |
|
} |
|
|
|
return implode(', ', $this->qb_from); |
|
} |
|
|
|
}
|
|
|