1. sfPDODatabase.class.php
  2. /**
 * sfPDODatabase provides connectivity for the PDO database abstraction layer.
 *
 * @package    symfony
 * @subpackage database
 * @author     Daniel Swarbrick (daniel@pressure.net.nz)
 * @author     Fabien Potencier 
 * @author     Sean Kerr 
 * @author     Dustin Whittle 
 * @version    SVN: $Id: sfPDODatabase.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
 */
  3. class sfPDODatabase extends sfDatabase
  4. {
  5.   /**
  6.    * Connects to the database.
  7.    *
  8.    * @throws <b>sfDatabaseException</b> If a connection could not be created
  9.    */
  10.   public function connect()
  11.   {
  12.     if (!$dsn = $this->getParameter('dsn'))
  13.     {
  14.       // missing required dsn parameter
  15.       throw new sfDatabaseException('Database configuration is missing the "dsn" parameter.');
  16.     }
  18.     try
  19.     {
  20.       $pdo_class  = $this->getParameter('class', 'PDO');
  21.       $username   = $this->getParameter('username');
  22.       $password   = $this->getParameter('password');
  23.       $persistent = $this->getParameter('persistent');
  25.       $options = ($persistent) ? array(PDO::ATTR_PERSISTENT => true) : array();
  27.       $this->connection = new $pdo_class($dsn, $username, $password, $options);
  29.     }
  30.     catch (PDOException $e)
  31.     {
  32.       throw new sfDatabaseException($e->getMessage());
  33.     }
  35.     // lets generate exceptions instead of silent failures
  36.     if (sfConfig::get('sf_debug'))
  37.     {
  38.       $this->connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  39.     }
  40.     else
  41.     {
  42.       $this->connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
  43.     }
  45.     // compatability
  46.     $compatability = $this->getParameter('compat');
  47.     if ($compatability)
  48.     {
  49.       $this->connection->setAttribute(PDO::ATTR_CASE, PDO::CASE_NATURAL);
  50.     }
  52.     // nulls
  53.     $nulls = $this->getParameter('nulls');
  54.     if ($nulls)
  55.     {
  56.       $this->connection->setAttribute(PDO::ATTR_ORACLE_NULLS, PDO::NULL_EMPTY_STRING);
  57.     }
  59.     // auto commit
  60.     $autocommit = $this->getParameter('autocommit');
  61.     if ($autocommit)
  62.     {
  63.       $this->connection->setAttribute(PDO::ATTR_AUTOCOMMIT, true);
  64.     }
  66.     $this->resource = $this->connection;
  68.   }
  70.   /**
  71.    * Execute the shutdown procedure.
  72.    *
  73.    * @return void
  74.    */
  75.   public function shutdown()
  76.   {
  77.     if ($this->connection !== null)
  78.     {
  79.       @$this->connection = null;
  80.     }
  81.   }
  83.   /**
  84.    * Magic method for calling PDO directly via sfPDODatabase
  85.    *
  86.    * @param string $method
  87.    * @param array $arguments
  88.    * @return mixed
  89.    */
  90.   public function __call($method, $arguments)
  91.   {
  92.     return $this->getConnection()->$method($arguments);
  93.   }
  94. }
Debug toolbar