mirror of
https://github.com/Pathduck/gallery3.git
synced 2026-05-20 03:19:13 -04:00
93 lines
2.3 KiB
PHP
93 lines
2.3 KiB
PHP
<?php defined('SYSPATH') or die('No direct script access.');
|
|
/**
|
|
* MySQL database connection.
|
|
*
|
|
* $Id: Database_Mysqli.php 4679 2009-11-10 01:45:52Z isaiah $
|
|
*
|
|
* @package Kohana
|
|
* @author Kohana Team
|
|
* @copyright (c) 2008-2009 Kohana Team
|
|
* @license http://kohanaphp.com/license
|
|
*/
|
|
|
|
define('RUNS_MYSQLND', function_exists('mysqli_fetch_all'));
|
|
|
|
class Database_Mysqli_Core extends Database_Mysql {
|
|
|
|
public function connect()
|
|
{
|
|
if (is_object($this->connection))
|
|
return;
|
|
|
|
extract($this->config['connection']);
|
|
|
|
// Persistent connections are supported as of PHP 5.3
|
|
if (RUNS_MYSQLND AND $this->config['persistent'] === TRUE)
|
|
{
|
|
$host = 'p:'.$host;
|
|
}
|
|
|
|
$host = isset($host) ? $host : $socket;
|
|
|
|
if($this->connection = new mysqli($host, $user, $pass, $database, $port)) {
|
|
|
|
if (isset($this->config['character_set']))
|
|
{
|
|
// Set the character set
|
|
$this->set_charset($this->config['character_set']);
|
|
}
|
|
|
|
// Clear password after successful connect
|
|
$this->db_config['connection']['pass'] = NULL;
|
|
|
|
return $this->connection;
|
|
}
|
|
|
|
// Unable to connect to the database
|
|
throw new Database_Exception('#:errno: :error',
|
|
array(':error' => $this->connection->connect_error,
|
|
':errno' => $this->connection->connect_errno));
|
|
}
|
|
|
|
public function disconnect()
|
|
{
|
|
return is_object($this->connection) and $this->connection->close();
|
|
}
|
|
|
|
public function set_charset($charset)
|
|
{
|
|
// Make sure the database is connected
|
|
is_object($this->connection) or $this->connect();
|
|
|
|
if ( ! $this->connection->set_charset($charset))
|
|
{
|
|
// Unable to set charset
|
|
throw new Database_Exception('#:errno: :error',
|
|
array(':error' => $this->connection->connect_error,
|
|
':errno' => $this->connection->connect_errno));
|
|
}
|
|
}
|
|
|
|
public function query_execute($sql)
|
|
{
|
|
// Make sure the database is connected
|
|
is_object($this->connection) or $this->connect();
|
|
|
|
$result = $this->connection->query($sql);
|
|
|
|
// Set the last query
|
|
$this->last_query = $sql;
|
|
|
|
return new Database_Mysqli_Result($result, $sql, $this->connection, $this->config['object']);
|
|
}
|
|
|
|
public function escape($value)
|
|
{
|
|
// Make sure the database is connected
|
|
is_object($this->connection) or $this->connect();
|
|
|
|
return $this->connection->real_escape_string($value);
|
|
}
|
|
|
|
} // End Database_MySQLi
|