mirror of
https://github.com/Sarjuuk/aowow.git
synced 2025-11-29 15:58:16 +08:00
item another one >.<
This commit is contained in:
Sarjuuk
273
includes/libs/DbSimple/Connect.php
Normal file
273
includes/libs/DbSimple/Connect.php
Normal file
@@ -0,0 +1,273 @@
|
||||
<?php
|
||||
|
||||
/**
|
||||
* Используйте константу DBSIMPLE_SKIP в качестве подстановочного значения чтобы пропустить опцональный SQL блок.
|
||||
*/
|
||||
define('DBSIMPLE_SKIP', log(0));
|
||||
/**
|
||||
* Имена специализированных колонок в резальтате,
|
||||
* которые используются как ключи в результирующем массиве
|
||||
*/
|
||||
define('DBSIMPLE_ARRAY_KEY', 'ARRAY_KEY'); // hash-based resultset support
|
||||
define('DBSIMPLE_PARENT_KEY', 'PARENT_KEY'); // forrest-based resultset support
|
||||
|
||||
/**
|
||||
* Класс обертка для DbSimple
|
||||
*
|
||||
* <br>нужен для ленивой инициализации коннекта к базе
|
||||
*
|
||||
* @package DbSimple
|
||||
* @method mixed transaction(string $mode=null)
|
||||
* @method mixed commit()
|
||||
* @method mixed rollback()
|
||||
* @method mixed select(string $query [, $arg1] [,$arg2] ...)
|
||||
* @method mixed selectRow(string $query [, $arg1] [,$arg2] ...)
|
||||
* @method array selectCol(string $query [, $arg1] [,$arg2] ...)
|
||||
* @method string selectCell(string $query [, $arg1] [,$arg2] ...)
|
||||
* @method mixed query(string $query [, $arg1] [,$arg2] ...)
|
||||
* @method string escape(mixed $s, bool $isIdent=false)
|
||||
* @method DbSimple_SubQuery subquery(string $query [, $arg1] [,$arg2] ...)
|
||||
* @method callback setLogger(callback $logger)
|
||||
* @method callback setCacher(callback $cacher)
|
||||
* @method string setIdentPrefix($prx)
|
||||
* @method string setCachePrefix($prx)
|
||||
*/
|
||||
class DbSimple_Connect
|
||||
{
|
||||
/** @var DbSimple_Generic_Database База данных */
|
||||
protected $DbSimple;
|
||||
/** @var string DSN подключения */
|
||||
protected $DSN;
|
||||
/** @var string Тип базы данных */
|
||||
protected $shema;
|
||||
/** @var array Что выставить при коннекте */
|
||||
protected $init;
|
||||
/** @var integer код ошибки */
|
||||
public $error = null;
|
||||
/** @var string сообщение об ошибке */
|
||||
public $errmsg = null;
|
||||
|
||||
/**
|
||||
* Конструктор только запоминает переданный DSN
|
||||
* создание класса и коннект происходит позже
|
||||
*
|
||||
* @param string $dsn DSN строка БД
|
||||
*/
|
||||
public function __construct($dsn)
|
||||
{
|
||||
$this->DbSimple = null;
|
||||
$this->DSN = $dsn;
|
||||
$this->init = array();
|
||||
$this->shema = ucfirst(substr($dsn, 0, strpos($dsn, ':')));
|
||||
}
|
||||
|
||||
/**
|
||||
* Взять базу из пула коннектов
|
||||
*
|
||||
* @param string $dsn DSN строка БД
|
||||
* @return DbSimple_Connect
|
||||
*/
|
||||
public static function get($dsn)
|
||||
{
|
||||
static $pool = array();
|
||||
return isset($pool[$dsn]) ? $pool[$dsn] : $pool[$dsn] = new self($dsn);
|
||||
}
|
||||
|
||||
/**
|
||||
* Возвращает тип базы данных
|
||||
*
|
||||
* @return string имя типа БД
|
||||
*/
|
||||
public function getShema()
|
||||
{
|
||||
return $this->shema;
|
||||
}
|
||||
|
||||
/**
|
||||
* Коннект при первом запросе к базе данных
|
||||
*/
|
||||
public function __call($method, $params)
|
||||
{
|
||||
if ($this->DbSimple === null)
|
||||
$this->connect($this->DSN);
|
||||
return call_user_func_array(array(&$this->DbSimple, $method), $params);
|
||||
}
|
||||
|
||||
/**
|
||||
* mixed selectPage(int &$total, string $query [, $arg1] [,$arg2] ...)
|
||||
* Функцию нужно вызвать отдельно из-за передачи по ссылке
|
||||
*/
|
||||
public function selectPage(&$total, $query)
|
||||
{
|
||||
if ($this->DbSimple === null)
|
||||
$this->connect($this->DSN);
|
||||
$args = func_get_args();
|
||||
$args[0] = &$total;
|
||||
return call_user_func_array(array(&$this->DbSimple, 'selectPage'), $args);
|
||||
}
|
||||
|
||||
/**
|
||||
* Подключение к базе данных
|
||||
* @param string $dsn DSN строка БД
|
||||
*/
|
||||
protected function connect($dsn)
|
||||
{
|
||||
$parsed = $this->parseDSN($dsn);
|
||||
if (!$parsed)
|
||||
$this->errorHandler('Ошибка разбора строки DSN', $dsn);
|
||||
if (!isset($parsed['scheme']))
|
||||
$this->errorHandler('Невозможно загрузить драйвер базы данных', $parsed);
|
||||
$this->shema = ucfirst($parsed['scheme']);
|
||||
require_once dirname(__FILE__).'/'.$this->shema.'.php';
|
||||
$class = 'DbSimple_'.$this->shema;
|
||||
$this->DbSimple = new $class($parsed);
|
||||
$this->errmsg = &$this->DbSimple->errmsg;
|
||||
$this->error = &$this->DbSimple->error;
|
||||
$prefix = isset($parsed['prefix']) ? $parsed['prefix'] : ($this->_identPrefix ? $this->_identPrefix : false);
|
||||
if ($prefix)
|
||||
$this->DbSimple->setIdentPrefix($prefix);
|
||||
if ($this->_cachePrefix) $this->DbSimple->setCachePrefix($this->_cachePrefix);
|
||||
if ($this->_cacher) $this->DbSimple->setCacher($this->_cacher);
|
||||
if ($this->_logger) $this->DbSimple->setLogger($this->_logger);
|
||||
$this->DbSimple->setErrorHandler($this->errorHandler!==null ? $this->errorHandler : array(&$this, 'errorHandler'));
|
||||
//выставление переменных
|
||||
foreach($this->init as $query)
|
||||
call_user_func_array(array(&$this->DbSimple, 'query'), $query);
|
||||
$this->init = array();
|
||||
}
|
||||
|
||||
/**
|
||||
* Функция обработки ошибок - стандартный обработчик
|
||||
* Все вызовы без @ прекращают выполнение скрипта
|
||||
*
|
||||
* @param string $msg Сообщение об ошибке
|
||||
* @param array $info Подробная информация о контексте ошибки
|
||||
*/
|
||||
public function errorHandler($msg, $info)
|
||||
{
|
||||
// Если использовалась @, ничего не делать.
|
||||
if (!error_reporting()) return;
|
||||
// Выводим подробную информацию об ошибке.
|
||||
echo "SQL Error: $msg<br><pre>";
|
||||
print_r($info);
|
||||
echo "</pre>";
|
||||
exit();
|
||||
}
|
||||
|
||||
/**
|
||||
* Выставляет запрос для инициализации
|
||||
*
|
||||
* @param string $query запрос
|
||||
*/
|
||||
public function addInit($query)
|
||||
{
|
||||
$args = func_get_args();
|
||||
if ($this->DbSimple !== null)
|
||||
return call_user_func_array(array(&$this->DbSimple, 'query'), $args);
|
||||
$this->init[] = $args;
|
||||
}
|
||||
|
||||
/**
|
||||
* Устанавливает новый обработчик ошибок
|
||||
* Обработчик получает 2 аргумента:
|
||||
* - сообщение об ошибке
|
||||
* - массив (код, сообщение, запрос, контекст)
|
||||
*
|
||||
* @param callback|null|false $handler обработчик ошибок
|
||||
* <br> null - по умолчанию
|
||||
* <br> false - отключен
|
||||
* @return callback|null|false предыдущий обработчик
|
||||
*/
|
||||
public function setErrorHandler($handler)
|
||||
{
|
||||
$prev = $this->errorHandler;
|
||||
$this->errorHandler = $handler;
|
||||
if ($this->DbSimple)
|
||||
$this->DbSimple->setErrorHandler($handler);
|
||||
return $prev;
|
||||
}
|
||||
|
||||
/** @var callback обработчик ошибок */
|
||||
private $errorHandler = null;
|
||||
private $_cachePrefix = '';
|
||||
private $_identPrefix = null;
|
||||
private $_logger = null;
|
||||
private $_cacher = null;
|
||||
|
||||
/**
|
||||
* callback setLogger(callback $logger)
|
||||
* Set query logger called before each query is executed.
|
||||
* Returns previous logger.
|
||||
*/
|
||||
public function setLogger($logger)
|
||||
{
|
||||
$prev = $this->_logger;
|
||||
$this->_logger = $logger;
|
||||
if ($this->DbSimple)
|
||||
$this->DbSimple->setLogger($logger);
|
||||
return $prev;
|
||||
}
|
||||
|
||||
/**
|
||||
* callback setCacher(callback $cacher)
|
||||
* Set cache mechanism called during each query if specified.
|
||||
* Returns previous handler.
|
||||
*/
|
||||
public function setCacher(Zend_Cache_Backend_Interface $cacher=null)
|
||||
{
|
||||
$prev = $this->_cacher;
|
||||
$this->_cacher = $cacher;
|
||||
if ($this->DbSimple)
|
||||
$this->DbSimple->setCacher($cacher);
|
||||
return $prev;
|
||||
}
|
||||
|
||||
/**
|
||||
* string setIdentPrefix($prx)
|
||||
* Set identifier prefix used for $_ placeholder.
|
||||
*/
|
||||
public function setIdentPrefix($prx)
|
||||
{
|
||||
$old = $this->_identPrefix;
|
||||
if ($prx !== null) $this->_identPrefix = $prx;
|
||||
if ($this->DbSimple)
|
||||
$this->DbSimple->setIdentPrefix($prx);
|
||||
return $old;
|
||||
}
|
||||
|
||||
/**
|
||||
* string setCachePrefix($prx)
|
||||
* Set cache prefix used in key caclulation.
|
||||
*/
|
||||
public function setCachePrefix($prx)
|
||||
{
|
||||
$old = $this->_cachePrefix;
|
||||
if ($prx !== null) $this->_cachePrefix = $prx;
|
||||
if ($this->DbSimple)
|
||||
$this->DbSimple->setCachePrefix($prx);
|
||||
return $old;
|
||||
}
|
||||
|
||||
/**
|
||||
* Разбирает строку DSN в массив параметров подключения к базе
|
||||
*
|
||||
* @param string $dsn строка DSN для разбора
|
||||
* @return array Параметры коннекта
|
||||
*/
|
||||
protected function parseDSN($dsn)
|
||||
{
|
||||
$parsed = parse_url($dsn);
|
||||
if (!$parsed)
|
||||
return null;
|
||||
$params = null;
|
||||
if (!empty($parsed['query']))
|
||||
{
|
||||
parse_str($parsed['query'], $params);
|
||||
$parsed += $params;
|
||||
}
|
||||
$parsed['dsn'] = $dsn;
|
||||
return $parsed;
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
1390
includes/libs/DbSimple/Database.php
Normal file
1390
includes/libs/DbSimple/Database.php
Normal file
File diff suppressed because it is too large
Load Diff
136
includes/libs/DbSimple/Generic.php
Normal file
136
includes/libs/DbSimple/Generic.php
Normal file
@@ -0,0 +1,136 @@
|
||||
<?php
|
||||
/**
|
||||
* DbSimple_Generic: universal database connected by DSN.
|
||||
* (C) Dk Lab, http://en.dklab.ru
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Lesser General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2.1 of the License, or (at your option) any later version.
|
||||
* See http://www.gnu.org/copyleft/lesser.html
|
||||
*
|
||||
* Use static DbSimple_Generic::connect($dsn) call if you don't know
|
||||
* database type and parameters, but have its DSN.
|
||||
*
|
||||
* Additional keys can be added by appending a URI query string to the
|
||||
* end of the DSN.
|
||||
*
|
||||
* The format of the supplied DSN is in its fullest form:
|
||||
* phptype(dbsyntax)://username:password@protocol+hostspec/database?option=8&another=true
|
||||
*
|
||||
* Most variations are allowed:
|
||||
* phptype://username:password@protocol+hostspec:110//usr/db_file.db?mode=0644
|
||||
* phptype://username:password@hostspec/database_name
|
||||
* phptype://username:password@hostspec
|
||||
* phptype://username@hostspec
|
||||
* phptype://hostspec/database
|
||||
* phptype://hostspec
|
||||
* phptype(dbsyntax)
|
||||
* phptype
|
||||
*
|
||||
* Parsing code is partially grabbed from PEAR DB class,
|
||||
* initial author: Tomas V.V.Cox <cox@idecnet.com>.
|
||||
*
|
||||
* Contains 3 classes:
|
||||
* - DbSimple_Generic: database factory class
|
||||
* - DbSimple_Generic_Database: common database methods
|
||||
* - DbSimple_Generic_Blob: common BLOB support
|
||||
* - DbSimple_Generic_LastError: error reporting and tracking
|
||||
*
|
||||
* Special result-set fields:
|
||||
* - ARRAY_KEY* ("*" means "anything")
|
||||
* - PARENT_KEY
|
||||
*
|
||||
* Transforms:
|
||||
* - GET_ATTRIBUTES
|
||||
* - CALC_TOTAL
|
||||
* - GET_TOTAL
|
||||
* - UNIQ_KEY
|
||||
*
|
||||
* Query attributes:
|
||||
* - BLOB_OBJ
|
||||
* - CACHE
|
||||
*
|
||||
* @author Dmitry Koterov, http://forum.dklab.ru/users/DmitryKoterov/
|
||||
* @author Konstantin Zhinko, http://forum.dklab.ru/users/KonstantinGinkoTit/
|
||||
*
|
||||
* @version 2.x $Id$
|
||||
*/
|
||||
|
||||
/**
|
||||
* Use this constant as placeholder value to skip optional SQL block [...].
|
||||
*/
|
||||
if (!defined('DBSIMPLE_SKIP'))
|
||||
define('DBSIMPLE_SKIP', log(0));
|
||||
|
||||
/**
|
||||
* Names of special columns in result-set which is used
|
||||
* as array key (or karent key in forest-based resultsets) in
|
||||
* resulting hash.
|
||||
*/
|
||||
if (!defined('DBSIMPLE_ARRAY_KEY'))
|
||||
define('DBSIMPLE_ARRAY_KEY', 'ARRAY_KEY'); // hash-based resultset support
|
||||
if (!defined('DBSIMPLE_PARENT_KEY'))
|
||||
define('DBSIMPLE_PARENT_KEY', 'PARENT_KEY'); // forrest-based resultset support
|
||||
|
||||
|
||||
/**
|
||||
* DbSimple factory.
|
||||
*/
|
||||
class DbSimple_Generic
|
||||
{
|
||||
/**
|
||||
* DbSimple_Generic connect(mixed $dsn)
|
||||
*
|
||||
* Universal static function to connect ANY database using DSN syntax.
|
||||
* Choose database driver according to DSN. Return new instance
|
||||
* of this driver.
|
||||
*/
|
||||
function connect($dsn)
|
||||
{
|
||||
// Load database driver and create its instance.
|
||||
$parsed = DbSimple_Generic::parseDSN($dsn);
|
||||
if (!$parsed) {
|
||||
$dummy = null;
|
||||
return $dummy;
|
||||
}
|
||||
$class = 'DbSimple_'.ucfirst($parsed['scheme']);
|
||||
if (!class_exists($class)) {
|
||||
$file = dirname(__FILE__).'/'.ucfirst($parsed['scheme']). ".php";
|
||||
if (is_file($file)) {
|
||||
require_once($file);
|
||||
} else {
|
||||
trigger_error("Error loading database driver: no file $file", E_USER_ERROR);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
$object = new $class($parsed);
|
||||
if (isset($parsed['ident_prefix'])) {
|
||||
$object->setIdentPrefix($parsed['ident_prefix']);
|
||||
}
|
||||
$object->setCachePrefix(md5(serialize($parsed['dsn'])));
|
||||
return $object;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* array parseDSN(mixed $dsn)
|
||||
* Parse a data source name.
|
||||
* See parse_url() for details.
|
||||
*/
|
||||
function parseDSN($dsn)
|
||||
{
|
||||
if (is_array($dsn)) return $dsn;
|
||||
$parsed = parse_url($dsn);
|
||||
if (!$parsed) return null;
|
||||
$params = null;
|
||||
if (!empty($parsed['query'])) {
|
||||
parse_str($parsed['query'], $params);
|
||||
$parsed += $params;
|
||||
}
|
||||
$parsed['dsn'] = $dsn;
|
||||
return $parsed;
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
288
includes/libs/DbSimple/Ibase.php
Normal file
288
includes/libs/DbSimple/Ibase.php
Normal file
@@ -0,0 +1,288 @@
|
||||
<?php
|
||||
/**
|
||||
* DbSimple_Ibase: Interbase/Firebird database.
|
||||
* (C) Dk Lab, http://en.dklab.ru
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Lesser General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2.1 of the License, or (at your option) any later version.
|
||||
* See http://www.gnu.org/copyleft/lesser.html
|
||||
*
|
||||
* Placeholders are emulated because of logging purposes.
|
||||
*
|
||||
* @author Dmitry Koterov, http://forum.dklab.ru/users/DmitryKoterov/
|
||||
* @author Konstantin Zhinko, http://forum.dklab.ru/users/KonstantinGinkoTit/
|
||||
*
|
||||
* @version 2.x $Id$
|
||||
*/
|
||||
require_once dirname(__FILE__) . '/Database.php';
|
||||
|
||||
/**
|
||||
* Best transaction parameters for script queries.
|
||||
* They never give us update conflicts (unlike others)!
|
||||
* Used by default.
|
||||
*/
|
||||
define('IBASE_BEST_TRANSACTION', IBASE_COMMITTED + IBASE_WAIT + IBASE_REC_VERSION);
|
||||
define('IBASE_BEST_FETCH', IBASE_UNIXTIME);
|
||||
|
||||
/**
|
||||
* Database class for Interbase/Firebird.
|
||||
*/
|
||||
|
||||
class DbSimple_Ibase extends DbSimple_Database
|
||||
{
|
||||
var $DbSimple_Ibase_BEST_TRANSACTION = IBASE_BEST_TRANSACTION;
|
||||
var $DbSimple_Ibase_USE_NATIVE_PHOLDERS = true;
|
||||
var $fetchFlags = IBASE_BEST_FETCH;
|
||||
var $link;
|
||||
var $trans;
|
||||
var $prepareCache = array();
|
||||
|
||||
/**
|
||||
* constructor(string $dsn)
|
||||
* Connect to Interbase/Firebird.
|
||||
*/
|
||||
function DbSimple_Ibase($dsn)
|
||||
{
|
||||
$p = DbSimple_Database::parseDSN($dsn);
|
||||
if (!is_callable('ibase_connect')) {
|
||||
return $this->_setLastError("-1", "Interbase/Firebird extension is not loaded", "ibase_connect");
|
||||
}
|
||||
$ok = $this->link = ibase_connect(
|
||||
$p['host'] . (empty($p['port'])? "" : ":".$p['port']) .':'.preg_replace('{^/}s', '', $p['path']),
|
||||
$p['user'],
|
||||
$p['pass'],
|
||||
isset($p['CHARSET']) ? $p['CHARSET'] : 'win1251',
|
||||
isset($p['BUFFERS']) ? $p['BUFFERS'] : 0,
|
||||
isset($p['DIALECT']) ? $p['DIALECT'] : 3,
|
||||
isset($p['ROLE']) ? $p['ROLE'] : ''
|
||||
);
|
||||
if (isset($p['TRANSACTION'])) $this->DbSimple_Ibase_BEST_TRANSACTION = eval($p['TRANSACTION'].";");
|
||||
$this->_resetLastError();
|
||||
if (!$ok) return $this->_setDbError('ibase_connect()');
|
||||
}
|
||||
|
||||
function _performEscape($s, $isIdent=false)
|
||||
{
|
||||
if (!$isIdent)
|
||||
return "'" . str_replace("'", "''", $s) . "'";
|
||||
else
|
||||
return '"' . str_replace('"', '_', $s) . '"';
|
||||
}
|
||||
|
||||
function _performTransaction($parameters=null)
|
||||
{
|
||||
if ($parameters === null) $parameters = $this->DbSimple_Ibase_BEST_TRANSACTION;
|
||||
$this->trans = @ibase_trans($parameters, $this->link);
|
||||
}
|
||||
|
||||
function _performNewBlob($blobid=null)
|
||||
{
|
||||
return new DbSimple_Ibase_Blob($this, $blobid);
|
||||
}
|
||||
|
||||
function _performGetBlobFieldNames($result)
|
||||
{
|
||||
$blobFields = array();
|
||||
for ($i=ibase_num_fields($result)-1; $i>=0; $i--) {
|
||||
$info = ibase_field_info($result, $i);
|
||||
if ($info['type'] === "BLOB") $blobFields[] = $info['name'];
|
||||
}
|
||||
return $blobFields;
|
||||
}
|
||||
|
||||
function _performGetPlaceholderIgnoreRe()
|
||||
{
|
||||
return '
|
||||
" (?> [^"\\\\]+|\\\\"|\\\\)* " |
|
||||
\' (?> [^\'\\\\]+|\\\\\'|\\\\)* \' |
|
||||
` (?> [^`]+ | ``)* ` | # backticks
|
||||
/\* .*? \*/ # comments
|
||||
';
|
||||
}
|
||||
|
||||
function _performCommit()
|
||||
{
|
||||
if (!is_resource($this->trans)) return false;
|
||||
$result = @ibase_commit($this->trans);
|
||||
if (true === $result) {
|
||||
$this->trans = null;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
||||
|
||||
function _performRollback()
|
||||
{
|
||||
if (!is_resource($this->trans)) return false;
|
||||
$result = @ibase_rollback($this->trans);
|
||||
if (true === $result) {
|
||||
$this->trans = null;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
||||
function _performTransformQuery(&$queryMain, $how)
|
||||
{
|
||||
// If we also need to calculate total number of found rows...
|
||||
switch ($how) {
|
||||
// Prepare total calculation (if possible)
|
||||
case 'CALC_TOTAL':
|
||||
// Not possible
|
||||
return true;
|
||||
|
||||
// Perform total calculation.
|
||||
case 'GET_TOTAL':
|
||||
// TODO: GROUP BY ... -> COUNT(DISTINCT ...)
|
||||
$re = '/^
|
||||
(?> -- [^\r\n]* | \s+)*
|
||||
(\s* SELECT \s+) #1
|
||||
((?:FIRST \s+ \S+ \s+ (?:SKIP \s+ \S+ \s+)? )?) #2
|
||||
(.*?) #3
|
||||
(\s+ FROM \s+ .*?) #4
|
||||
((?:\s+ ORDER \s+ BY \s+ .*)?) #5
|
||||
$/six';
|
||||
$m = null;
|
||||
if (preg_match($re, $queryMain[0], $m)) {
|
||||
$queryMain[0] = $m[1] . $this->_fieldList2Count($m[3]) . " AS C" . $m[4];
|
||||
$skipHead = substr_count($m[2], '?');
|
||||
if ($skipHead) array_splice($queryMain, 1, $skipHead);
|
||||
$skipTail = substr_count($m[5], '?');
|
||||
if ($skipTail) array_splice($queryMain, -$skipTail);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
function _performQuery($queryMain)
|
||||
{
|
||||
$this->_lastQuery = $queryMain;
|
||||
$this->_expandPlaceholders($queryMain, $this->DbSimple_Ibase_USE_NATIVE_PHOLDERS);
|
||||
|
||||
$hash = $queryMain[0];
|
||||
|
||||
if (!isset($this->prepareCache[$hash])) {
|
||||
$this->prepareCache[$hash] = @ibase_prepare((is_resource($this->trans) ? $this->trans : $this->link), $queryMain[0]);
|
||||
} else {
|
||||
// Prepare cache hit!
|
||||
}
|
||||
|
||||
$prepared = $this->prepareCache[$hash];
|
||||
if (!$prepared) return $this->_setDbError($queryMain[0]);
|
||||
$queryMain[0] = $prepared;
|
||||
$result = @call_user_func_array('ibase_execute', $queryMain);
|
||||
// ATTENTION!!!
|
||||
// WE MUST save prepared ID (stored in $prepared variable) somewhere
|
||||
// before returning $result because of ibase destructor. Now it is done
|
||||
// by $this->prepareCache. When variable $prepared goes out of scope, it
|
||||
// is destroyed, and memory for result also freed by PHP. Totally we
|
||||
// got "Invalud statement handle" error message.
|
||||
|
||||
if ($result === false) return $this->_setDbError($queryMain[0]);
|
||||
if (!is_resource($result)) {
|
||||
// Non-SELECT queries return number of affected rows, SELECT - resource.
|
||||
return @ibase_affected_rows((is_resource($this->trans) ? $this->trans : $this->link));
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
||||
function _performFetch($result)
|
||||
{
|
||||
// Select fetch mode.
|
||||
$flags = $this->fetchFlags;
|
||||
if (empty($this->attributes['BLOB_OBJ'])) $flags = $flags | IBASE_TEXT;
|
||||
else $flags = $flags & ~IBASE_TEXT;
|
||||
|
||||
$row = @ibase_fetch_assoc($result, $flags);
|
||||
if (ibase_errmsg()) return $this->_setDbError($this->_lastQuery);
|
||||
return $row;
|
||||
}
|
||||
|
||||
|
||||
function _setDbError($query)
|
||||
{
|
||||
return $this->_setLastError(ibase_errcode(), ibase_errmsg(), $query);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
class DbSimple_Ibase_Blob implements DbSimple_Blob
|
||||
{
|
||||
var $blob; // resourse link
|
||||
var $id;
|
||||
var $database;
|
||||
|
||||
function DbSimple_Ibase_Blob(&$database, $id=null)
|
||||
{
|
||||
$this->database =& $database;
|
||||
$this->id = $id;
|
||||
$this->blob = null;
|
||||
}
|
||||
|
||||
function read($len)
|
||||
{
|
||||
if ($this->id === false) return ''; // wr-only blob
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
$data = @ibase_blob_get($this->blob, $len);
|
||||
if ($data === false) return $this->_setDbError('read');
|
||||
return $data;
|
||||
}
|
||||
|
||||
function write($data)
|
||||
{
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
$ok = @ibase_blob_add($this->blob, $data);
|
||||
if ($ok === false) return $this->_setDbError('add data to');
|
||||
return true;
|
||||
}
|
||||
|
||||
function close()
|
||||
{
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
if ($this->blob) {
|
||||
$id = @ibase_blob_close($this->blob);
|
||||
if ($id === false) return $this->_setDbError('close');
|
||||
$this->blob = null;
|
||||
} else {
|
||||
$id = null;
|
||||
}
|
||||
return $this->id ? $this->id : $id;
|
||||
}
|
||||
|
||||
function length()
|
||||
{
|
||||
if ($this->id === false) return 0; // wr-only blob
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
$info = @ibase_blob_info($this->id);
|
||||
if (!$info) return $this->_setDbError('get length of');
|
||||
return $info[0];
|
||||
}
|
||||
|
||||
function _setDbError($query)
|
||||
{
|
||||
$hId = $this->id === null ? "null" : ($this->id === false ? "false" : $this->id);
|
||||
$query = "-- $query BLOB $hId";
|
||||
$this->database->_setDbError($query);
|
||||
}
|
||||
|
||||
// Called on each blob use (reading or writing).
|
||||
function _firstUse()
|
||||
{
|
||||
// BLOB is opened - nothing to do.
|
||||
if (is_resource($this->blob)) return true;
|
||||
// Open or create blob.
|
||||
if ($this->id !== null) {
|
||||
$this->blob = @ibase_blob_open($this->id);
|
||||
if ($this->blob === false) return $this->_setDbError('open');
|
||||
} else {
|
||||
$this->blob = @ibase_blob_create($this->database->link);
|
||||
if ($this->blob === false) return $this->_setDbError('create');
|
||||
}
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
208
includes/libs/DbSimple/Mysql.php
Normal file
208
includes/libs/DbSimple/Mysql.php
Normal file
@@ -0,0 +1,208 @@
|
||||
<?php
|
||||
/**
|
||||
* DbSimple_Mysql: MySQL database.
|
||||
* (C) Dk Lab, http://en.dklab.ru
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Lesser General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2.1 of the License, or (at your option) any later version.
|
||||
* See http://www.gnu.org/copyleft/lesser.html
|
||||
*
|
||||
* Placeholders end blobs are emulated.
|
||||
*
|
||||
* @author Dmitry Koterov, http://forum.dklab.ru/users/DmitryKoterov/
|
||||
* @author Konstantin Zhinko, http://forum.dklab.ru/users/KonstantinGinkoTit/
|
||||
*
|
||||
* @version 2.x $Id: Mysql.php 247 2008-08-18 21:17:08Z dk $
|
||||
*/
|
||||
require_once dirname(__FILE__).'/Database.php';
|
||||
|
||||
|
||||
/**
|
||||
* Database class for MySQL.
|
||||
*/
|
||||
class DbSimple_Mysql extends DbSimple_Database
|
||||
{
|
||||
var $link;
|
||||
|
||||
/**
|
||||
* constructor(string $dsn)
|
||||
* Connect to MySQL.
|
||||
*/
|
||||
function DbSimple_Mysql($dsn)
|
||||
{
|
||||
$connect = 'mysql_'.((isset($dsn['persist']) && $dsn['persist'])?'p':'').'connect';
|
||||
if (!is_callable($connect))
|
||||
return $this->_setLastError("-1", "MySQL extension is not loaded", $connect);
|
||||
$ok = $this->link = @call_user_func($connect,
|
||||
$dsn['host'] . (empty($dsn['port'])? "" : ":".$dsn['port']),
|
||||
empty($dsn['user'])?'':$dsn['user'],
|
||||
empty($dsn['pass'])?'':$dsn['pass'],
|
||||
true
|
||||
);
|
||||
$this->_resetLastError();
|
||||
if (!$ok)
|
||||
if (!$ok) return $this->_setDbError('mysql_connect("' . $str . '", "' . $p['user'] . '")');
|
||||
$ok = @mysql_select_db(preg_replace('{^/}s', '', $dsn['path']), $this->link);
|
||||
if (!$ok)
|
||||
return $this->_setDbError('mysql_select_db()');
|
||||
mysql_query('SET NAMES '.(isset($dsn['enc'])?$dsn['enc']:'UTF8'));
|
||||
}
|
||||
|
||||
|
||||
protected function _performEscape($s, $isIdent=false)
|
||||
{
|
||||
if (!$isIdent)
|
||||
return "'" . mysql_real_escape_string($s, $this->link) . "'";
|
||||
else
|
||||
return "`" . str_replace('`', '``', $s) . "`";
|
||||
}
|
||||
|
||||
|
||||
protected function _performNewBlob($blobid=null)
|
||||
{
|
||||
return new DbSimple_Mysql_Blob($this, $blobid);
|
||||
}
|
||||
|
||||
|
||||
protected function _performGetBlobFieldNames($result)
|
||||
{
|
||||
$blobFields = array();
|
||||
for ($i=mysql_num_fields($result)-1; $i>=0; $i--)
|
||||
{
|
||||
$type = mysql_field_type($result, $i);
|
||||
if (stripos($type, "BLOB") !== false)
|
||||
$blobFields[] = mysql_field_name($result, $i);
|
||||
}
|
||||
return $blobFields;
|
||||
}
|
||||
|
||||
|
||||
protected function _performGetPlaceholderIgnoreRe()
|
||||
{
|
||||
return '
|
||||
" (?> [^"\\\\]+|\\\\"|\\\\)* " |
|
||||
\' (?> [^\'\\\\]+|\\\\\'|\\\\)* \' |
|
||||
` (?> [^`]+ | ``)* ` | # backticks
|
||||
/\* .*? \*/ # comments
|
||||
';
|
||||
}
|
||||
|
||||
|
||||
protected function _performTransaction($parameters=null)
|
||||
{
|
||||
return $this->query('BEGIN');
|
||||
}
|
||||
|
||||
|
||||
protected function _performCommit()
|
||||
{
|
||||
return $this->query('COMMIT');
|
||||
}
|
||||
|
||||
|
||||
protected function _performRollback()
|
||||
{
|
||||
return $this->query('ROLLBACK');
|
||||
}
|
||||
|
||||
|
||||
protected function _performTransformQuery(&$queryMain, $how)
|
||||
{
|
||||
// If we also need to calculate total number of found rows...
|
||||
switch ($how)
|
||||
{
|
||||
// Prepare total calculation (if possible)
|
||||
case 'CALC_TOTAL':
|
||||
$m = null;
|
||||
if (preg_match('/^(\s* SELECT)(.*)/six', $queryMain[0], $m))
|
||||
$queryMain[0] = $m[1] . ' SQL_CALC_FOUND_ROWS' . $m[2];
|
||||
return true;
|
||||
|
||||
// Perform total calculation.
|
||||
case 'GET_TOTAL':
|
||||
// Built-in calculation available?
|
||||
$queryMain = array('SELECT FOUND_ROWS()');
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
protected function _performQuery($queryMain)
|
||||
{
|
||||
$this->_lastQuery = $queryMain;
|
||||
$this->_expandPlaceholders($queryMain, false);
|
||||
$result = mysql_query($queryMain[0], $this->link);
|
||||
if ($result === false)
|
||||
return $this->_setDbError($queryMain[0]);
|
||||
if (!is_resource($result)) {
|
||||
if (preg_match('/^\s* INSERT \s+/six', $queryMain[0]))
|
||||
{
|
||||
// INSERT queries return generated ID.
|
||||
return mysql_insert_id($this->link);
|
||||
}
|
||||
// Non-SELECT queries return number of affected rows, SELECT - resource.
|
||||
return mysql_affected_rows($this->link);
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
||||
|
||||
protected function _performFetch($result)
|
||||
{
|
||||
$row = mysql_fetch_assoc($result);
|
||||
if (mysql_error()) return $this->_setDbError($this->_lastQuery);
|
||||
if ($row === false) return null;
|
||||
return $row;
|
||||
}
|
||||
|
||||
|
||||
protected function _setDbError($query)
|
||||
{
|
||||
if ($this->link) {
|
||||
return $this->_setLastError(mysql_errno($this->link), mysql_error($this->link), $query);
|
||||
} else {
|
||||
return $this->_setLastError(mysql_errno(), mysql_error(), $query);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
class DbSimple_Mysql_Blob implements DbSimple_Blob
|
||||
{
|
||||
// MySQL does not support separate BLOB fetching.
|
||||
private $blobdata = null;
|
||||
private $curSeek = 0;
|
||||
|
||||
public function __construct(&$database, $blobdata=null)
|
||||
{
|
||||
$this->blobdata = $blobdata;
|
||||
$this->curSeek = 0;
|
||||
}
|
||||
|
||||
public function read($len)
|
||||
{
|
||||
$p = $this->curSeek;
|
||||
$this->curSeek = min($this->curSeek + $len, strlen($this->blobdata));
|
||||
return substr($this->blobdata, $p, $len);
|
||||
}
|
||||
|
||||
public function write($data)
|
||||
{
|
||||
$this->blobdata .= $data;
|
||||
}
|
||||
|
||||
public function close()
|
||||
{
|
||||
return $this->blobdata;
|
||||
}
|
||||
|
||||
public function length()
|
||||
{
|
||||
return strlen($this->blobdata);
|
||||
}
|
||||
}
|
||||
?>
|
||||
183
includes/libs/DbSimple/Mysqli.php
Normal file
183
includes/libs/DbSimple/Mysqli.php
Normal file
@@ -0,0 +1,183 @@
|
||||
<?php
|
||||
/**
|
||||
* DbSimple_Mysqli: MySQLi database.
|
||||
* (C) Dk Lab, http://en.dklab.ru
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Lesser General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2.1 of the License, or (at your option) any later version.
|
||||
* See http://www.gnu.org/copyleft/lesser.html
|
||||
*
|
||||
* Placeholders are emulated because of logging purposes.
|
||||
*
|
||||
* @author Andrey Stavitsky
|
||||
*
|
||||
* @version 2.x $Id$
|
||||
*/
|
||||
require_once dirname(__FILE__).'/Database.php';
|
||||
|
||||
/**
|
||||
* Database class for MySQL.
|
||||
*/
|
||||
class DbSimple_Mysqli extends DbSimple_Database
|
||||
{
|
||||
private $link;
|
||||
private $isMySQLnd;
|
||||
|
||||
public function DbSimple_Mysqli($dsn)
|
||||
{
|
||||
$base = preg_replace('{^/}s', '', $dsn['path']);
|
||||
if (!class_exists('mysqli'))
|
||||
return $this->_setLastError('-1', 'mysqli extension is not loaded', 'mysqli');
|
||||
|
||||
try
|
||||
{
|
||||
$this->link = mysqli_init();
|
||||
|
||||
$this->link->options(MYSQLI_OPT_CONNECT_TIMEOUT,
|
||||
isset($dsn['timeout']) && $dsn['timeout'] ? $dsn['timeout'] : 0);
|
||||
|
||||
$this->link->real_connect((isset($dsn['persist']) && $dsn['persist'])?'p:'.$dsn['host']:$dsn['host'],
|
||||
$dsn['user'], isset($dsn['pass'])?$dsn['pass']:'', $base,
|
||||
empty($dsn['port'])?NULL:$dsn['port'], NULL,
|
||||
(isset($dsn['compression']) && $dsn['compression'])
|
||||
? MYSQLI_CLIENT_COMPRESS : NULL);
|
||||
|
||||
$this->link->set_charset((isset($dsn['enc']) ? $dsn['enc'] : 'UTF8'));
|
||||
|
||||
$this->isMySQLnd = method_exists('mysqli_result', 'fetch_all');
|
||||
}
|
||||
catch (mysqli_sql_exception $e)
|
||||
{
|
||||
$this->_setLastError($e->getCode() , $e->getMessage(), 'new mysqli');
|
||||
}
|
||||
}
|
||||
|
||||
protected function _performGetPlaceholderIgnoreRe()
|
||||
{
|
||||
return '
|
||||
" (?> [^"\\\\]+|\\\\"|\\\\)* " |
|
||||
\' (?> [^\'\\\\]+|\\\\\'|\\\\)* \' |
|
||||
` (?> [^`]+ | ``)* ` | # backticks
|
||||
/\* .*? \*/ # comments
|
||||
';
|
||||
}
|
||||
|
||||
protected function _performEscape($s, $isIdent=false)
|
||||
{
|
||||
if (!$isIdent)
|
||||
{
|
||||
return "'" .$this->link->escape_string($s). "'";
|
||||
}
|
||||
else
|
||||
{
|
||||
return "`" . str_replace('`', '``', $s) . "`";
|
||||
}
|
||||
}
|
||||
|
||||
protected function _performTransaction($parameters=null)
|
||||
{
|
||||
return $this->link->query('BEGIN');
|
||||
}
|
||||
|
||||
protected function _performCommit()
|
||||
{
|
||||
return $this->link->query('COMMIT');
|
||||
}
|
||||
|
||||
protected function _performRollback()
|
||||
{
|
||||
return $this->link->query('ROLLBACK');
|
||||
}
|
||||
|
||||
protected function _performQuery($queryMain)
|
||||
{
|
||||
$this->_lastQuery = $queryMain;
|
||||
|
||||
$this->_expandPlaceholders($queryMain, false);
|
||||
|
||||
$result = $this->link->query($queryMain[0]);
|
||||
|
||||
if (!$result)
|
||||
return $this->_setDbError($this->link, $queryMain[0]);
|
||||
|
||||
if ($this->link->errno!=0)
|
||||
return $this->_setDbError($this->link, $queryMain[0]);
|
||||
|
||||
if (preg_match('/^\s* INSERT \s+/six', $queryMain[0]))
|
||||
return $this->link->insert_id;
|
||||
|
||||
if ($this->link->field_count == 0)
|
||||
return $this->link->affected_rows;
|
||||
|
||||
if ($this->isMySQLnd)
|
||||
{
|
||||
$res = $result->fetch_all(MYSQLI_ASSOC);
|
||||
$result->close();
|
||||
}
|
||||
else
|
||||
{
|
||||
$res = $result;
|
||||
}
|
||||
|
||||
return $res;
|
||||
}
|
||||
|
||||
protected function _performTransformQuery(&$queryMain, $how)
|
||||
{
|
||||
// If we also need to calculate total number of found rows...
|
||||
switch ($how)
|
||||
{
|
||||
// Prepare total calculation (if possible)
|
||||
case 'CALC_TOTAL':
|
||||
$m = null;
|
||||
if (preg_match('/^(\s* SELECT)(.*)/six', $queryMain[0], $m))
|
||||
$queryMain[0] = $m[1] . ' SQL_CALC_FOUND_ROWS' . $m[2];
|
||||
return true;
|
||||
|
||||
// Perform total calculation.
|
||||
case 'GET_TOTAL':
|
||||
// Built-in calculation available?
|
||||
$queryMain = array('SELECT FOUND_ROWS()');
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
protected function _setDbError($obj,$q)
|
||||
{
|
||||
$info=$obj?$obj:$this->link;
|
||||
return $this->_setLastError($info->errno, $info->error, $q);
|
||||
}
|
||||
|
||||
protected function _performNewBlob($id=null)
|
||||
{
|
||||
}
|
||||
|
||||
protected function _performGetBlobFieldNames($result)
|
||||
{
|
||||
return array();
|
||||
}
|
||||
|
||||
protected function _performFetch($result)
|
||||
{
|
||||
if ($this->isMySQLnd)
|
||||
return $result;
|
||||
|
||||
$row = $result->fetch_assoc();
|
||||
|
||||
if ($this->link->error)
|
||||
return $this->_setDbError($this->_lastQuery);
|
||||
|
||||
if ($row === false)
|
||||
{
|
||||
$result->close();
|
||||
return null;
|
||||
}
|
||||
|
||||
return $row;
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
312
includes/libs/DbSimple/Postgresql.php
Normal file
312
includes/libs/DbSimple/Postgresql.php
Normal file
@@ -0,0 +1,312 @@
|
||||
<?php
|
||||
/**
|
||||
* DbSimple_Postgreql: PostgreSQL database.
|
||||
* (C) Dk Lab, http://en.dklab.ru
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Lesser General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2.1 of the License, or (at your option) any later version.
|
||||
* See http://www.gnu.org/copyleft/lesser.html
|
||||
*
|
||||
* Placeholders are emulated because of logging purposes.
|
||||
*
|
||||
* @author Dmitry Koterov, http://forum.dklab.ru/users/DmitryKoterov/
|
||||
* @author Konstantin Zhinko, http://forum.dklab.ru/users/KonstantinGinkoTit/
|
||||
*
|
||||
* @version 2.x $Id: Postgresql.php 167 2007-01-22 10:12:09Z tit $
|
||||
*/
|
||||
require_once dirname(__FILE__) . '/Generic.php';
|
||||
|
||||
|
||||
/**
|
||||
* Database class for PostgreSQL.
|
||||
*/
|
||||
class DbSimple_Postgresql extends DbSimple_Generic_Database
|
||||
{
|
||||
|
||||
var $DbSimple_Postgresql_USE_NATIVE_PHOLDERS = null;
|
||||
var $prepareCache = array();
|
||||
var $link;
|
||||
|
||||
/**
|
||||
* constructor(string $dsn)
|
||||
* Connect to PostgresSQL.
|
||||
*/
|
||||
function DbSimple_Postgresql($dsn)
|
||||
{
|
||||
$p = DbSimple_Generic::parseDSN($dsn);
|
||||
if (!is_callable('pg_connect')) {
|
||||
return $this->_setLastError("-1", "PostgreSQL extension is not loaded", "pg_connect");
|
||||
}
|
||||
|
||||
// Prepare+execute works only in PHP 5.1+.
|
||||
$this->DbSimple_Postgresql_USE_NATIVE_PHOLDERS = function_exists('pg_prepare');
|
||||
|
||||
$ok = $this->link = @pg_connect(
|
||||
$t = (!empty($p['host']) ? 'host='.$p['host'].' ' : '').
|
||||
(!empty($p['port']) ? 'port='.$p['port'].' ' : '').
|
||||
'dbname='.preg_replace('{^/}s', '', $p['path']).' '.
|
||||
(!empty($p['user']) ? 'user='.$p['user'].' ' : '').
|
||||
(!empty($p['pass']) ? 'password='.$p['pass'].' ' : '')
|
||||
);
|
||||
$this->_resetLastError();
|
||||
if (!$ok) return $this->_setDbError('pg_connect()');
|
||||
}
|
||||
|
||||
|
||||
function _performEscape($s, $isIdent=false)
|
||||
{
|
||||
if (!$isIdent)
|
||||
return "'" . str_replace("'", "''", $s) . "'";
|
||||
else
|
||||
return '"' . str_replace('"', '_', $s) . '"';
|
||||
}
|
||||
|
||||
|
||||
function _performTransaction($parameters=null)
|
||||
{
|
||||
return $this->query('BEGIN');
|
||||
}
|
||||
|
||||
|
||||
function& _performNewBlob($blobid=null)
|
||||
{
|
||||
$obj =& new DbSimple_Postgresql_Blob($this, $blobid);
|
||||
return $obj;
|
||||
}
|
||||
|
||||
|
||||
function _performGetBlobFieldNames($result)
|
||||
{
|
||||
$blobFields = array();
|
||||
for ($i=pg_num_fields($result)-1; $i>=0; $i--) {
|
||||
$type = pg_field_type($result, $i);
|
||||
if (strpos($type, "BLOB") !== false) $blobFields[] = pg_field_name($result, $i);
|
||||
}
|
||||
return $blobFields;
|
||||
}
|
||||
|
||||
// TODO: Real PostgreSQL escape
|
||||
function _performGetPlaceholderIgnoreRe()
|
||||
{
|
||||
return '
|
||||
" (?> [^"\\\\]+|\\\\"|\\\\)* " |
|
||||
\' (?> [^\'\\\\]+|\\\\\'|\\\\)* \' |
|
||||
/\* .*? \*/ # comments
|
||||
';
|
||||
}
|
||||
|
||||
function _performGetNativePlaceholderMarker($n)
|
||||
{
|
||||
// PostgreSQL uses specific placeholders such as $1, $2, etc.
|
||||
return '$' . ($n + 1);
|
||||
}
|
||||
|
||||
function _performCommit()
|
||||
{
|
||||
return $this->query('COMMIT');
|
||||
}
|
||||
|
||||
|
||||
function _performRollback()
|
||||
{
|
||||
return $this->query('ROLLBACK');
|
||||
}
|
||||
|
||||
|
||||
function _performTransformQuery(&$queryMain, $how)
|
||||
{
|
||||
|
||||
// If we also need to calculate total number of found rows...
|
||||
switch ($how) {
|
||||
// Prepare total calculation (if possible)
|
||||
case 'CALC_TOTAL':
|
||||
// Not possible
|
||||
return true;
|
||||
|
||||
// Perform total calculation.
|
||||
case 'GET_TOTAL':
|
||||
// TODO: GROUP BY ... -> COUNT(DISTINCT ...)
|
||||
$re = '/^
|
||||
(?> -- [^\r\n]* | \s+)*
|
||||
(\s* SELECT \s+) #1
|
||||
(.*?) #2
|
||||
(\s+ FROM \s+ .*?) #3
|
||||
((?:\s+ ORDER \s+ BY \s+ .*?)?) #4
|
||||
((?:\s+ LIMIT \s+ \S+ \s* (?: OFFSET \s* \S+ \s*)? )?) #5
|
||||
$/six';
|
||||
$m = null;
|
||||
if (preg_match($re, $queryMain[0], $m)) {
|
||||
$queryMain[0] = $m[1] . $this->_fieldList2Count($m[2]) . " AS C" . $m[3];
|
||||
$skipTail = substr_count($m[4] . $m[5], '?');
|
||||
if ($skipTail) array_splice($queryMain, -$skipTail);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
function _performQuery($queryMain)
|
||||
{
|
||||
$this->_lastQuery = $queryMain;
|
||||
$isInsert = preg_match('/^\s* INSERT \s+/six', $queryMain[0]);
|
||||
|
||||
//
|
||||
// Note that in case of INSERT query we CANNOT work with prepare...execute
|
||||
// cache, because RULEs do not work after pg_execute(). This is a very strange
|
||||
// bug... To reproduce:
|
||||
// $DB->query("CREATE TABLE test(id SERIAL, str VARCHAR(10)) WITH OIDS");
|
||||
// $DB->query("CREATE RULE test_r AS ON INSERT TO test DO (SELECT 111 AS id)");
|
||||
// print_r($DB->query("INSERT INTO test(str) VALUES ('test')"));
|
||||
// In case INSERT + pg_execute() it returns new row OID (numeric) instead
|
||||
// of result of RULE query. Strange, very strange...
|
||||
//
|
||||
|
||||
if ($this->DbSimple_Postgresql_USE_NATIVE_PHOLDERS && !$isInsert) {
|
||||
// Use native placeholders only if PG supports them.
|
||||
$this->_expandPlaceholders($queryMain, true);
|
||||
$hash = md5($queryMain[0]);
|
||||
if (!isset($this->prepareCache[$hash])) {
|
||||
$this->prepareCache[$hash] = true;
|
||||
$prepared = @pg_prepare($this->link, $hash, $queryMain[0]);
|
||||
if ($prepared === false) return $this->_setDbError($queryMain[0]);
|
||||
} else {
|
||||
// Prepare cache hit!
|
||||
}
|
||||
$result = pg_execute($this->link, $hash, array_slice($queryMain, 1));
|
||||
} else {
|
||||
// No support for native placeholders or INSERT query.
|
||||
$this->_expandPlaceholders($queryMain, false);
|
||||
$result = @pg_query($this->link, $queryMain[0]);
|
||||
}
|
||||
|
||||
if ($result === false) return $this->_setDbError($queryMain);
|
||||
if (!pg_num_fields($result)) {
|
||||
if ($isInsert) {
|
||||
// INSERT queries return generated OID (if table is WITH OIDs).
|
||||
//
|
||||
// Please note that unfortunately we cannot use lastval() PostgreSQL
|
||||
// stored function because it generates fatal error if INSERT query
|
||||
// does not contain sequence-based field at all. This error terminates
|
||||
// the current transaction, and we cannot continue to work nor know
|
||||
// if table contains sequence-updateable field or not.
|
||||
//
|
||||
// To use auto-increment functionality you must invoke
|
||||
// $insertedId = $DB->query("SELECT lastval()")
|
||||
// manually where it is really needed.
|
||||
//
|
||||
return @pg_last_oid($result);
|
||||
}
|
||||
// Non-SELECT queries return number of affected rows, SELECT - resource.
|
||||
return @pg_affected_rows($result);
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
||||
|
||||
function _performFetch($result)
|
||||
{
|
||||
$row = @pg_fetch_assoc($result);
|
||||
if (pg_last_error($this->link)) return $this->_setDbError($this->_lastQuery);
|
||||
if ($row === false) return null;
|
||||
return $row;
|
||||
}
|
||||
|
||||
|
||||
function _setDbError($query)
|
||||
{
|
||||
return $this->_setLastError(null, pg_last_error($this->link), $query);
|
||||
}
|
||||
|
||||
function _getVersion()
|
||||
{
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
class DbSimple_Postgresql_Blob extends DbSimple_Generic_Blob
|
||||
{
|
||||
var $blob; // resourse link
|
||||
var $id;
|
||||
var $database;
|
||||
|
||||
function DbSimple_Postgresql_Blob(&$database, $id=null)
|
||||
{
|
||||
$this->database =& $database;
|
||||
$this->database->transaction();
|
||||
$this->id = $id;
|
||||
$this->blob = null;
|
||||
}
|
||||
|
||||
function read($len)
|
||||
{
|
||||
if ($this->id === false) return ''; // wr-only blob
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
$data = @pg_lo_read($this->blob, $len);
|
||||
if ($data === false) return $this->_setDbError('read');
|
||||
return $data;
|
||||
}
|
||||
|
||||
function write($data)
|
||||
{
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
$ok = @pg_lo_write($this->blob, $data);
|
||||
if ($ok === false) return $this->_setDbError('add data to');
|
||||
return true;
|
||||
}
|
||||
|
||||
function close()
|
||||
{
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
if ($this->blob) {
|
||||
$id = @pg_lo_close($this->blob);
|
||||
if ($id === false) return $this->_setDbError('close');
|
||||
$this->blob = null;
|
||||
} else {
|
||||
$id = null;
|
||||
}
|
||||
$this->database->commit();
|
||||
return $this->id? $this->id : $id;
|
||||
}
|
||||
|
||||
function length()
|
||||
{
|
||||
if (!($e=$this->_firstUse())) return $e;
|
||||
|
||||
@pg_lo_seek($this->blob, 0, PGSQL_SEEK_END);
|
||||
$len = @pg_lo_tell($this->blob);
|
||||
@pg_lo_seek($this->blob, 0, PGSQL_SEEK_SET);
|
||||
|
||||
if (!$len) return $this->_setDbError('get length of');
|
||||
return $len;
|
||||
}
|
||||
|
||||
function _setDbError($query)
|
||||
{
|
||||
$hId = $this->id === null? "null" : ($this->id === false? "false" : $this->id);
|
||||
$query = "-- $query BLOB $hId";
|
||||
$this->database->_setDbError($query);
|
||||
}
|
||||
|
||||
// Called on each blob use (reading or writing).
|
||||
function _firstUse()
|
||||
{
|
||||
// BLOB opened - do nothing.
|
||||
if (is_resource($this->blob)) return true;
|
||||
|
||||
// Open or create blob.
|
||||
if ($this->id !== null) {
|
||||
$this->blob = @pg_lo_open($this->database->link, $this->id, 'rw');
|
||||
if ($this->blob === false) return $this->_setDbError('open');
|
||||
} else {
|
||||
$this->id = @pg_lo_create($this->database->link);
|
||||
$this->blob = @pg_lo_open($this->database->link, $this->id, 'w');
|
||||
if ($this->blob === false) return $this->_setDbError('create');
|
||||
}
|
||||
return true;
|
||||
}
|
||||
}
|
||||
?>
|
||||
Reference in New Issue
Block a user