統計
| ブランチ: | リビジョン:

pictcode / lib / Cake / Model / ConnectionManager.php @ 635eef61

履歴 | 表示 | アノテート | ダウンロード (7.376 KB)

1
<?php
2
/**
3
 * Datasource connection manager
4
 *
5
 * Provides an interface for loading and enumerating connections defined in app/Config/database.php
6
 *
7
 * CakePHP(tm) : Rapid Development Framework (http://cakephp.org)
8
 * Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
9
 *
10
 * Licensed under The MIT License
11
 * For full copyright and license information, please see the LICENSE.txt
12
 * Redistributions of files must retain the above copyright notice.
13
 *
14
 * @copyright     Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
15
 * @link          http://cakephp.org CakePHP(tm) Project
16
 * @package       Cake.Model
17
 * @since         CakePHP(tm) v 0.10.x.1402
18
 * @license       http://www.opensource.org/licenses/mit-license.php MIT License
19
 */
20

    
21
App::uses('DataSource', 'Model/Datasource');
22

    
23
/**
24
 * Manages loaded instances of DataSource objects
25
 *
26
 * Provides an interface for loading and enumerating connections defined in
27
 * app/Config/database.php
28
 *
29
 * @package       Cake.Model
30
 */
31
class ConnectionManager {
32

    
33
/**
34
 * Holds a loaded instance of the Connections object
35
 *
36
 * @var DATABASE_CONFIG
37
 */
38
        public static $config = null;
39

    
40
/**
41
 * Holds instances DataSource objects
42
 *
43
 * @var array
44
 */
45
        protected static $_dataSources = array();
46

    
47
/**
48
 * Contains a list of all file and class names used in Connection settings
49
 *
50
 * @var array
51
 */
52
        protected static $_connectionsEnum = array();
53

    
54
/**
55
 * Indicates if the init code for this class has already been executed
56
 *
57
 * @var bool
58
 */
59
        protected static $_init = false;
60

    
61
/**
62
 * Loads connections configuration.
63
 *
64
 * @return void
65
 */
66
        protected static function _init() {
67
                include_once APP . 'Config' . DS . 'database.php';
68
                if (class_exists('DATABASE_CONFIG')) {
69
                        static::$config = new DATABASE_CONFIG();
70
                }
71
                static::$_init = true;
72
        }
73

    
74
/**
75
 * Gets a reference to a DataSource object
76
 *
77
 * @param string $name The name of the DataSource, as defined in app/Config/database.php
78
 * @return DataSource Instance
79
 * @throws MissingDatasourceException
80
 */
81
        public static function getDataSource($name) {
82
                if (empty(static::$_init)) {
83
                        static::_init();
84
                }
85

    
86
                if (!empty(static::$_dataSources[$name])) {
87
                        return static::$_dataSources[$name];
88
                }
89

    
90
                if (empty(static::$_connectionsEnum[$name])) {
91
                        static::_getConnectionObject($name);
92
                }
93

    
94
                static::loadDataSource($name);
95
                $conn = static::$_connectionsEnum[$name];
96
                $class = $conn['classname'];
97

    
98
                if (strpos(App::location($class), 'Datasource') === false) {
99
                        throw new MissingDatasourceException(array(
100
                                'class' => $class,
101
                                'plugin' => null,
102
                                'message' => 'Datasource is not found in Model/Datasource package.'
103
                        ));
104
                }
105
                static::$_dataSources[$name] = new $class(static::$config->{$name});
106
                static::$_dataSources[$name]->configKeyName = $name;
107

    
108
                return static::$_dataSources[$name];
109
        }
110

    
111
/**
112
 * Gets the list of available DataSource connections
113
 * This will only return the datasources instantiated by this manager
114
 * It differs from enumConnectionObjects, since the latter will return all configured connections
115
 *
116
 * @return array List of available connections
117
 */
118
        public static function sourceList() {
119
                if (empty(static::$_init)) {
120
                        static::_init();
121
                }
122
                return array_keys(static::$_dataSources);
123
        }
124

    
125
/**
126
 * Gets a DataSource name from an object reference.
127
 *
128
 * @param DataSource $source DataSource object
129
 * @return string|null Datasource name, or null if source is not present
130
 *    in the ConnectionManager.
131
 */
132
        public static function getSourceName($source) {
133
                if (empty(static::$_init)) {
134
                        static::_init();
135
                }
136
                foreach (static::$_dataSources as $name => $ds) {
137
                        if ($ds === $source) {
138
                                return $name;
139
                        }
140
                }
141
                return null;
142
        }
143

    
144
/**
145
 * Loads the DataSource class for the given connection name
146
 *
147
 * @param string|array $connName A string name of the connection, as defined in app/Config/database.php,
148
 *    or an array containing the filename (without extension) and class name of the object,
149
 *    to be found in app/Model/Datasource/ or lib/Cake/Model/Datasource/.
150
 * @return bool True on success, null on failure or false if the class is already loaded
151
 * @throws MissingDatasourceException
152
 */
153
        public static function loadDataSource($connName) {
154
                if (empty(static::$_init)) {
155
                        static::_init();
156
                }
157

    
158
                if (is_array($connName)) {
159
                        $conn = $connName;
160
                } else {
161
                        $conn = static::$_connectionsEnum[$connName];
162
                }
163

    
164
                if (class_exists($conn['classname'], false)) {
165
                        return false;
166
                }
167

    
168
                $plugin = $package = null;
169
                if (!empty($conn['plugin'])) {
170
                        $plugin = $conn['plugin'] . '.';
171
                }
172
                if (!empty($conn['package'])) {
173
                        $package = '/' . $conn['package'];
174
                }
175

    
176
                App::uses($conn['classname'], $plugin . 'Model/Datasource' . $package);
177
                if (!class_exists($conn['classname'])) {
178
                        throw new MissingDatasourceException(array(
179
                                'class' => $conn['classname'],
180
                                'plugin' => substr($plugin, 0, -1)
181
                        ));
182
                }
183
                return true;
184
        }
185

    
186
/**
187
 * Returns a list of connections
188
 *
189
 * @return array An associative array of elements where the key is the connection name
190
 *    (as defined in Connections), and the value is an array with keys 'filename' and 'classname'.
191
 */
192
        public static function enumConnectionObjects() {
193
                if (empty(static::$_init)) {
194
                        static::_init();
195
                }
196
                return (array)static::$config;
197
        }
198

    
199
/**
200
 * Dynamically creates a DataSource object at runtime, with the given name and settings
201
 *
202
 * @param string $name The DataSource name
203
 * @param array $config The DataSource configuration settings
204
 * @return DataSource|null A reference to the DataSource object, or null if creation failed
205
 */
206
        public static function create($name = '', $config = array()) {
207
                if (empty(static::$_init)) {
208
                        static::_init();
209
                }
210

    
211
                if (empty($name) || empty($config) || array_key_exists($name, static::$_connectionsEnum)) {
212
                        return null;
213
                }
214
                static::$config->{$name} = $config;
215
                static::$_connectionsEnum[$name] = static::_connectionData($config);
216
                $return = static::getDataSource($name);
217
                return $return;
218
        }
219

    
220
/**
221
 * Removes a connection configuration at runtime given its name
222
 *
223
 * @param string $name the connection name as it was created
224
 * @return bool success if connection was removed, false if it does not exist
225
 */
226
        public static function drop($name) {
227
                if (empty(static::$_init)) {
228
                        static::_init();
229
                }
230

    
231
                if (!isset(static::$config->{$name})) {
232
                        return false;
233
                }
234
                unset(static::$_connectionsEnum[$name], static::$_dataSources[$name], static::$config->{$name});
235
                return true;
236
        }
237

    
238
/**
239
 * Gets a list of class and file names associated with the user-defined DataSource connections
240
 *
241
 * @param string $name Connection name
242
 * @return void
243
 * @throws MissingDatasourceConfigException
244
 */
245
        protected static function _getConnectionObject($name) {
246
                if (!empty(static::$config->{$name})) {
247
                        static::$_connectionsEnum[$name] = static::_connectionData(static::$config->{$name});
248
                } else {
249
                        throw new MissingDatasourceConfigException(array('config' => $name));
250
                }
251
        }
252

    
253
/**
254
 * Returns the file, class name, and parent for the given driver.
255
 *
256
 * @param array $config Array with connection configuration. Key 'datasource' is required
257
 * @return array An indexed array with: filename, classname, plugin and parent
258
 */
259
        protected static function _connectionData($config) {
260
                $package = $classname = $plugin = null;
261

    
262
                list($plugin, $classname) = pluginSplit($config['datasource']);
263
                if (strpos($classname, '/') !== false) {
264
                        $package = dirname($classname);
265
                        $classname = basename($classname);
266
                }
267
                return compact('package', 'classname', 'plugin');
268
        }
269

    
270
}