1. sfDatabaseManager.class.php
  2. /**
 * sfDatabaseManager allows you to setup your database connectivity before the
 * request is handled. This eliminates the need for a filter to manage database
 * connections.
 *
 * @package    symfony
 * @subpackage database
 * @author     Fabien Potencier 
 * @author     Sean Kerr 
 * @version    SVN: $Id: sfDatabaseManager.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
 */
  3. class sfDatabaseManager
  4. {
  5.   protected
  6.     $configuration = null,
  7.     $databases     = array();
  9.   /**
  10.    * Class constructor.
  11.    *
  12.    * @see initialize()
  13.    */
  14.   public function __construct(sfProjectConfiguration $configuration, $options = array())
  15.   {
  16.     $this->initialize($configuration);
  18.     if (!isset($options['auto_shutdown']) || $options['auto_shutdown'])
  19.     {
  20.       register_shutdown_function(array($this, 'shutdown'));
  21.     }
  22.   }
  24.   /**
  25.    * Initializes this sfDatabaseManager object
  26.    *
  27.    * @param sfProjectConfiguration $configuration A sfProjectConfiguration instance
  28.    *
  29.    * @return bool true, if initialization completes successfully, otherwise false
  30.    *
  31.    * @throws <b>sfInitializationException</b> If an error occurs while initializing this sfDatabaseManager object
  32.    */
  33.   public function initialize(sfProjectConfiguration $configuration)
  34.   {
  35.     $this->configuration = $configuration;
  37.     $this->loadConfiguration();
  38.   }
  40.   /**
  41.    * Loads database configuration.
  42.    */
  43.   public function loadConfiguration()
  44.   {
  45.     if ($this->configuration instanceof sfApplicationConfiguration)
  46.     {
  47.       $databases = include($this->configuration->getConfigCache()->checkConfig('config/databases.yml'));
  48.     }
  49.     else
  50.     {
  51.       $configHandler = new sfDatabaseConfigHandler();
  52.       $databases = $configHandler->evaluate(array($this->configuration->getRootDir().'/config/databases.yml'));
  53.     }
  55.     foreach ($databases as $name => $database)
  56.     {
  57.       $this->setDatabase($name, $database);
  58.     }
  59.   }
  61.   /**
  62.    * Sets a database connection.
  63.    *
  64.    * @param string     $name     The database name
  65.    * @param sfDatabase $database A sfDatabase instance
  66.    */
  67.   public function setDatabase($name, sfDatabase $database)
  68.   {
  69.     $this->databases[$name] = $database;
  70.   }
  72.   /**
  73.    * Retrieves the database connection associated with this sfDatabase implementation.
  74.    *
  75.    * @param string $name A database name
  76.    *
  77.    * @return mixed A Database instance
  78.    *
  79.    * @throws <b>sfDatabaseException</b> If the requested database name does not exist
  80.    */
  81.   public function getDatabase($name = 'default')
  82.   {
  83.     if (isset($this->databases[$name]))
  84.     {
  85.       return $this->databases[$name];
  86.     }
  88.     // nonexistent database name
  89.     throw new sfDatabaseException(sprintf('Database "%s" does not exist.', $name));
  90.   }
  92.   /**
  93.    * Returns the names of all database connections.
  94.    *
  95.    * @return array An array containing all database connection names
  96.    */
  97.   public function getNames()
  98.   {
  99.     return array_keys($this->databases);
  100.   }
  102.   /**
  103.    * Executes the shutdown procedure
  104.    *
  105.    * @return void
  106.    *
  107.    * @throws <b>sfDatabaseException</b> If an error occurs while shutting down this DatabaseManager
  108.    */
  109.   public function shutdown()
  110.   {
  111.     // loop through databases and shutdown connections
  112.     foreach ($this->databases as $database)
  113.     {
  114.       $database->shutdown();
  115.     }
  116.   }
  117. }
Debug toolbar