1. sfMySQLDatabase.class.php
  2. /**
 * sfMySQLDatabase provides connectivity for the MySQL brand database.
 *
 * Optional parameters:
 *
 * # database   - [none]      - The database name.
 * # host       - [localhost] - The database host.
 * # username   - [none]      - The database username.
 * # password   - [none]      - The database password.
 * # persistent - [No]        - Indicates that the connection should be persistent.
 *
 * @package    symfony
 * @subpackage database
 * @author     Fabien Potencier 
 * @author     Sean Kerr 
 * @version    SVN: $Id: sfMySQLDatabase.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
 */
  3. class sfMySQLDatabase 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.     $database = $this->getParameter('database');
  13.     $host     = $this->getParameter('host', 'localhost');
  14.     $password = $this->getParameter('password');
  15.     $username = $this->getParameter('username');
  16.     $encoding = $this->getParameter('encoding');
  18.     // let's see if we need a persistent connection
  19.     $connect = $this->getConnectMethod($this->getParameter('persistent', false));
  20.     if ($password == null)
  21.     {
  22.       if ($username == null)
  23.       {
  24.         $this->connection = @$connect($host);
  25.       }
  26.       else
  27.       {
  28.         $this->connection = @$connect($host, $username);
  29.       }
  30.     }
  31.     else
  32.     {
  33.       $this->connection = @$connect($host, $username, $password);
  34.     }
  36.     // make sure the connection went through
  37.     if ($this->connection === false)
  38.     {
  39.       // the connection's foobar'd
  40.       throw new sfDatabaseException('Failed to create a MySQLDatabase connection.');
  41.     }
  43.     // select our database
  44.     if ($this->selectDatabase($database))
  45.     {
  46.       // can't select the database
  47.       throw new sfDatabaseException(sprintf('Failed to select MySQLDatabase "%s".', $database));
  48.     }
  50.     // set encoding if specified
  51.     if ($encoding)
  52.     {
  53.       @mysql_query("SET NAMES '".$encoding."'", $this->connection);
  54.     }
  56.     // since we're not an abstraction layer, we copy the connection
  57.     // to the resource
  58.     $this->resource = $this->connection;
  59.   }
  61.   /**
  62.    * Returns the appropriate connect method.
  63.    * 
  64.    * @param bool $persistent wether persistent connections are use or not
  65.    * @return string name of connect method.
  66.    */
  67.   protected function getConnectMethod($persistent)
  68.   {
  69.     return $persistent ? 'mysql_pconnect' : 'mysql_connect';
  70.   }
  71.   
  72.   /**
  73.    * Selects the database to be used in this connection
  74.    * 
  75.    * @param string $database Name of database to be connected
  76.    *
  77.    * @return bool true if this was successful
  78.    */
  79.   protected function selectDatabase($database)
  80.   {
  81.    return ($database != null && !@mysql_select_db($database, $this->connection));
  82.   }
  84.   /**
  85.    * Execute the shutdown procedure
  86.    *
  87.    * @return void
  88.    *
  89.    * @throws <b>sfDatabaseException</b> If an error occurs while shutting down this database
  90.    */
  91.   public function shutdown()
  92.   {
  93.     if ($this->connection != null)
  94.     {
  95.       @mysql_close($this->connection);
  96.     }
  97.   }
  98. }
Debug toolbar