pictcode / lib / Cake / Model / ConnectionManager.php @ 22fd3a57
履歴 | 表示 | アノテート | ダウンロード (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 |
} |