* @author David Zülke * @copyright Authors * @copyright The Agavi Project * * @since 0.11.0 * * @version $Id$ */ class AgaviDoctrineDatabase extends AgaviDatabase { /** * @var Doctrine_Manager The Doctrine Manager instance we should use. */ protected $doctrineManager; /** * Connect to the database. * * @throws AgaviDatabaseException If a connection could not be * created. * * @author David Zülke * @since 0.11.0 */ public function connect() { // this doesn't do anything, Doctrine is handling the lazy connection stuff } /** * Retrieve a raw database resource associated with this Database * implementation. * * @return mixed A database resource. * * @throws AgaviDatabaseException If no resource could be retrieved * * @author David Zülke * @since 0.11.0 */ public function getResource() { return $this->connection->getDbh(); } /** * Initialize Doctrine set the autoloading * * @param AgaviDatabaseManager The database manager of this instance. * @param array An assoc array of initialization params. * * @author David Zülke * @author Ross Lawley * @since 0.11.0 */ public function initialize(AgaviDatabaseManager $databaseManager, array $parameters = array()) { parent::initialize($databaseManager, $parameters); $name = $this->getName(); // try to autoload doctrine if(!class_exists('Doctrine')) { // okay that didn't work. last resort: include it. we assume it's on the include path by default require('Doctrine.php'); } // in any case, it's loaded now. maybe we need to register the autoloading stuff for it! if(!in_array(array('Doctrine', 'autoload'), spl_autoload_functions())) { // we do spl_autoload_register(array('Doctrine', 'autoload')); } // cool. Assign the Doctrine Manager instance $this->doctrineManager = Doctrine_Manager::getInstance(); // now we're in business. we will set up connections right away, as Doctrine is handling the lazy-connecting stuff for us. // that way, you can just start using classes in your code try { $dsn = $this->getParameter('dsn'); if($dsn === null) { // missing required dsn parameter $error = 'Database configuration specifies method "dsn", but is missing dsn parameter'; throw new AgaviDatabaseException($error); } $this->connection = $this->doctrineManager->openConnection($dsn, $name); // do not assign the resource here. that would connect to the database // $this->resource = $this->connection->getDbh(); foreach((array)$this->getParameter('attributes', array()) as $attributeName => $attributeValue) { $this->connection->setAttribute($attributeName, $attributeValue); } foreach((array)$this->getParameter('bind_components', array()) as $componentName) { $this->doctrineManager->bindComponent($componentName, $name); } } catch(Doctrine_Exception $e) { // the connection's foobar'd throw new AgaviDatabaseException($e->getMessage()); } } /** * Execute the shutdown procedure. * * @throws AgaviDatabaseException If an error occurs while shutting * down this database. * * @author David Zülke * @since 0.11.0 */ public function shutdown() { if($this->connection !== null) { $this->doctrineManager->closeConnection($this->connection); $this->connection = null; $this->resource = null; } } /** * Get the Doctrine Manager instance. * * @return Doctrine_Manager The Doctrine Manager instance. * * @author David Zülke * @since 0.11.0 */ public function getDoctrineManager() { return $this->doctrineManager; } } ?>