1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
<?php
/*
* This file is part of the symfony package.
* (c) 2004-2006 Fabien Potencier <fabien.potencier@symfony-project.com>
* (c) 2004-2006 Sean Kerr <sean@code-box.org>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
/**
* 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 <fabien.potencier@symfony-project.com>
* @author Sean Kerr <sean@code-box.org>
* @version SVN: $Id: sfDatabaseManager.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
*/
class sfDatabaseManager
{
protected
$configuration = null,
$databases = array();
/**
* Class constructor.
*
* @see initialize()
*/
public function __construct(sfProjectConfiguration $configuration, $options = array())
{
$this->initialize($configuration);
if (!isset($options['auto_shutdown']) || $options['auto_shutdown'])
{
register_shutdown_function(array($this, 'shutdown'));
}
}
/**
* Initializes this sfDatabaseManager object
*
* @param sfProjectConfiguration $configuration A sfProjectConfiguration instance
*
* @return bool true, if initialization completes successfully, otherwise false
*
* @throws <b>sfInitializationException</b> If an error occurs while initializing this sfDatabaseManager object
*/
public function initialize(sfProjectConfiguration $configuration)
{
$this->configuration = $configuration;
$this->loadConfiguration();
}
/**
* Loads database configuration.
*/
public function loadConfiguration()
{
if ($this->configuration instanceof sfApplicationConfiguration)
{
$databases = include($this->configuration->getConfigCache()->checkConfig('config/databases.yml'));
}
else
{
$configHandler = new sfDatabaseConfigHandler();
$databases = $configHandler->evaluate(array($this->configuration->getRootDir().'/config/databases.yml'));
}
foreach ($databases as $name => $database)
{
$this->setDatabase($name, $database);
}
}
/**
* Sets a database connection.
*
* @param string $name The database name
* @param sfDatabase $database A sfDatabase instance
*/
public function setDatabase($name, sfDatabase $database)
{
$this->databases[$name] = $database;
}
/**
* Retrieves the database connection associated with this sfDatabase implementation.
*
* @param string $name A database name
*
* @return mixed A Database instance
*
* @throws <b>sfDatabaseException</b> If the requested database name does not exist
*/
public function getDatabase($name = 'default')
{
if (isset($this->databases[$name]))
{
return $this->databases[$name];
}
// nonexistent database name
throw new sfDatabaseException(sprintf('Database "%s" does not exist.', $name));
}
/**
* Returns the names of all database connections.
*
* @return array An array containing all database connection names
*/
public function getNames()
{
return array_keys($this->databases);
}
/**
* Executes the shutdown procedure
*
* @return void
*
* @throws <b>sfDatabaseException</b> If an error occurs while shutting down this DatabaseManager
*/
public function shutdown()
{
// loop through databases and shutdown connections
foreach ($this->databases as $database)
{
$database->shutdown();
}
}
}
|