RetailCRM-Mirror/doctrine2
1
0
Fork 0
mirror of synced 2025-01-06 00:57:10 +03:00
Code Issues Projects Releases Wiki Activity

[2.0] Formatting issues.

Browse Source
This commit is contained in:
romanb 2009-05-28 11:19:27 +00:00
parent a758b56551
commit 05173a867e
1 changed files with 254 additions and 254 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

508
lib/Doctrine/DBAL/Connection.php
View File

@ -63,135 +63,135 @@ class Connection
* Constant for transaction isolation level READ COMMITTED. * Constant for transaction isolation level READ COMMITTED.
*/ */
const TRANSACTION_READ_COMMITTED = 2; const TRANSACTION_READ_COMMITTED = 2;
/** /**
* Constant for transaction isolation level REPEATABLE READ. * Constant for transaction isolation level REPEATABLE READ.
*/ */
const TRANSACTION_REPEATABLE_READ = 3; const TRANSACTION_REPEATABLE_READ = 3;
/** /**
* Constant for transaction isolation level SERIALIZABLE. * Constant for transaction isolation level SERIALIZABLE.
*/ */
const TRANSACTION_SERIALIZABLE = 4; const TRANSACTION_SERIALIZABLE = 4;
/**
* The wrapped driver connection.
*
* @var Doctrine\DBAL\Driver\Connection
*/
protected $_conn;
/**
* The Configuration.
*
* @var Doctrine\DBAL\Configuration
*/
protected $_config;
/**
* The EventManager.
*
* @var Doctrine\Common\EventManager
*/
protected $_eventManager;
/**
* Whether or not a connection has been established.
*
* @var boolean
*/
protected $_isConnected = false;
/**
* The transaction nesting level.
*
* @var integer
*/
protected $_transactionNestingLevel = 0;
/**
* The currently active transaction isolation level.
*
* @var integer
*/
protected $_transactionIsolationLevel;
/**
* The parameters used during creation of the Connection instance.
*
* @var array
*/
protected $_params = array();
/**
* The query count. Represents the number of executed database queries by the connection.
*
* @var integer
*/
protected $_queryCount = 0;
/**
* The DatabasePlatform object that provides information about the
* database platform used by the connection.
*
* @var Doctrine\DBAL\Platforms\AbstractPlatform
*/
protected $_platform;
/**
* The schema manager.
*
* @var Doctrine\DBAL\Schema\SchemaManager
*/
protected $_schemaManager;
/** /**
* The wrapped driver connection. * The used DBAL driver.
* *
* @var Doctrine\DBAL\Driver\Connection * @var Doctrine\DBAL\Driver
*/ */
protected $_conn; protected $_driver;
/** /**
* The Configuration. * Whether to quote identifiers. Read from the configuration upon construction.
* *
* @var Doctrine\DBAL\Configuration * @var boolean
*/ */
protected $_config; protected $_quoteIdentifiers = false;
/** /**
* The EventManager. * Initializes a new instance of the Connection class.
* *
* @var Doctrine\Common\EventManager * @param array $params The connection parameters.
*/ * @param Driver $driver
protected $_eventManager; * @param Configuration $config
* @param EventManager $eventManager
*/
public function __construct(array $params, Driver $driver, Configuration $config = null,
EventManager $eventManager = null)
{
$this->_driver = $driver;
$this->_params = $params;
/** if (isset($params['pdo'])) {
* Whether or not a connection has been established. $this->_conn = $params['pdo'];
* $this->_isConnected = true;
* @var boolean }
*/
protected $_isConnected = false;
/** // Create default config and event manager if none given
* The transaction nesting level. if ( ! $config) {
* $config = new Configuration();
* @var integer
*/
protected $_transactionNestingLevel = 0;
/**
* The currently active transaction isolation level.
*
* @var integer
*/
protected $_transactionIsolationLevel;
/**
* The parameters used during creation of the Connection instance.
*
* @var array
*/
protected $_params = array();
/**
* The query count. Represents the number of executed database queries by the connection.
*
* @var integer
*/
protected $_queryCount = 0;
/**
* The DatabasePlatform object that provides information about the
* database platform used by the connection.
*
* @var Doctrine\DBAL\Platforms\AbstractPlatform
*/
protected $_platform;
/**
* The schema manager.
*
* @var Doctrine\DBAL\Schema\SchemaManager
*/
protected $_schemaManager;
/**
* The used DBAL driver.
*
* @var Doctrine\DBAL\Driver
*/
protected $_driver;
/**
* Whether to quote identifiers. Read from the configuration upon construction.
*
* @var boolean
*/
protected $_quoteIdentifiers = false;
/**
* Initializes a new instance of the Connection class.
*
* @param array $params The connection parameters.
* @param Driver $driver
* @param Configuration $config
* @param EventManager $eventManager
*/
public function __construct(array $params, Driver $driver, Configuration $config = null,
EventManager $eventManager = null)
{
$this->_driver = $driver;
$this->_params = $params;
if (isset($params['pdo'])) {
$this->_conn = $params['pdo'];
$this->_isConnected = true;
}
// Create default config and event manager if none given
if ( ! $config) {
$config = new Configuration();
} }
if ( ! $eventManager) { if ( ! $eventManager) {
$eventManager = new EventManager(); $eventManager = new EventManager();
} }
$this->_config = $config; $this->_config = $config;
$this->_eventManager = $eventManager; $this->_eventManager = $eventManager;
$this->_platform = $driver->getDatabasePlatform(); $this->_platform = $driver->getDatabasePlatform();
$this->_transactionIsolationLevel = $this->_platform->getDefaultTransactionIsolationLevel(); $this->_transactionIsolationLevel = $this->_platform->getDefaultTransactionIsolationLevel();
$this->_quoteIdentifiers = $config->getQuoteIdentifiers(); $this->_quoteIdentifiers = $config->getQuoteIdentifiers();
$this->_platform->setQuoteIdentifiers($this->_quoteIdentifiers); $this->_platform->setQuoteIdentifiers($this->_quoteIdentifiers);
} }
/** /**
* Get the array of parameters used to instantiated this connection instance * Get the array of parameters used to instantiated this connection instance
* *
@ -202,15 +202,15 @@ class Connection
return $this->_params; return $this->_params;
} }
/** /**
* Get the name of the database connected to for this Connection instance * Get the name of the database connected to for this Connection instance
* *
* @return string $database * @return string $database
*/ */
public function getDatabase() public function getDatabase()
{ {
return $this->_driver->getDatabase($this); return $this->_driver->getDatabase($this);
} }
/** /**
* Gets the DBAL driver instance. * Gets the DBAL driver instance.
@ -252,70 +252,70 @@ class Connection
return $this->_platform; return $this->_platform;
} }
/** /**
* Establishes the connection with the database. * Establishes the connection with the database.
* *
* @return boolean * @return boolean
*/ */
public function connect() public function connect()
{ {
if ($this->_isConnected) return false; if ($this->_isConnected) return false;
$driverOptions = isset($this->_params['driverOptions']) ? $driverOptions = isset($this->_params['driverOptions']) ?
$this->_params['driverOptions'] : array(); $this->_params['driverOptions'] : array();
$user = isset($this->_params['user']) ? $user = isset($this->_params['user']) ?
$this->_params['user'] : null; $this->_params['user'] : null;
$password = isset($this->_params['password']) ? $password = isset($this->_params['password']) ?
$this->_params['password'] : null; $this->_params['password'] : null;
$this->_conn = $this->_driver->connect( $this->_conn = $this->_driver->connect(
$this->_params, $this->_params,
$user, $user,
$password, $password,
$driverOptions $driverOptions
); );
$this->_isConnected = true; $this->_isConnected = true;
return true; return true;
} }
/** /**
* Convenience method for PDO::query("...") followed by $stmt->fetch(PDO::FETCH_ASSOC). * Convenience method for PDO::query("...") followed by $stmt->fetch(PDO::FETCH_ASSOC).
* *
* @param string $statement The SQL query. * @param string $statement The SQL query.
* @param array $params The query parameters. * @param array $params The query parameters.
* @return array * @return array
*/ */
public function fetchRow($statement, array $params = array()) public function fetchRow($statement, array $params = array())
{ {
return $this->execute($statement, $params)->fetch(\PDO::FETCH_ASSOC); return $this->execute($statement, $params)->fetch(\PDO::FETCH_ASSOC);
} }
/** /**
* Convenience method for PDO::query("...") followed by $stmt->fetch(PDO::FETCH_NUM). * Convenience method for PDO::query("...") followed by $stmt->fetch(PDO::FETCH_NUM).
* *
* @param string $statement sql query to be executed * @param string $statement sql query to be executed
* @param array $params prepared statement params * @param array $params prepared statement params
* @return array * @return array
*/ */
public function fetchArray($statement, array $params = array()) public function fetchArray($statement, array $params = array())
{ {
return $this->execute($statement, $params)->fetch(\PDO::FETCH_NUM); return $this->execute($statement, $params)->fetch(\PDO::FETCH_NUM);
} }
/** /**
* Convenience method for PDO::query("...") followed by $stmt->fetchAll(PDO::FETCH_COLUMN, ...). * Convenience method for PDO::query("...") followed by $stmt->fetchAll(PDO::FETCH_COLUMN, ...).
* *
* @param string $statement sql query to be executed * @param string $statement sql query to be executed
* @param array $params prepared statement params * @param array $params prepared statement params
* @param int $colnum 0-indexed column number to retrieve * @param int $colnum 0-indexed column number to retrieve
* @return array * @return array
*/ */
public function fetchColumn($statement, array $params = array(), $colnum = 0) public function fetchColumn($statement, array $params = array(), $colnum = 0)
{ {
return $this->execute($statement, $params)->fetchAll(\PDO::FETCH_COLUMN, $colnum); return $this->execute($statement, $params)->fetchAll(\PDO::FETCH_COLUMN, $colnum);
} }
/** /**
* Whether an actual connection to the database is established. * Whether an actual connection to the database is established.
@ -327,71 +327,71 @@ class Connection
return $this->_isConnected; return $this->_isConnected;
} }
/** /**
* Convenience method for PDO::query("...") followed by $stmt->fetchAll(PDO::FETCH_BOTH). * Convenience method for PDO::query("...") followed by $stmt->fetchAll(PDO::FETCH_BOTH).
* *
* @param string $statement sql query to be executed * @param string $statement sql query to be executed
* @param array $params prepared statement params * @param array $params prepared statement params
* @return array * @return array
*/ */
public function fetchBoth($statement, array $params = array()) public function fetchBoth($statement, array $params = array())
{ {
return $this->execute($statement, $params)->fetchAll(\PDO::FETCH_BOTH); return $this->execute($statement, $params)->fetchAll(\PDO::FETCH_BOTH);
} }
/** /**
* Deletes table row(s) matching the specified identifier. * Deletes table row(s) matching the specified identifier.
* *
* @param string $table The table to delete data from * @param string $table The table to delete data from
* @param array $identifier An associateve array containing identifier fieldname-value pairs. * @param array $identifier An associateve array containing identifier fieldname-value pairs.
* @return integer The number of affected rows * @return integer The number of affected rows
*/ */
public function delete($tableName, array $identifier) public function delete($tableName, array $identifier)
{ {
$this->connect(); $this->connect();
$criteria = array(); $criteria = array();
foreach (array_keys($identifier) as $id) { foreach (array_keys($identifier) as $id) {
$criteria[] = $this->quoteIdentifier($id) . ' = ?'; $criteria[] = $this->quoteIdentifier($id) . ' = ?';
} }
$query = 'DELETE FROM ' $query = 'DELETE FROM '
. $this->quoteIdentifier($tableName) . $this->quoteIdentifier($tableName)
. ' WHERE ' . implode(' AND ', $criteria); . ' WHERE ' . implode(' AND ', $criteria);
return $this->exec($query, array_values($identifier)); return $this->exec($query, array_values($identifier));
} }
/** /**
* Closes the connection. * Closes the connection.
* *
* @return void * @return void
*/ */
public function close() public function close()
{ {
unset($this->_conn); unset($this->_conn);
$this->_isConnected = false; $this->_isConnected = false;
} }
/** /**
* Sets the transaction isolation level. * Sets the transaction isolation level.
* *
* @param integer $level The level to set. * @param integer $level The level to set.
*/ */
public function setTransactionIsolation($level) public function setTransactionIsolation($level)
{ {
$this->_transactionIsolationLevel = $level; $this->_transactionIsolationLevel = $level;
return $this->exec($this->_platform->getSetTransactionIsolationSql($level)); return $this->exec($this->_platform->getSetTransactionIsolationSql($level));
} }
/** /**
* Gets the currently active transaction isolation level. * Gets the currently active transaction isolation level.
* *
* @return integer The current transaction isolation level. * @return integer The current transaction isolation level.
*/ */
public function getTransactionIsolation() public function getTransactionIsolation()
{ {
return $this->_transactionIsolationLevel; return $this->_transactionIsolationLevel;
} }
/** /**
* Updates table row(s) with specified data * Updates table row(s) with specified data
@ -417,9 +417,9 @@ class Connection
$params = array_merge(array_values($data), array_values($identifier)); $params = array_merge(array_values($data), array_values($identifier));
$sql = 'UPDATE ' . $this->quoteIdentifier($tableName) $sql = 'UPDATE ' . $this->quoteIdentifier($tableName)
. ' SET ' . implode(', ', $set) . ' SET ' . implode(', ', $set)
. ' WHERE ' . implode(' = ? AND ', array_keys($identifier)) . ' WHERE ' . implode(' = ? AND ', array_keys($identifier))
. ' = ?'; . ' = ?';
return $this->exec($sql, $params); return $this->exec($sql, $params);
} }
@ -566,11 +566,11 @@ class Connection
public function execute($query, array $params = array()) public function execute($query, array $params = array())
{ {
$this->connect(); $this->connect();
if ($this->_config->getSqlLogger()) { if ($this->_config->getSqlLogger()) {
$this->_config->getSqlLogger()->logSql($query, $params); $this->_config->getSqlLogger()->logSql($query, $params);
} }
if ( ! empty($params)) { if ( ! empty($params)) {
$stmt = $this->prepare($query); $stmt = $this->prepare($query);
$stmt->execute($params); $stmt->execute($params);