rush:
PHP;">
_con
fig settings.
*
* @return string
*/
protected function _dsn()
{
// baseline of DSN parts
$dsn = $this->_con
fig;
// don't pass the username,password,charset,persistent and driver_options in the DSN
unset($dsn['username']);
unset($dsn['password']);
unset($dsn['options']);
unset($dsn['charset']);
unset($dsn['persistent']);
unset($dsn['driver_options']);
// use all remaining parts in the DSN
foreach ($dsn as $key => $val) {
$dsn[$key] = "$key=$val";
}
return $this->_pdoType . ':' . implode(';',$dsn);
}
/**
* Creates a PDO object and connects to the database.
*
* @return void
* @throws Zend_Db_Adapter_Exception
*/
protected function _connect()
{
// if we already have a PDO object,no need to re-connect.
if ($this->_connection) {
return;
}
// get the dsn f
irst,because some adapters alter the $_pdoType
$dsn = $this->_dsn();
// check for PDO extension
if (!extension_loaded('pdo')) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception('The PDO extension is
required for this adapter but the extension is not loaded');
}
// check the PDO driver is available
if (!in_array($this->_pdoType,PDO::getAvailableDrivers())) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception('The ' . $this->_pdoType . ' driver is not currently installed');
}
// create PDO connection
$q = $this->_profiler->queryStart('connect',Zend_Db_Profiler::CONNECT);
// add the persistence flag if we find it in our con
fig array
if (isset($this->_con
fig['persistent']) && ($this->_con
fig['persistent'] == true)) {
$this->_con
fig['driver_options'][PDO::ATTR_PERSISTENT] = true;
}
try {
$this->_connection = new PDO(
$dsn,$this->_con
fig['username'],$this->_con
fig['password'],$this->_con
fig['driver_options']
);
$this->_profiler->queryEnd($q);
// set the PDO connection to perform case-folding on array keys,or not
$this->_connection->setAttribute(PDO::ATTR_CASE,$this->_caseFolding);
// always use exceptions.
$this->_connection->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception($e->getMessage(),$e->getCode(),$e);
}
}
/**
* Test if a connection is active
*
* @return boolean
*/
public function isConnected()
{
return ((bool) ($this->_connection instanceof PDO));
}
/**
* Force the connection to close.
*
* @return void
*/
public function closeConnection()
{
$this->_connection = null;
}
/**
* Prepares an
sql statement.
*
* @p
aram string $
sql The
sql statement with placeholders.
* @p
aram array $bind An array of data to bind to the placeholders.
* @return PDOStatement
*/
public function prepare($
sql)
{
$this->_connect();
$stmtClass = $this->_defaultStmtClass;
if (!class_exists($stmtClass)) {
require_once 'Zend/Loader.
PHP';
Zend_Loader::loadClass($stmtClass);
}
$stmt = new $stmtClass($this,$
sql);
$stmt->setFetchMode($this->_fetchMode);
return $stmt;
}
/**
* Gets the last ID generated automatically by an IDENTITY/AUTOINCREMENT column.
*
* As a convention,on RDBMS brands that support sequences
* (e.g. Oracle,Postgre
sql,DB2),this method forms the name of a sequence
* from the arguments and returns the last id generated by that sequence.
* On RDBMS brands that support IDENTITY/AUTOINCREMENT columns,this method
* returns the last value generated for such a column,and the table name
* argument is
disregarded.
*
* On RDBMS brands that don't support sequences,$tableName and $primaryKey
* are ig
nored.
*
* @p
aram string $tableName OPTIONAL Name of table.
* @p
aram string $primaryKey OPTIONAL Name of primary key column.
* @return string
*/
public function lastInsertId($tableName = null,$primaryKey = null)
{
$this->_connect();
return $this->_connection->lastInsertId();
}
/**
* Special handling for PDO query().
* All bind p
arameter names must begin with ':'
*
* @p
aram string|Zend_Db_Select $
sql The
sql statement with placeholders.
* @p
aram array $bind An array of data to bind to the placeholders.
* @return Zend_Db_Statement_Pdo
* @throws Zend_Db_Adapter_Exception To re-throw PDOException.
*/
public function query($
sql,$bind = array())
{
if (empty($bind) && $
sql instanceof Zend_Db_Select) {
$bind = $
sql->getBind();
}
if (is_array($bind)) {
foreach ($bind as $name => $value) {
if (!is_int($name) && !preg_match('/^:/',$name)) {
$newName = ":$name";
unset($bind[$name]);
$bind[$newName] = $value;
}
}
}
try {
return parent::query($
sql,$bind);
} catch (PDOException $e) {
/**
* @see Zend_Db_Statement_Exception
*/
require_once 'Zend/Db/Statement/Exception.
PHP';
throw new Zend_Db_Statement_Exception($e->getMessage(),$e);
}
}
/**
* Executes an
sql statement and return the number of affected rows
*
* @p
aram mixed $
sql The
sql statement with placeholders.
* May be a string or Zend_Db_Select.
* @return integer Number of rows that were modified
* or deleted by the
sql statement
*/
public function exec($
sql)
{
if ($
sql instanceof Zend_Db_Select) {
$
sql = $
sql->assemble();
}
try {
$affected = $this->getConnection()->exec($
sql);
if ($affected === false) {
$errorInfo = $this->getConnection()->errorInfo();
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception($errorInfo[2]);
}
return $affected;
} catch (PDOException $e) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception($e->getMessage(),$e);
}
}
/**
* Quote a raw string.
*
* @p
aram string $value Raw string
* @return string Quoted string
*/
protected function _quote($value)
{
if (is_int($value) || is_float($value)) {
return $value;
}
$this->_connect();
return $this->_connection->quote($value);
}
/**
* Begin a transaction.
*/
protected function _beginTransaction()
{
$this->_connect();
$this->_connection->beginTransaction();
}
/**
* Commit a transaction.
*/
protected function _commit()
{
$this->_connect();
$this->_connection->commit();
}
/**
* Roll-back a transaction.
*/
protected function _rollBack() {
$this->_connect();
$this->_connection->rollBack();
}
/**
* Set the PDO fetch mode.
*
* @t
odo Support FETCH_CLASS and FETCH_INTO.
*
* @p
aram int $mode A PDO fetch mode.
* @return void
* @throws Zend_Db_Adapter_Exception
*/
public function setFetchMode($mode)
{
//check for PDO extension
if (!extension_loaded('pdo')) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception('The PDO extension is
required for this adapter but the extension is not loaded');
}
switch ($mode) {
case PDO::FETCH_LAZY:
case PDO::FETCH_ASSOC:
case PDO::FETCH_NUM:
case PDO::FETCH_BOTH:
case PDO::FETCH_NAMED:
case PDO::FETCH_OBJ:
$this->_fetchMode = $mode;
break;
default:
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception("Invalid fetch mode '$mode' specified");
break;
}
}
/**
* Check if the adapter supports real
sql p
arameters.
*
* @p
aram string $type 'positional' or 'named'
* @return bool
*/
public function supportsP
arameters($type)
{
switch ($type) {
case 'positional':
case 'named':
default:
return true;
}
}
/**
* Retrieve server version in
PHP style
*
* @return string
*/
public function getServerVersion()
{
$this->_connect();
try {
$version = $this->_connection->getAttribute(PDO::ATTR_SERVER_VERSION);
} catch (PDOException $e) {
// In case of the driver doesn't support getting attributes
return null;
}
$matches = null;
if (preg_match('/((?:[0-9]{1,2}\.){1,3}[0-9]{1,2})/',$version,$matches)) {
return $matches[1];
} else {
return null;
}
}
}
rush:
PHP;">
Zend_Db::FLOAT_TYPE
);
/** Weither or not that object can get serialized
*
* @var bool
*/
protected $_allowSerialization = true;
/**
* Weither or not the database should be reconnected
* to that adapter when waking up
*
* @var bool
*/
protected $_autoReconnectOnUnserialize = false;
/**
* Constructor.
*
* $con
fig is an array of key/value pa
irs or an instance of Zend_Con
fig
* containing con
figuration options. These options are common to most adapters:
*
*
dbname => (string) The name of the database to user
* username => (string) Connect to the database as this username.
* password => (string) Password associated with the username.
* host => (string) What host to connect to,defaults to localhost
*
* Some options are used on a case-by-case basis by adapters:
*
* port => (string) The port of the database
* persistent => (boolean) Whether to use a persistent connection or not,defaults to false
* protocol => (string) The network protocol,defaults to TCPIP
* caseFolding => (int) style of case-al
teration used for identifiers
* socket => (string) The socket or named pipe that should be used
*
* @p
aram array|Zend_Con
fig $con
fig An array or instance of Zend_Con
fig having con
figuration data
* @throws Zend_Db_Adapter_Exception
*/
public function __construct($con
fig)
{
/*
* Verify that adapter p
arameters are in an array.
*/
if (!is_array($con
fig)) {
/*
* Convert Zend_Con
fig argument to a plain array.
*/
if ($con
fig instanceof Zend_Con
fig) {
$con
fig = $con
fig->toArray();
} else {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception('Adapter p
arameters must be in an array or a Zend_Con
fig object');
}
}
$this->_check
requiredOptions($con
fig);
$options = array(
Zend_Db::CASE_FOLDING => $this->_caseFolding,Zend_Db::AUTO_QUOTE_IDENTIFIERS => $this->_autoQuoteIdentifiers,Zend_Db::FETCH_MODE => $this->_fetchMode,);
$driverOptions = array();
/*
*
normalize the con
fig and merge it with the defaults
*/
if (array_key_exists('options',$con
fig)) {
// can't use array_merge() because keys might be integers
foreach ((array) $con
fig['options'] as $key => $value) {
$options[$key] = $value;
}
}
if (array_key_exists('driver_options',$con
fig)) {
if (!empty($con
fig['driver_options'])) {
// can't use array_merge() because keys might be integers
foreach ((array) $con
fig['driver_options'] as $key => $value) {
$driverOptions[$key] = $value;
}
}
}
if (!isset($con
fig['charset'])) {
$con
fig['charset'] = null;
}
if (!isset($con
fig['persistent'])) {
$con
fig['persistent'] = false;
}
$this->_con
fig = array_merge($this->_con
fig,$con
fig);
$this->_con
fig['options'] = $options;
$this->_con
fig['driver_options'] = $driverOptions;
// obtain the case setting,if there is one
if (array_key_exists(Zend_Db::CASE_FOLDING,$options)) {
$case = (int) $options[Zend_Db::CASE_FOLDING];
switch ($case) {
case Zend_Db::CASE_LOWER:
case Zend_Db::CASE_UPPER:
case Zend_Db::CASE_NATURAL:
$this->_caseFolding = $case;
break;
default:
/** @see Zend_Db_Adapter_Exception */
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception('Case must be one of the following constants: '
. 'Zend_Db::CASE_NATURAL,Zend_Db::CASE_LOWER,Zend_Db::CASE_UPPER');
}
}
if (array_key_exists(Zend_Db::FETCH_MODE,$options)) {
if (is_string($options[Zend_Db::FETCH_MODE])) {
$constant = 'Zend_Db::FETCH_' . str
toupper($options[Zend_Db::FETCH_MODE]);
if(defined($constant)) {
$options[Zend_Db::FETCH_MODE] = constant($constant);
}
}
$this->setFetchMode((int) $options[Zend_Db::FETCH_MODE]);
}
// obtain quoting property if there is one
if (array_key_exists(Zend_Db::AUTO_QUOTE_IDENTIFIERS,$options)) {
$this->_autoQuoteIdentifiers = (bool) $options[Zend_Db::AUTO_QUOTE_IDENTIFIERS];
}
// obtain allow serialization property if there is one
if (array_key_exists(Zend_Db::ALLOW_SERIALIZATION,$options)) {
$this->_allowSerialization = (bool) $options[Zend_Db::ALLOW_SERIALIZATION];
}
// obtain auto reconnect on unserialize property if there is one
if (array_key_exists(Zend_Db::AUTO_RECONNECT_ON_UNSERIALIZE,$options)) {
$this->_autoReconnectOnUnserialize = (bool) $options[Zend_Db::AUTO_RECONNECT_ON_UNSERIALIZE];
}
// create a profiler object
$profiler = false;
if (array_key_exists(Zend_Db::PROFILER,$this->_con
fig)) {
$profiler = $this->_con
fig[Zend_Db::PROFILER];
unset($this->_con
fig[Zend_Db::PROFILER]);
}
$this->setProfiler($profiler);
}
/**
* Check for con
fig options that are mandatory.
* Throw exceptions if any are missing.
*
* @p
aram array $con
fig
* @throws Zend_Db_Adapter_Exception
*/
protected function _check
requiredOptions(array $con
fig)
{
// we need at least a
dbname
if (! array_key_exists('
dbname',$con
fig)) {
/** @see Zend_Db_Adapter_Exception */
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception("Con
figuration array must have a key for '
dbname' that names the database instance");
}
if (! array_key_exists('password',$con
fig)) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception("Con
figuration array must have a key for 'password' for login credentials");
}
if (! array_key_exists('username',$con
fig)) {
/**
* @see Zend_Db_Adapter_Exception
*/
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception("Con
figuration array must have a key for 'username' for login credentials");
}
}
/**
* Returns the underlying database connection object or resource.
* If not presently connected,this initiates the connection.
*
* @return object|resource|null
*/
public function getConnection()
{
$this->_connect();
return $this->_connection;
}
/**
* Returns the con
figuration variables in this adapter.
*
* @return array
*/
public function getCon
fig()
{
return $this->_con
fig;
}
/**
* Set the adapter's profiler object.
*
* The argument may be a boolean,an associative array,an instance of
* Zend_Db_Profiler,or an instance of Zend_Con
fig.
*
* A boolean argument sets the profiler to enabled if true,or
disabled if
* false. The profiler class is the adapter's default profiler class,* Zend_Db_Profiler.
*
* An instance of Zend_Db_Profiler sets the adapter's instance to that
* object. The profiler is enabled and
disabled sep
arately.
*
* An associative array argument may contain any of the keys 'enabled',* 'class',and 'instance'. The 'enabled' and 'instance' keys correspond to the
* boolean and object types documented above. The 'class' key is used to name a
* class to use for a custom profiler. The class must be Zend_Db_Profiler or a
* subclass. The class is instantiated with no constructor arguments. The 'class'
* option is ig
nored when the 'instance' option is supplied.
*
* An object of type Zend_Con
fig may contain the properties 'enabled','class',and
* 'instance',just as if an associative array had been passed instead.
*
* @p
aram Zend_Db_Profiler|Zend_Con
fig|array|boolean $profiler
* @return Zend_Db_Adapter_Abstract Provides a fluent interface
* @throws Zend_Db_Profiler_Exception if the object instance or class specified
* is not Zend_Db_Profiler or an extension of that class.
*/
public function setProfiler($profiler)
{
$enabled = null;
$profilerClass = $this->_defaultProfilerClass;
$profilerInstance = null;
if ($profilerIsObject = is_object($profiler)) {
if ($profiler instanceof Zend_Db_Profiler) {
$profilerInstance = $profiler;
} else if ($profiler instanceof Zend_Con
fig) {
$profiler = $profiler->toArray();
} else {
/**
* @see Zend_Db_Profiler_Exception
*/
require_once 'Zend/Db/Profiler/Exception.
PHP';
throw new Zend_Db_Profiler_Exception('Profiler argument must be an instance of either Zend_Db_Profiler'
. ' or Zend_Con
fig when provided as an object');
}
}
if (is_array($profiler)) {
if (isset($profiler['enabled'])) {
$enabled = (bool) $profiler['enabled'];
}
if (isset($profiler['class'])) {
$profilerClass = $profiler['class'];
}
if (isset($profiler['instance'])) {
$profilerInstance = $profiler['instance'];
}
} else if (!$profilerIsObject) {
$enabled = (bool) $profiler;
}
if ($profilerInstance === null) {
if (!class_exists($profilerClass)) {
require_once 'Zend/Loader.
PHP';
Zend_Loader::loadClass($profilerClass);
}
$profilerInstance = new $profilerClass();
}
if (!$profilerInstance instanceof Zend_Db_Profiler) {
/** @see Zend_Db_Profiler_Exception */
require_once 'Zend/Db/Profiler/Exception.
PHP';
throw new Zend_Db_Profiler_Exception('Class ' . get_class($profilerInstance) . ' does not extend '
. 'Zend_Db_Profiler');
}
if (null !== $enabled) {
$profilerInstance->setEnabled($enabled);
}
$this->_profiler = $profilerInstance;
return $this;
}
/**
* Returns the profiler for this adapter.
*
* @return Zend_Db_Profiler
*/
public function getProfiler()
{
return $this->_profiler;
}
/**
* Get the default statement class.
*
* @return string
*/
public function getStatementClass()
{
return $this->_defaultStmtClass;
}
/**
* Set the default statement class.
*
* @return Zend_Db_Adapter_Abstract Fluent interface
*/
public function setStatementClass($class)
{
$this->_defaultStmtClass = $class;
return $this;
}
/**
* Prepares and executes an
sql statement with bound data.
*
* @p
aram mixed $
sql The
sql statement with placeholders.
* May be a string or Zend_Db_Select.
* @p
aram mixed $bind An array of data to bind to the placeholders.
* @return Zend_Db_Statement_Interface
*/
public function query($
sql,$bind = array())
{
// connect to the database if needed
$this->_connect();
// is the $
sql a Zend_Db_Select object?
if ($
sql instanceof Zend_Db_Select) {
if (empty($bind)) {
$bind = $
sql->getBind();
}
$
sql = $
sql->assemble();
}
// make sure $bind to an array;
// don't use (array) typecasting because
// because $bind may be a Zend_Db_Expr object
if (!is_array($bind)) {
$bind = array($bind);
}
// prepare and execute the statement with profiling
$stmt = $this->prepare($
sql);
$stmt->execute($bind);
// return the results em
bedded in the prepared statement object
$stmt->setFetchMode($this->_fetchMode);
return $stmt;
}
/**
* Leave autocommit mode and begin a transaction.
*
* @return Zend_Db_Adapter_Abstract
*/
public function beginTransaction()
{
$this->_connect();
$q = $this->_profiler->queryStart('begin',Zend_Db_Profiler::TRANSACTION);
$this->_beginTransaction();
$this->_profiler->queryEnd($q);
return $this;
}
/**
* Commit a transaction and return to autocommit mode.
*
* @return Zend_Db_Adapter_Abstract
*/
public function commit()
{
$this->_connect();
$q = $this->_profiler->queryStart('commit',Zend_Db_Profiler::TRANSACTION);
$this->_commit();
$this->_profiler->queryEnd($q);
return $this;
}
/**
* Roll back a transaction and return to autocommit mode.
*
* @return Zend_Db_Adapter_Abstract
*/
public function rollBack()
{
$this->_connect();
$q = $this->_profiler->queryStart('rollback',Zend_Db_Profiler::TRANSACTION);
$this->_rollBack();
$this->_profiler->queryEnd($q);
return $this;
}
/**
* Inserts a table row with specified data.
*
* @p
aram mixed $table The table to insert data into.
* @p
aram array $bind Column-value pa
irs.
* @return int The number of affected rows.
* @throws Zend_Db_Adapter_Exception
*/
public function insert($table,array $bind)
{
// extract and quote col names from the array keys
$cols = array();
$vals = array();
$i = 0;
foreach ($bind as $col => $val) {
$cols[] = $this->quoteIdentifier($col,true);
if ($val instanceof Zend_Db_Expr) {
$vals[] = $val->__toString();
unset($bind[$col]);
} else {
if ($this->supportsP
arameters('positional')) {
$vals[] = '?';
} else {
if ($this->supportsP
arameters('named')) {
unset($bind[$col]);
$bind[':col'.$i] = $val;
$vals[] = ':col'.$i;
$i++;
} else {
/** @see Zend_Db_Adapter_Exception */
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception(get_class($this) ." doesn't support positional or named binding");
}
}
}
}
// build the statement
$
sql = "INSERT INTO "
. $this->quoteIdentifier($table,true)
. ' (' . implode(',',$cols) . ') '
. 'VALUES (' . implode(',$vals) . ')';
// execute the statement and return the number of affected rows
if ($this->supportsP
arameters('positional')) {
$bind = array_values($bind);
}
$stmt = $this->query($
sql,$bind);
$result = $stmt->rowCount();
return $result;
}
/**
* Updates table rows with specified data based on a WHERE clause.
*
* @p
aram mixed $table The table to update.
* @p
aram array $bind Column-value pa
irs.
* @p
aram mixed $where UPDATE WHERE clause(s).
* @return int The number of affected rows.
* @throws Zend_Db_Adapter_Exception
*/
public function update($table,array $bind,$where = '')
{
/**
* Build "col = ?" pa
irs for the statement,* except for Zend_Db_Expr which is treated li
terally.
*/
$set = array();
$i = 0;
foreach ($bind as $col => $val) {
if ($val instanceof Zend_Db_Expr) {
$val = $val->__toString();
unset($bind[$col]);
} else {
if ($this->supportsP
arameters('positional')) {
$val = '?';
} else {
if ($this->supportsP
arameters('named')) {
unset($bind[$col]);
$bind[':col'.$i] = $val;
$val = ':col'.$i;
$i++;
} else {
/** @see Zend_Db_Adapter_Exception */
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception(get_class($this) ." doesn't support positional or named binding");
}
}
}
$set[] = $this->quoteIdentifier($col,true) . ' = ' . $val;
}
$where = $this->_whereExpr($where);
/**
* Build the UPDATE statement
*/
$
sql = "UPDATE "
. $this->quoteIdentifier($table,true)
. ' SET ' . implode(',$set)
. (($where) ? " WHERE $where" : '');
/**
* Execute the statement and return the number of affected rows
*/
if ($this->supportsP
arameters('positional')) {
$stmt = $this->query($
sql,array_values($bind));
} else {
$stmt = $this->query($
sql,$bind);
}
$result = $stmt->rowCount();
return $result;
}
/**
* Deletes table rows based on a WHERE clause.
*
* @p
aram mixed $table The table to update.
* @p
aram mixed $where DELETE WHERE clause(s).
* @return int The number of affected rows.
*/
public function delete($table,$where = '')
{
$where = $this->_whereExpr($where);
/**
* Build the DELETE statement
*/
$
sql = "DELETE FROM "
. $this->quoteIdentifier($table,true)
. (($where) ? " WHERE $where" : '');
/**
* Execute the statement and return the number of affected rows
*/
$stmt = $this->query($
sql);
$result = $stmt->rowCount();
return $result;
}
/**
* Convert an array,string,or Zend_Db_Expr object
* into a string to put in a WHERE clause.
*
* @p
aram mixed $where
* @return string
*/
protected function _whereExpr($where)
{
if (empty($where)) {
return $where;
}
if (!is_array($where)) {
$where = array($where);
}
foreach ($where as $cond => &$term) {
// is $cond an int? (i.e. Not a condition)
if (is_int($cond)) {
// $term is the full condition
if ($term instanceof Zend_Db_Expr) {
$term = $term->__toString();
}
} else {
// $cond is the condition with placeholder,// and $term is quoted into the condition
$term = $this->quoteInto($cond,$term);
}
$term = '(' . $term . ')';
}
$where = implode(' AND ',$where);
return $where;
}
/**
* Creates and returns a new Zend_Db_Select object for this adapter.
*
* @return Zend_Db_Select
*/
public function select()
{
return new Zend_Db_Select($this);
}
/**
* Get the fetch mode.
*
* @return int
*/
public function getFetchMode()
{
return $this->_fetchMode;
}
/**
* Fetches all
sql result rows as a sequential array.
* Uses the current fetchMode for the adapter.
*
* @p
aram string|Zend_Db_Select $
sql An
sql SELECT statement.
* @p
aram mixed $bind Data to bind into SELECT placeholders.
* @p
aram mixed $fetchMode Override current fetch mode.
* @return array
*/
public function fetchAll($
sql,$bind = array(),$fetchMode = null)
{
if ($fetchMode === null) {
$fetchMode = $this->_fetchMode;
}
$stmt = $this->query($
sql,$bind);
$result = $stmt->fetchAll($fetchMode);
return $result;
}
/**
* Fetches the f
irst row of the
sql result.
* Uses the current fetchMode for the adapter.
*
* @p
aram string|Zend_Db_Select $
sql An
sql SELECT statement.
* @p
aram mixed $bind Data to bind into SELECT placeholders.
* @p
aram mixed $fetchMode Override current fetch mode.
* @return mixed Array,object,or scalar depending on fetch mode.
*/
public function fetchRow($
sql,$bind);
$result = $stmt->fetch($fetchMode);
return $result;
}
/**
* Fetches all
sql result rows as an associative array.
*
* The f
irst column is the key,the entire row array is the
* value. You should construct the query to be sure that
* the f
irst column contains unique values,or else
* rows with duplicate values in the f
irst column will
* overwrite prev
IoUs data.
*
* @p
aram string|Zend_Db_Select $
sql An
sql SELECT statement.
* @p
aram mixed $bind Data to bind into SELECT placeholders.
* @return array
*/
public function fetchAssoc($
sql,$bind = array())
{
$stmt = $this->query($
sql,$bind);
$data = array();
while ($row = $stmt->fetch(Zend_Db::FETCH_ASSOC)) {
$tmp = array_values(array_slice($row,1));
$data[$tmp[0]] = $row;
}
return $data;
}
/**
* Fetches the f
irst column of all
sql result rows as an array.
*
* @p
aram string|Zend_Db_Select $
sql An
sql SELECT statement.
* @p
aram mixed $bind Data to bind into SELECT placeholders.
* @return array
*/
public function fetchCol($
sql,$bind);
$result = $stmt->fetchAll(Zend_Db::FETCH_COLUMN,0);
return $result;
}
/**
* Fetches all
sql result rows as an array of key-value pa
irs.
*
* The f
irst column is the key,the second column is the
* value.
*
* @p
aram string|Zend_Db_Select $
sql An
sql SELECT statement.
* @p
aram mixed $bind Data to bind into SELECT placeholders.
* @return array
*/
public function fetchPa
irs($
sql,$bind);
$data = array();
while ($row = $stmt->fetch(Zend_Db::FETCH_NUM)) {
$data[$row[0]] = $row[1];
}
return $data;
}
/**
* Fetches the f
irst column of the f
irst row of the
sql result.
*
* @p
aram string|Zend_Db_Select $
sql An
sql SELECT statement.
* @p
aram mixed $bind Data to bind into SELECT placeholders.
* @return string
*/
public function fetchOne($
sql,$bind);
$result = $stmt->fetchColumn(0);
return $result;
}
/**
* Quote a raw string.
*
* @p
aram string $value Raw string
* @return string Quoted string
*/
protected function _quote($value)
{
if (is_int($value)) {
return $value;
} elseif (is_float($value)) {
return sprintf('%F',$value);
}
return "'" . add
cslashes($value,"\000\n\r\\'\"\032") . "'";
}
/**
* Safely quotes a value for an
sql statement.
*
* If an array is passed as the value,the array values are quoted
* and then returned as a comma-sep
arated string.
*
* @p
aram mixed $value The value to quote.
* @p
aram mixed $type OPTIONAL the
sql datatype name,or constant,or null.
* @return mixed An
sql-safe quoted value (or string of sep
arated values).
*/
public function quote($value,$type = null)
{
$this->_connect();
if ($value instanceof Zend_Db_Select) {
return '(' . $value->assemble() . ')';
}
if ($value instanceof Zend_Db_Expr) {
return $value->__toString();
}
if (is_array($value)) {
foreach ($value as &$val) {
$val = $this->quote($val,$type);
}
return implode(',$value);
}
if ($type !== null && array_key_exists($type = str
toupper($type),$this->_numericDataTypes)) {
$quotedValue = '0';
switch ($this->_numericDataTypes[$type]) {
case Zend_Db::INT_TYPE: // 32-bit integer
$quotedValue = (string) intval($value);
break;
case Zend_Db::BIGINT_TYPE: // 64-bit integer
// ANSI
sql-style hex li
terals (e.g. x'[\dA-F]+')
// are not supported here,because these are string
// li
terals,not numeric li
terals.
if (preg_match('/^(
[+-]? # optional sign
(?:
0[Xx][\da-fA-F]+ # ODBC-style hexadecimal
|\d+ # decimal or octal,or
MysqL ZEROFILL decimal
(?:[eE][+-]?\d+)? # optional exponent on decimals or octals
)
)/x',(string) $value,$matches)) {
$quotedValue = $matches[1];
}
break;
case Zend_Db::FLOAT_TYPE: // float or decimal
$quotedValue = sprintf('%F',$value);
}
return $quotedValue;
}
return $this->_quote($value);
}
/**
* Quotes a value and places into a piece of text at a placeholder.
*
* The placeholder is a question-mark; all placeholders will be replaced
* with the quoted value. For example:
*
*
* $text = "WHERE date < ?";
* $date = "2005-01-02";
* $safe = $sql->quoteInto($text,$date);
* // $safe = "WHERE date < '2005-01-02'"
*
*
* @p
aram string $text The text with a placeholder.
* @p
aram mixed $value The value to quote.
* @p
aram string $type OPTIONAL
sql datatype
* @p
aram integer $count OPTIONAL count of placeholders to replace
* @return string An
sql-safe quoted value placed into the original text.
*/
public function quoteInto($text,$value,$type = null,$count = null)
{
if ($count === null) {
return str_replace('?',$this->quote($value,$type),$text);
} else {
while ($count > 0) {
if (strpos($text,'?') !== false) {
$text = substr_replace($text,strpos($text,'?'),1);
}
--$count;
}
return $text;
}
}
/**
* Quotes an identifier.
*
* Accepts a string representing a qualified indentifier. For Example:
*
* $adapter->quoteIdentifier('myschema.mytable')
*
* Returns: "myschema"."mytable"
*
* Or,an array of one or more identifiers that may form a qualified identifier:
*
* $adapter->quoteIdentifier(array('myschema','my.table'))
*
* Returns: "myschema"."my.table"
*
* The actual quote ch
aracter surrounding the identifiers may
vary depending on
* the adapter.
*
* @p
aram string|array|Zend_Db_Expr $ident The identifier.
* @p
aram boolean $auto If true,heed the AUTO_QUOTE_IDENTIFIERS con
fig option.
* @return string The quoted identifier.
*/
public function quoteIdentifier($ident,$auto=false)
{
return $this->_quoteIdentifierAs($ident,$auto);
}
/**
* Quote a column identifier and alias.
*
* @p
aram string|array|Zend_Db_Expr $ident The identifier or expression.
* @p
aram string $alias An alias for the column.
* @p
aram boolean $auto If true,heed the AUTO_QUOTE_IDENTIFIERS con
fig option.
* @return string The quoted identifier and alias.
*/
public function quoteColumnAs($ident,$alias,$auto);
}
/**
* Quote a table identifier and alias.
*
* @p
aram string|array|Zend_Db_Expr $ident The identifier or expression.
* @p
aram string $alias An alias for the table.
* @p
aram boolean $auto If true,heed the AUTO_QUOTE_IDENTIFIERS con
fig option.
* @return string The quoted identifier and alias.
*/
public function quoteTableAs($ident,$alias = null,$auto = false)
{
return $this->_quoteIdentifierAs($ident,$auto);
}
/**
* Quote an identifier and an optional alias.
*
* @p
aram string|array|Zend_Db_Expr $ident The identifier or expression.
* @p
aram string $alias An optional alias.
* @p
aram boolean $auto If true,heed the AUTO_QUOTE_IDENTIFIERS con
fig option.
* @p
aram string $as The string to add between the identifier/expression and the alias.
* @return string The quoted identifier and alias.
*/
protected function _quoteIdentifierAs($ident,$auto = false,$as = ' AS ')
{
if ($ident instanceof Zend_Db_Expr) {
$quoted = $ident->__toString();
} elseif ($ident instanceof Zend_Db_Select) {
$quoted = '(' . $ident->assemble() . ')';
} else {
if (is_string($ident)) {
$ident = explode('.',$ident);
}
if (is_array($ident)) {
$segments = array();
foreach ($ident as $segment) {
if ($segment instanceof Zend_Db_Expr) {
$segments[] = $segment->__toString();
} else {
$segments[] = $this->_quoteIdentifier($segment,$auto);
}
}
if ($alias !== null && end($ident) == $alias) {
$alias = null;
}
$quoted = implode('.',$segments);
} else {
$quoted = $this->_quoteIdentifier($ident,$auto);
}
}
if ($alias !== null) {
$quoted .= $as . $this->_quoteIdentifier($alias,$auto);
}
return $quoted;
}
/**
* Quote an identifier.
*
* @p
aram string $value The identifier or expression.
* @p
aram boolean $auto If true,heed the AUTO_QUOTE_IDENTIFIERS con
fig option.
* @return string The quoted identifier and alias.
*/
protected function _quoteIdentifier($value,$auto=false)
{
if ($auto === false || $this->_autoQuoteIdentifiers === true) {
$q = $this->getQuoteIdentifierSymbol();
return ($q . str_replace("$q","$q$q",$value) . $q);
}
return $value;
}
/**
* Returns the symbol the adapter uses for delimited identifiers.
*
* @return string
*/
public function getQuoteIdentifierSymbol()
{
return '"';
}
/**
* Return the most recent value from the specified sequence in the database.
* This is supported only on RDBMS brands that support sequences
* (e.g. Oracle,DB2). Other RDBMS brands return null.
*
* @p
aram string $sequenceName
* @return string
*/
public function lastSequenceId($sequenceName)
{
return null;
}
/**
* Generate a new value from the specified sequence in the database,and return it.
* This is supported only on RDBMS brands that support sequences
* (e.g. Oracle,DB2). Other RDBMS brands return null.
*
* @p
aram string $sequenceName
* @return string
*/
public function nextSequenceId($sequenceName)
{
return null;
}
/**
* Helper method to change the case of the strings used
* when returning result sets in FETCH_ASSOC and FETCH_BOTH
* modes.
*
* This is not intended to be used by application code,* but the method must be public so the Statement class
* can invoke it.
*
* @p
aram string $key
* @return string
*/
public function foldCase($key)
{
switch ($this->_caseFolding) {
case Zend_Db::CASE_LOWER:
$value = strtolower((string) $key);
break;
case Zend_Db::CASE_UPPER:
$value = str
toupper((string) $key);
break;
case Zend_Db::CASE_NATURAL:
default:
$value = (string) $key;
}
return $value;
}
/**
* called when object is getting serialized
* This
disconnects the DB object that cant be serialized
*
* @throws Zend_Db_Adapter_Exception
* @return array
*/
public function __sleep()
{
if ($this->_allowSerialization == false) {
/** @see Zend_Db_Adapter_Exception */
require_once 'Zend/Db/Adapter/Exception.
PHP';
throw new Zend_Db_Adapter_Exception(get_class($this) ." is not allowed to be serialized");
}
$this->_connection = false;
return array_keys(array_diff_key(get_object_vars($this),array('_connection'=>false)));
}
/**
* called when object is getting unserialized
*
* @return void
*/
public function __wakeup()
{
if ($this->_autoReconnectOnUnserialize == true) {
$this->getConnection();
}
}
/**
* Abstract Methods
*/
/**
* Returns a list of the tables in the database.
*
* @return array
*/
abstract public function listTables();
/**
* Returns the column descriptions for a table.
*
* The return value is an associative array keyed by the column name,* as returned by the RDBMS.
*
* The value of each array element is an associative array
* with the following keys:
*
* SCHEMA_NAME => string; name of database or schema
* TABLE_NAME => string;
* COLUMN_NAME => string; column name
* COLUMN_POSITION => number; ordinal position of column in table
* DATA_TYPE => string;
sql datatype name of column
* DEFAULT => string; default expression of column,null if none
* NULLABLE => boolean; true if column can have nulls
* LENGTH => number; length of CHAR/VARCHAR
* SCALE => number; scale of NUMERIC/DECIMAL
* PRECISION => number; precision of NUMERIC/DECIMAL
* UNSIGNED => boolean; unsigned property of an integer type
* PRIMARY => boolean; true if column is part of the primary key
* PRIMARY_POSITION => integer; position of column in primary key
*
* @p
aram string $tableName
* @p
aram string $schemaName OPTIONAL
* @return array
*/
abstract public function describeTable($tableName,$schemaName = null);
/**
* Creates a connection to the database.
*
* @return void
*/
abstract protected function _connect();
/**
* Test if a connection is active
*
* @return boolean
*/
abstract public function isConnected();
/**
* Force the connection to close.
*
* @return void
*/
abstract public function closeConnection();
/**
* Prepare a statement and return a PDOStatement-like object.
*
* @p
aram string|Zend_Db_Select $
sql sql query
* @return Zend_Db_Statement|PDOStatement
*/
abstract public function prepare($
sql);
/**
* Gets the last ID generated automatically by an IDENTITY/AUTOINCREMENT column.
*
* As a convention,and the table name
* argument is
disregarded.
*
* @p
aram string $tableName OPTIONAL Name of table.
* @p
aram string $primaryKey OPTIONAL Name of primary key column.
* @return string
*/
abstract public function lastInsertId($tableName = null,$primaryKey = null);
/**
* Begin a transaction.
*/
abstract protected function _beginTransaction();
/**
* Commit a transaction.
*/
abstract protected function _commit();
/**
* Roll-back a transaction.
*/
abstract protected function _rollBack();
/**
* Set the fetch mode.
*
* @p
aram integer $mode
* @return void
* @throws Zend_Db_Adapter_Exception
*/
abstract public function setFetchMode($mode);
/**
* Adds an adapter-specific LIMIT clause to the SELECT statement.
*
* @p
aram mixed $
sql
* @p
aram integer $count
* @p
aram integer $offset
* @return string
*/
abstract public function limit($
sql,$offset = 0);
/**
* Check if the adapter supports real
sql p
arameters.
*
* @p
aram string $type 'positional' or 'named'
* @return bool
*/
abstract public function supportsP
arameters($type);
/**
* Retrieve server version in
PHP style
*
* @return string
*/
abstract public function getServerVersion();
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。