1. sfPostgreSQLDatabase.class.php
  2. /**
 * sfPostgreSQLDatabase provides connectivity for the PostgreSQL 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.
 * # port       - [none]      - TCP/IP port on which PostgreSQL is listening.
 *
 * @package    symfony
 * @subpackage database
 * @author     Fabien Potencier 
 * @author     Sean Kerr 
 * @version    SVN: $Id: sfPostgreSQLDatabase.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
 */
  3. class sfPostgreSQLDatabase 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');
  14.     $password = $this->getParameter('password');
  15.     $port     = $this->getParameter('port');
  16.     $username = $this->getParameter('username');
  18.     // construct connection string
  19.     $string = ($database != null ? (' dbname='   .$database) : '').
  20.               ($host != null     ? (' host='     .$host)     : '').
  21.               ($password != null ? (' password=' .$password) : '').
  22.               ($port != null     ? (' port='     .$port)     : '').
  23.               ($username != null ? (' user='     .$username) : '');
  25.     // let's see if we need a persistent connection
  26.     $persistent = $this->getParameter('persistent', false);
  27.     $connect    = $persistent ? 'pg_pconnect' : 'pg_connect';
  29.     $this->connection = @$connect($string);
  31.     // make sure the connection went through
  32.     if ($this->connection === false)
  33.     {
  34.       // the connection's foobar'd
  35.       throw new sfDatabaseException('Failed to create a PostgreSQLDatabase connection.');
  36.     }
  38.     // since we're not an abstraction layer, we copy the connection
  39.     // to the resource
  40.     $this->resource = $this->connection;
  41.   }
  43.   /**
  44.    * Executes the shutdown procedure.
  45.    *
  46.    * @throws <b>sfDatabaseException</b> If an error occurs while shutting down this database
  47.    */
  48.   public function shutdown()
  49.   {
  50.     if ($this->connection != null)
  51.     {
  52.       @pg_close($this->connection);
  53.     }
  54.   }
  55. }
Debug toolbar