mirror of
https://github.com/kamilwylegala/cakephp2-php8.git
synced 2024-11-16 20:08:24 +00:00
678ec860a1
Fixes issues with saving HABTM git-svn-id: https://svn.cakephp.org/repo/branches/1.2.x.x@3478 3807eeeb-6ff5-0310-8944-8be069107fe0
485 lines
No EOL
10 KiB
PHP
485 lines
No EOL
10 KiB
PHP
<?php
|
|
/* SVN FILE: $Id$ */
|
|
/**
|
|
* DataSource base class
|
|
*
|
|
* Long description for file
|
|
*
|
|
* PHP versions 4 and 5
|
|
*
|
|
* CakePHP : Rapid Development Framework <http://www.cakephp.org/>
|
|
* Copyright (c) 2006, Cake Software Foundation, Inc.
|
|
* 1785 E. Sahara Avenue, Suite 490-204
|
|
* Las Vegas, Nevada 89104
|
|
*
|
|
* Licensed under The MIT License
|
|
* Redistributions of files must retain the above copyright notice.
|
|
*
|
|
* @filesource
|
|
* @copyright Copyright (c) 2006, Cake Software Foundation, Inc.
|
|
* @link http://www.cakefoundation.org/projects/info/cakephp CakePHP Project
|
|
* @package cake
|
|
* @subpackage cake.cake.libs.model.datasources
|
|
* @since CakePHP v 0.10.5.1790
|
|
* @version $Revision$
|
|
* @modifiedby $LastChangedBy$
|
|
* @lastmodified $Date$
|
|
* @license http://www.opensource.org/licenses/mit-license.php The MIT License
|
|
*/
|
|
/**
|
|
* DataSource base class
|
|
*
|
|
* Long description for file
|
|
*
|
|
* @package cake
|
|
* @subpackage cake.cake.libs.model.datasources
|
|
*/
|
|
class DataSource extends Object{
|
|
/**
|
|
* Are we connected to the DataSource?
|
|
*
|
|
* @var boolean
|
|
* @access public
|
|
*/
|
|
var $connected = false;
|
|
/**
|
|
* Print debug info?
|
|
*
|
|
* @var boolean
|
|
* @access public
|
|
*/
|
|
var $debug = false;
|
|
/**
|
|
* Print full query debug info?
|
|
*
|
|
* @var boolean
|
|
* @access public
|
|
*/
|
|
var $fullDebug = false;
|
|
/**
|
|
* Error description of last query
|
|
*
|
|
* @var unknown_type
|
|
* @access public
|
|
*/
|
|
var $error = null;
|
|
/**
|
|
* String to hold how many rows were affected by the last SQL operation.
|
|
*
|
|
* @var string
|
|
* @access public
|
|
*/
|
|
var $affected = null;
|
|
/**
|
|
* Number of rows in current resultset
|
|
*
|
|
* @var int
|
|
* @access public
|
|
*/
|
|
var $numRows = null;
|
|
/**
|
|
* Time the last query took
|
|
*
|
|
* @var int
|
|
* @access public
|
|
*/
|
|
var $took = null;
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @var array
|
|
* @access private
|
|
*/
|
|
var $_result = null;
|
|
/**
|
|
* Queries count.
|
|
*
|
|
* @var int
|
|
* @access private
|
|
*/
|
|
var $_queriesCnt = 0;
|
|
/**
|
|
* Total duration of all queries.
|
|
*
|
|
* @var unknown_type
|
|
* @access private
|
|
*/
|
|
var $_queriesTime = null;
|
|
/**
|
|
* Log of queries executed by this DataSource
|
|
*
|
|
* @var unknown_type
|
|
* @access private
|
|
*/
|
|
var $_queriesLog = array();
|
|
/**
|
|
* Maximum number of items in query log, to prevent query log taking over
|
|
* too much memory on large amounts of queries -- I we've had problems at
|
|
* >6000 queries on one system.
|
|
*
|
|
* @var int Maximum number of queries in the queries log.
|
|
* @access private
|
|
*/
|
|
var $_queriesLogMax = 200;
|
|
/**
|
|
* Caches serialzed results of executed queries
|
|
*
|
|
* @var array Maximum number of queries in the queries log.
|
|
* @access private
|
|
*/
|
|
var $_queryCache = array();
|
|
/**
|
|
* The default configuration of a specific DataSource
|
|
*
|
|
* @var array
|
|
* @access public
|
|
*/
|
|
var $_baseConfig = array();
|
|
/**
|
|
* Holds references to descriptions loaded by the DataSource
|
|
*
|
|
* @var array
|
|
* @access private
|
|
*/
|
|
var $__descriptions = array();
|
|
/**
|
|
* Holds a list of sources (tables) contained in the DataSource
|
|
*
|
|
* @var array
|
|
* @access private
|
|
*/
|
|
var $__sources = null;
|
|
/**
|
|
* A reference to the physical connection of this DataSource
|
|
*
|
|
* @var array
|
|
* @access public
|
|
*/
|
|
var $connection = null;
|
|
/**
|
|
* The DataSource configuration
|
|
*
|
|
* @var array
|
|
* @access public
|
|
*/
|
|
var $config = array();
|
|
/**
|
|
* The DataSource configuration key name
|
|
*
|
|
* @var string
|
|
* @access public
|
|
*/
|
|
var $configKeyName = null;
|
|
/**
|
|
* Whether or not this DataSource is in the middle of a transaction
|
|
*
|
|
* @var boolean
|
|
* @access public
|
|
*/
|
|
var $__transactionStarted = false;
|
|
/**
|
|
* Constructor.
|
|
*/
|
|
function __construct() {
|
|
parent::__construct();
|
|
if (func_num_args() > 0) {
|
|
$this->setConfig(func_get_arg(0));
|
|
}
|
|
}
|
|
/**
|
|
* Returns true if the DataSource supports the given interface (method)
|
|
*
|
|
* @param string $interface The name of the interface (method)
|
|
* @return boolean True on success
|
|
*/
|
|
function isInterfaceSupported($interface) {
|
|
$methods = get_class_methods(get_class($this));
|
|
$methods = strtolower(implode('|', $methods));
|
|
$methods = explode('|', $methods);
|
|
$return = in_array(strtolower($interface), $methods);
|
|
return $return;
|
|
}
|
|
/**
|
|
* Sets the configuration for the DataSource
|
|
*
|
|
* @param array $config The configuration array
|
|
* @return void
|
|
*/
|
|
function setConfig($config) {
|
|
if (is_array($this->_baseConfig)) {
|
|
$this->config = $this->_baseConfig;
|
|
foreach($config as $key => $val) {
|
|
$this->config[$key] = $val;
|
|
}
|
|
}
|
|
}
|
|
/**
|
|
* Cache the DataSource description
|
|
*
|
|
* @param string $object The name of the object (model) to cache
|
|
* @param mixed $data The description of the model, usually a string or array
|
|
* @return void
|
|
*/
|
|
function __cacheDescription($object, $data = null) {
|
|
if (DEBUG > 0) {
|
|
$expires = "+15 seconds";
|
|
} else {
|
|
$expires = "+999 days";
|
|
}
|
|
|
|
if ($data !== null) {
|
|
$this->__descriptions[$object] =& $data;
|
|
$cache = serialize($data);
|
|
} else {
|
|
$cache = null;
|
|
}
|
|
$new = cache('models' . DS . ConnectionManager::getSourceName($this) . '_' . $object, $cache, $expires);
|
|
|
|
if ($new != null) {
|
|
$new = unserialize($new);
|
|
}
|
|
return $new;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @return string
|
|
*/
|
|
function conditions($conditions) {
|
|
return $conditions;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $name
|
|
* @return unknown
|
|
*/
|
|
function name($name) {
|
|
return $name;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $value
|
|
* @return unknown
|
|
*/
|
|
function value($value) {
|
|
return $value;
|
|
}
|
|
/**
|
|
* Returns a Model description (metadata) or null if none found.
|
|
*
|
|
* @param Model $model
|
|
* @return mixed
|
|
*/
|
|
function describe($model) {
|
|
if (isset($this->__descriptions[$model->table])) {
|
|
return $this->__descriptions[$model->table];
|
|
}
|
|
$cache = $this->__cacheDescription($model->tablePrefix.$model->table);
|
|
|
|
if ($cache !== null) {
|
|
$this->__descriptions[$model->table] =& $cache;
|
|
return $cache;
|
|
}
|
|
return null;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $fields
|
|
* @param unknown_type $values
|
|
* @return unknown
|
|
*/
|
|
function create(&$model, $fields = null, $values = null) {
|
|
return false;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $queryData
|
|
* @return unknown
|
|
*/
|
|
function read(&$model, $queryData = array()) {
|
|
return false;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $fields
|
|
* @param unknown_type $values
|
|
* @return unknown
|
|
*/
|
|
function update(&$model, $fields = null, $values = null) {
|
|
return false;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $id
|
|
*/
|
|
function delete(&$model, $id = null) {
|
|
if ($id == null) {
|
|
$id = $model->id;
|
|
}
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param mixed $fields
|
|
* @return mixed
|
|
*/
|
|
function fields($fields) {
|
|
return $fields;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param Model $model
|
|
* @param unknown_type $fields
|
|
* @return unknown
|
|
*/
|
|
function getColumnType(&$model, $fields) {
|
|
return false;
|
|
}
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $query
|
|
* @param unknown_type $data
|
|
* @param unknown_type $association
|
|
* @param unknown_type $assocData
|
|
* @param Model $model
|
|
* @param Model $linkModel
|
|
* @param array $stack
|
|
* @return unknown
|
|
*/
|
|
function insertQueryData($query, $data, $association, $assocData, &$model, &$linkModel, $stack) {
|
|
$keys = array('{$__cakeID__$}', '{$__cakeForeignKey__$}');
|
|
|
|
foreach($keys as $key) {
|
|
$val = null;
|
|
|
|
if (strpos($query, $key) !== false) {
|
|
switch($key) {
|
|
case '{$__cakeID__$}':
|
|
if (isset($data[$model->name]) || isset($data[$association])) {
|
|
if (isset($data[$model->name][$model->primaryKey])) {
|
|
$val = $data[$model->name][$model->primaryKey];
|
|
} elseif (isset($data[$association][$model->primaryKey])) {
|
|
$val = $data[$association][$model->primaryKey];
|
|
}
|
|
} else {
|
|
$found = false;
|
|
foreach (array_reverse($stack) as $assoc) {
|
|
if (isset($data[$assoc]) && isset($data[$assoc][$model->primaryKey])) {
|
|
$val = $data[$assoc][$model->primaryKey];
|
|
$found = true;
|
|
break;
|
|
}
|
|
}
|
|
if (!$found) {
|
|
$val = '';
|
|
}
|
|
}
|
|
break;
|
|
case '{$__cakeForeignKey__$}':
|
|
foreach($model->__associations as $id => $name) {
|
|
foreach($model->$name as $assocName => $assoc) {
|
|
if ($assocName === $association) {
|
|
if (isset($assoc['foreignKey'])) {
|
|
$foreignKey = $assoc['foreignKey'];
|
|
|
|
if (isset($data[$model->name][$foreignKey])) {
|
|
$val = $data[$model->name][$foreignKey];
|
|
} elseif (isset($data[$association][$foreignKey])) {
|
|
$val = $data[$association][$foreignKey];
|
|
} else {
|
|
$found = false;
|
|
foreach (array_reverse($stack) as $assoc) {
|
|
if (isset($data[$assoc]) && isset($data[$assoc][$foreignKey])) {
|
|
$val = $data[$assoc][$foreignKey];
|
|
$found = true;
|
|
break;
|
|
}
|
|
}
|
|
if (!$found) {
|
|
$val = '';
|
|
}
|
|
}
|
|
}
|
|
break 3;
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
if(empty($val)){
|
|
return false;
|
|
}
|
|
$query = r($key, $this->value($val, $model->getColumnType($model->primaryKey)), $query);
|
|
}
|
|
}
|
|
return $query;
|
|
}
|
|
/**
|
|
* To-be-overridden in subclasses.
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $key
|
|
* @return unknown
|
|
*/
|
|
function resolveKey($model, $key) {
|
|
return $model->name . $key;
|
|
}
|
|
/**
|
|
* Gets a value from an array or object.
|
|
* The special {n}, as seen in the Model::generateList method, is taken care of here.
|
|
*
|
|
* @param array $data
|
|
* @param mixed $path As an array, or as a dot-separated string.
|
|
* @return array
|
|
*/
|
|
function getFieldValue($data, $path) {
|
|
if (!is_array($path)) {
|
|
$path = explode('.', $path);
|
|
}
|
|
$tmp = array();
|
|
|
|
foreach($path as $i => $key) {
|
|
if (intval($key) > 0 || $key == '0') {
|
|
if (isset($data[intval($key)])) {
|
|
$data = $data[intval($key)];
|
|
} else {
|
|
return null;
|
|
}
|
|
} elseif ($key == '{n}') {
|
|
foreach($data as $j => $val) {
|
|
$tmp[] = DataSource::getFieldValue($val, array_slice($path, $i + 1));
|
|
}
|
|
return $tmp;
|
|
} else {
|
|
if (isset($data[$key])) {
|
|
$data = $data[$key];
|
|
} else {
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
return $data;
|
|
}
|
|
/**
|
|
* Closes the current datasource.
|
|
*
|
|
*/
|
|
function __destruct() {
|
|
if ($this->connected) {
|
|
$this->close();
|
|
}
|
|
}
|
|
}
|
|
?>
|