Файл: upload/include/library/phpfox/database/driver/sqlite.class.php
Строк: 333
<?php
/**
* [PHPFOX_HEADER]
*/
defined('PHPFOX') or exit('NO DICE!');
/**
* SQLite Database Driver
* NOTE: This driver is not in use and is still being tested thus no documentation was done for it just yet.
*
* @copyright [PHPFOX_COPYRIGHT]
* @author Raymond Benc
* @package Phpfox
* @version $Id: sqlite.class.php 1666 2010-07-07 08:17:00Z Raymond_Benc $
*/
class Database_Driver_Sqlite
{
public $sSlaveServer;
private $_hMaster = null;
private $_hSlave = null;
private $_sIsSlave = '';
public function connect($sHost, $sUser, $sPass, $sName, $sPort = false, $sPersistent = false)
{
if ($sPort)
{
$sHost = $sHost . ':' . $sPort;
}
$this->_hMaster = ($sPersistent ? @sqlite_popen($sHost, 0666, $sError) : @sqlite_open($sHost, 0666, $sError));
// Unable to connect to master
if (!$this->_hMaster)
{
// Cannot connect to the database
return Phpfox_Error::set('Cannot connect to the database: ' . $sError);
}
$this->_hSlave =& $this->_hMaster;
return true;
}
public function getVersion()
{
return @sqlite_libversion();
}
public function getServerInfo()
{
return 'SQLite ' . $this->getVersion();
}
/**
* Performs sql query with error reporting and logging.
*
* @todo Debug debug backtrace
* @access public
* @param string $sSql query string
* @return int query result handle
*/
public function query($sSql, &$hLink = '')
{
if (!$hLink)
{
$hLink =& $this->_hMaster;
}
(PHPFOX_DEBUG ? Phpfox_Debug::start('sql') : '');
$hRes = sqlite_query($sSql, $hLink);
if (!$hRes)
{
Phpfox_Error::trigger('Query Error:' . $this->_sqlError(), (PHPFOX_DEBUG ? E_USER_ERROR : E_USER_WARNING));
}
(PHPFOX_DEBUG ? Phpfox_Debug::end('sql', array('sql' => $sSql, 'slave' => $this->_sIsSlave, 'rows' => (is_bool($hRes) ? '-' : sqlite_num_rows($hRes)))) : '');
$this->_sIsSlave = '';
return $hRes;
}
/**
* Returns one field from a row
*
* @param string $sSql SQL query
* @return mixed field value
*/
public function getSlaveField($sSql)
{
$this->_sIsSlave = true;
return $this->_getField($sSql, $this->_hSlave);
}
public function getSlaveRow($sSql, $bAssoc = true)
{
$this->_sIsSlave = true;
return $this->_getRow($sSql, $bAssoc, $this->_hSlave);
}
public function getSlaveRows($sSql, $bAssoc = true)
{
$this->_sIsSlave = true;
return $this->_getRows($sSql, $bAssoc, $this->_hSlave);
}
public function getRow($sSql, $bAssoc = true)
{
return $this->_getRow($sSql, $bAssoc, $this->_hMaster);
}
public function getRows($sSql, $bAssoc = true)
{
return $this->_getRows($sSql, $bAssoc, $this->_hMaster);
}
/**
* Returns one field from a row
*
* @param string $sSql SQL query
* @return mixed field value
*/
public function getField($sSql)
{
return $this->_getField($sSql, $this->_hMaster);
}
/**
* Prepares string to store in db (performs addslashes() )
*
* @access public
* @param mixed $mParam string or array of string need to be escaped
* @return mixed escaped string or array of escaped strings
*/
public function escape($mParam)
{
if (is_array($mParam))
{
return array_map(array(&$this, 'escape'), $mParam);
}
if (get_magic_quotes_gpc())
{
$mParam = stripslashes($mParam);
}
$mParam = sqlite_escape_string($mParam);
return $mParam;
}
public function multiInsert($sTable, $aFields, $aValues)
{
foreach ($aValues as $mValue)
{
$aInserts = array();
for ($i = 0; $i < count($mValue); $i++)
{
$aInserts[$aFields[$i]] = (is_null($mValue[$i]) ? null : $mValue[$i]);
}
$this->insert($sTable, $aInserts);
}
}
/**
* Performs insert of one row. Accepts values to insert as an array:
* 'column1' => 'value1'
* 'column2' => 'value2'
*
* @access public
* @param string $sTable table name
* @param array $aValues column and values to insert
* @param boolean $bEscape true - method escapes values (with "), false - not escapes
* @return int last ID (or 0 on error)
*/
public function insert($sTable, $aValues, $bEscape = true, $bReturnQuery = false)
{
$sCols = '`'.implode('`, `', array_keys($aValues)).'`';
if ($bEscape)
{
$aValues = $this->escape($aValues);
$sVals = "'".implode("', '", array_values($aValues))."'";
}
else
{
$sVals = implode(',', array_values($aValues));
}
$sSql = 'INSERT INTO '. $sTable .' '.
' ('. str_replace('`', '', $sCols).')'.
' VALUES ('.$sVals.')';
if ($hRes = $this->query($sSql))
{
if ($bReturnQuery)
{
return $sSql;
}
return $this->getLastId();
}
return 0;
}
/**
* Performs update of rows.
*
* @access public
* @param string $sTable table name
* @param array $aValues array of column=>new_value
* @param string $sCond condition (without WHERE)
* @param boolean $bEscape true - method escapes values (with "), false - not escapes
* @return boolean true - update successfule, false - error
*/
public function update($sTable, $aValues, $sCond, $bEscape = true)
{
if (!is_array($aValues))
{
return false;
}
$sSets = '';
foreach ($aValues as $sCol=>$sValue)
{
if ($bEscape)
{
$sSets .= "" . $sCol . " = '" . $this->escape($sValue) . "', ";
}
else
{
$sSets .= ''.$sCol.' = '.$sValue.', ';
}
}
$sSets[strlen($sSets)-2]=' ';
$sSql = 'UPDATE '. $sTable .' SET '.$sSets.' WHERE '.$sCond;
return $this->query($sSql);
}
/**
* Delete entry from the database
*
* @access public
* @param string $sTable is the table name
* @param string $sQuery is the query we will run
*/
public function delete($sTable, $sQuery)
{
$this->query("DELETE FROM ". $sTable ." WHERE ". $sQuery);
}
/**
* Returns row id from last executed query
*
* @access public
* @return int id of last INSERT operation
*/
public function getLastId()
{
return sqlite_last_insert_rowid($this->_hMaster);
}
public function freeResult()
{
return true;
}
public function affectedRows()
{
return sqlite_changes($this->_hMaster);
}
public function search($sType, $mFields, $sSearch)
{
$sSql = '';
foreach ($mFields as $sField)
{
$sSql .= "OR ". $sField . " LIKE '%" . $this->escape($sSearch) . "%' ";
}
return 'AND (' . trim(ltrim(trim($sSql), 'OR')) . ')';
}
public function select($sSelect)
{
if (!isset($this->_aQuery['select']))
{
$this->_aQuery['select'] = 'SELECT ';
}
$this->_aQuery['select'] .= $sSelect;
return $this;
}
public function where($aConds)
{
$this->_aQuery['where'] = '';
if (is_array($aConds) && count($aConds))
{
foreach ($aConds as $sValue)
{
$this->_aQuery['where'] .= $sValue . ' ';
}
$this->_aQuery['where'] = "WHERE " . trim(preg_replace("/^(AND|OR)(.*?)/i", "", trim($this->_aQuery['where'])));
}
else
{
if (!empty($aConds))
{
$this->_aQuery['where'] .= 'WHERE ' . $aConds;
}
}
return $this;
}
public function from($sTable, $sAlias = '')
{
$this->_aQuery['table'] = 'FROM ' . $sTable . ($sAlias ? ' AS ' . $sAlias : '');
return $this;
}
public function order($sOrder)
{
if (!empty($sOrder))
{
$this->_aQuery['order'] = 'ORDER BY ' . $sOrder;
}
return $this;
}
public function group($sGroup)
{
$this->_aQuery['group'] = 'GROUP BY ' . $sGroup;
return $this;
}
public function having($sHaving)
{
$this->_aQuery['having'] = 'HAVING ' . $sHaving;
return $this;
}
public function leftJoin($sTable, $sAlias, $mParam = null)
{
$this->_join('LEFT JOIN', $sTable, $sAlias, $mParam);
return $this;
}
public function innerJoin($sTable, $sAlias, $mParam = null)
{
$this->_join('INNER JOIN', $sTable, $sAlias, $mParam);
return $this;
}
public function join($sTable, $sAlias, $mParam = null)
{
$this->_join('JOIN', $sTable, $sAlias, $mParam);
return $this;
}
public function limit($iPage, $sLimit = null, $iCnt = null)
{
if ($sLimit === null && $iCnt === null)
{
$this->_aQuery['limit'] = 'LIMIT ' . $iPage;
return $this;
}
$iOffset = Phpfox::getLib('pager')->getOffset($iPage, $sLimit, $iCnt);
$this->_aQuery['limit'] = ($sLimit ? 'LIMIT ' . $sLimit : '') . ($iOffset ? ' OFFSET ' . $iOffset : '');
return $this;
}
public function execute($sType, $aParams = array())
{
$sSql = $this->_aQuery['select'] . "n";
$sSql .= $this->_aQuery['table'] . "n";
$sSql .= (isset($this->_aQuery['join']) ? $this->_aQuery['join'] . "n" : '');
$sSql .= (isset($this->_aQuery['where']) ? $this->_aQuery['where'] . "n" : '');
$sSql .= (isset($this->_aQuery['group']) ? $this->_aQuery['group'] . "n" : '');
$sSql .= (isset($this->_aQuery['having']) ? $this->_aQuery['having'] . "n" : '');
$sSql .= (isset($this->_aQuery['order']) ? $this->_aQuery['order'] . "n" : '');
$sSql .= (isset($this->_aQuery['limit']) ? $this->_aQuery['limit'] . "n" : '');
$this->_aQuery = array();
$bDoCache = false;
if (isset($aParams['cache']) && $aParams)
{
$bDoCache = true;
$oCache = Phpfox::getLib('cache');
}
if ($bDoCache)
{
$sCacheId = $oCache->set($aParams['cache_name']);
if ((isset($aParams['cache_limit']) && ($aRows = $oCache->get($sCacheId, $aParams['cache_limit']))) || ($aRows = $oCache->get($sCacheId)))
{
return $aRows;
}
}
if (isset($aParams['count']))
{
}
switch($sType)
{
case 'getSlaveRows':
$aRows = $this->getSlaveRows($sSql);
break;
case 'getSlaveRow':
$aRows = $this->getSlaveRow($sSql);
break;
case 'getRow':
$aRows = $this->getRow($sSql);
break;
case 'getRows':
$aRows = $this->getRows($sSql);
break;
case 'getField':
$aRows = $this->getField($sSql);
break;
case 'getSlaveField':
$aRows = $this->getSlaveField($sSql);
break;
default:
Phpfox_Error::trigger('Invalid execute on SQL query.', E_USER_ERROR);
}
if ($bDoCache)
{
$oCache->save($sCacheId, $aRows);
}
if (isset($aParams['free_result']))
{
$this->freeResult();
}
return $aRows;
}
public function sqlReport($sQuery)
{
return false;
}
public function dropTables($aDrops, $aVals = array())
{
foreach ($aDrops as $sDrop)
{
$this->query("DROP TABLE {$sDrop}");
}
}
private function _join($sType, $sTable, $sAlias, $mParam = null)
{
if (!isset($this->_aQuery['join']))
{
$this->_aQuery['join'] = '';
}
$this->_aQuery['join'] .= $sType . " " . $sTable . " AS " . $sAlias;
if (is_array($mParam))
{
$this->_aQuery['join'] .= "ntON(";
foreach ($mParam as $sValue)
{
$this->_aQuery['join'] .= $sValue . " ";
}
}
else
{
if (preg_match("/(AND|OR|=)/", $mParam))
{
$this->_aQuery['join'] .= "ntON({$mParam}";
}
else
{
$this->_aQuery['join'] .= "ntUSING({$mParam}";
}
}
$this->_aQuery['join'] = preg_replace("/^(AND|OR)(.*?)/i", "", trim($this->_aQuery['join'])) . ")n";
}
private function _sqlError()
{
return @sqlite_error_string(@sqlite_last_error($this->_hMaster));
}
/**
* Returns exactly one row as array. If there is number of rows
* satisfying the condition then the first one will be returned.
*
* @access public
* @param string $sSql select query
* @param string $bAssoc type of returned rows array
* @return array exact one row (first if multiply row selected): or false on error
*/
private function _getRow($sSql, $bAssoc, &$hLink)
{
// Run the query
$hRes = $this->query($sSql, $hLink);
// Get the array
$aRes = sqlite_fetch_array($hRes, ($bAssoc ? SQLITE_ASSOC : SQLITE_NUM));
if (!$aRes)
{
return array();
}
foreach ($aRes as $mKey => $mValue)
{
if (strpos($mKey, '.'))
{
$aParts = explode('.', $mKey);
$mKey = $aParts[1];
}
$aRow[strtolower($mKey)] = $mValue;
}
return $aRow;
}
/**
* Gets data returned by sql query
*
* @access public
* @param string $sSql select query
* @param string $bAssoc type of returned rows array
* @return array selected rows (each row is array of specified type) or emprt array on error
*/
private function _getRows($sSql, $bAssoc = true, &$hLink)
{
$aRows = array();
$bAssoc = ($bAssoc ? SQLITE_ASSOC : SQLITE_NUM);
// Run the query
$this->rQuery = $this->query($sSql, $hLink);
// Put it into a while look
while($aRow = sqlite_fetch_array($this->rQuery, $bAssoc))
{
$aRow2 = array();
foreach ($aRow as $mKey => $mValue)
{
if (strpos($mKey, '.'))
{
$aParts = explode('.', $mKey);
$mKey = $aParts[1];
}
$aRow2[$mKey] = $mValue;
}
$aRows[] = $aRow2;
}
return $aRows; //empty array on error
}
/**
* Returns one field from a row
*
* @param string $sSql SQL query
* @return mixed field value
*/
private function _getField($sSql, &$hLink)
{
$sRes = '';
$aRow = $this->getRow($sSql, false, $hLink);
if ($aRow)
{
$sRes = $aRow[0];
}
return $sRes;
}
}
?>