. */ Doctrine::autoload('Doctrine_Connection_Common'); /** * Doctrine_Connection_Mysql * * @package Doctrine ORM * @url www.phpdoctrine.com * @license LGPL */ class Doctrine_Connection_Mysql extends Doctrine_Connection_Common { /** * @var string $driverName the name of this connection driver */ protected $driverName = 'Mysql'; /** * the constructor * * @param Doctrine_Manager $manager * @param PDO $pdo database handle */ public function __construct(Doctrine_Manager $manager,PDO $pdo) { $pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, true); $this->setAttribute(Doctrine::ATTR_QUERY_LIMIT, Doctrine::LIMIT_ROWS); $this->supported = array( 'sequences' => 'emulated', 'indexes' => true, 'affected_rows' => true, 'transactions' => true, 'savepoints' => false, 'summary_functions' => true, 'order_by_text' => true, 'current_id' => 'emulated', 'limit_queries' => true, 'LOBs' => true, 'replace' => true, 'sub_selects' => true, 'auto_increment' => true, 'primary_key' => true, 'result_introspection' => true, 'prepared_statements' => 'emulated', 'identifier_quoting' => true, 'pattern_escaping' => true ); parent::__construct($manager,$pdo); } /** * getTransactionIsolation * * @return string returns the current session transaction isolation level */ public function getTransactionIsolation() { $ret = $this->dbh->query('SELECT @@tx_isolation')->fetch(PDO::FETCH_NUM); return $ret[0]; } /** * Set the transacton isolation level. * * example : * * * $conn->setTransactionIsolation('READ UNCOMMITTED'); * * * @param string standard isolation level * READ UNCOMMITTED (allows dirty reads) * READ COMMITTED (prevents dirty reads) * REPEATABLE READ (prevents nonrepeatable reads) * SERIALIZABLE (prevents phantom reads) * * @throws Doctrine_Connection_Mysql_Exception if using unknown isolation level * @throws PDOException if something fails at the PDO level * @return void */ public function setTransactionIsolation($isolation) { switch ($isolation) { case 'READ UNCOMMITTED': case 'READ COMMITTED': case 'REPEATABLE READ': case 'SERIALIZABLE': break; default: throw new Doctrine_Connection_Mysql_Exception('Isolation level ' . $isolation . ' is not supported.'); } $query = "SET SESSION TRANSACTION ISOLATION LEVEL $isolation"; return $this->dbh->query($query); } /** * Returns string to concatenate two or more string parameters * * @param string $value1 * @param string $value2 * @param string $values... * @return string a concatenation of two or more strings */ public function concat($value1, $value2) { $args = func_get_args(); return "CONCAT(".implode(', ', $args).")"; } /** * returns the state of this connection * * @see Doctrine_Connection_Transaction::STATE_* constants * @return integer the connection state */ public function getState() { return 0; // @todo FIXME not working! } }