. */ Doctrine::autoload('Doctrine_Connection_Common'); /** * Doctrine_Connection_Mysql * * @package Doctrine * @license http://www.opensource.org/licenses/lgpl-license.php LGPL * @author Konsta Vesterinen * @author Lukas Smith (PEAR MDB2 library) * @version $Revision$ * @category Object Relational Mapping * @link www.phpdoctrine.com * @since 1.0 */ 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, $adapter) { $adapter->setAttribute(PDO::ATTR_EMULATE_PREPARES, true); $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, $adapter); } /** * 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); } }