mirror of
https://github.com/kamilwylegala/cakephp2-php8.git
synced 2025-01-19 11:06:15 +00:00
3984795205
Revision: [1829] Fixing AjaxHelper::form() Revision: [1828] Added check to return false is passing an empty string to requestAction(), method would seg fault if param was empty. Fixing another problem found when passing fields to the model methods. git-svn-id: https://svn.cakephp.org/repo/trunk/cake@1830 3807eeeb-6ff5-0310-8944-8be069107fe0
1038 lines
No EOL
30 KiB
PHP
1038 lines
No EOL
30 KiB
PHP
<?php
|
|
/* SVN FILE: $Id$ */
|
|
|
|
/**
|
|
* Short description for file.
|
|
*
|
|
* Long description for file
|
|
*
|
|
* PHP versions 4 and 5
|
|
*
|
|
* CakePHP : Rapid Development Framework <http://www.cakephp.org/>
|
|
* Copyright (c) 2005, 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) 2005, 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.0.1076
|
|
* @version $Revision$
|
|
* @modifiedby $LastChangedBy$
|
|
* @lastmodified $Date$
|
|
* @license http://www.opensource.org/licenses/mit-license.php The MIT License
|
|
*/
|
|
|
|
/**
|
|
* Include DataSource base class
|
|
*
|
|
*/
|
|
uses('model'.DS.'datasources'.DS.'datasource');
|
|
|
|
/**
|
|
* DboSource
|
|
*
|
|
* Creates DBO-descendant objects from a given db connection configuration
|
|
*
|
|
* @package cake
|
|
* @subpackage cake.cake.libs.model.datasources
|
|
* @since CakePHP v 0.10.0.1076
|
|
*
|
|
*/
|
|
class DboSource extends DataSource
|
|
{
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @var unknown_type
|
|
*/
|
|
var $description = "Database Data Source";
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @var unknown_type
|
|
*/
|
|
var $__bypass = false;
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @var unknown_type
|
|
*/
|
|
var $__assocJoins = null;
|
|
/**
|
|
* Constructor
|
|
*
|
|
*/
|
|
function __construct($config = null)
|
|
{
|
|
$this->debug = DEBUG > 0;
|
|
$this->fullDebug = DEBUG > 1;
|
|
parent::__construct($config);
|
|
return $this->connect();
|
|
}
|
|
|
|
/**
|
|
* Prepares a value, or an array of values for database queries by quoting and escaping them.
|
|
*
|
|
* @param mixed $data A value or an array of values to prepare.
|
|
* @return mixed Prepared value or array of values.
|
|
*/
|
|
function value ($data, $column = null)
|
|
{
|
|
if (is_array($data))
|
|
{
|
|
$out = array();
|
|
foreach ($data as $key => $item)
|
|
{
|
|
$out[$key] = $this->value($item);
|
|
}
|
|
return $out;
|
|
}
|
|
else
|
|
{
|
|
return null;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @return unknown
|
|
*/
|
|
function sources ()
|
|
{
|
|
return array_map('strtolower', $this->listSources());
|
|
}
|
|
|
|
/**
|
|
* Executes given SQL statement.
|
|
*
|
|
* @param string $sql SQL statement
|
|
* @return unknown
|
|
*/
|
|
function rawQuery ($sql)
|
|
{
|
|
$this->took = $this->error = $this->numRows = false;
|
|
return $this->execute($sql);
|
|
}
|
|
|
|
/**
|
|
* Queries the database with given SQL statement, and obtains some metadata about the result
|
|
* (rows affected, timing, any errors, number of rows in resultset). The query is also logged.
|
|
* If DEBUG is set, the log is shown all the time, else it is only shown on errors.
|
|
*
|
|
* @param string $sql
|
|
* @return unknown
|
|
*/
|
|
function execute($sql)
|
|
{
|
|
$t = getMicrotime();
|
|
$this->_result = $this->_execute($sql);
|
|
|
|
$this->affected = $this->lastAffected();
|
|
$this->took = round((getMicrotime() - $t) * 1000, 0);
|
|
$this->error = $this->lastError();
|
|
$this->numRows = $this->lastNumRows($this->_result);
|
|
$this->logQuery($sql);
|
|
|
|
if ($this->error)
|
|
{
|
|
return false;
|
|
}
|
|
else
|
|
{
|
|
return $this->_result;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns a single row of results from the _last_ SQL query.
|
|
*
|
|
* @param resource $res
|
|
* @return array A single row of results
|
|
*/
|
|
function fetchArray ($assoc=false)
|
|
{
|
|
if ($assoc === false)
|
|
{
|
|
return $this->fetchRow();
|
|
}
|
|
else
|
|
{
|
|
return $this->fetchRow($assoc);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns a single row of results for a _given_ SQL query.
|
|
*
|
|
* @param string $sql SQL statement
|
|
* @return array A single row of results
|
|
*/
|
|
function one ($sql)
|
|
{
|
|
if ($this->execute($sql))
|
|
{
|
|
return $this->fetchArray();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Returns an array of all result rows for a given SQL query.
|
|
* Returns false if no rows matched.
|
|
*
|
|
* @param string $sql SQL statement
|
|
* @return array Array of resultset rows, or false if no rows matched
|
|
*/
|
|
function fetchAll ($sql)
|
|
{
|
|
if($this->execute($sql))
|
|
{
|
|
$out = array();
|
|
while ($item = $this->fetchArray(null, true))
|
|
{
|
|
$out[] = $item;
|
|
}
|
|
return $out;
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns a single field of the first of query results for a given SQL query, or false if empty.
|
|
*
|
|
* @param string $name Name of the field
|
|
* @param string $sql SQL query
|
|
* @return unknown
|
|
*/
|
|
function field ($name, $sql)
|
|
{
|
|
$data = $this->one($sql);
|
|
if (empty($data[$name]))
|
|
{
|
|
return false;
|
|
}
|
|
else
|
|
{
|
|
return $data[$name];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Checks if it's connected to the database
|
|
*
|
|
* @return boolean True if the database is connected, else false
|
|
*/
|
|
function isConnected()
|
|
{
|
|
return $this->connected;
|
|
}
|
|
|
|
/**
|
|
* Outputs the contents of the log.
|
|
*
|
|
* @param boolean $sorted
|
|
*/
|
|
function showLog($sorted=false)
|
|
{
|
|
$log = $sorted?
|
|
sortByKey($this->_queriesLog, 'took', 'desc', SORT_NUMERIC):
|
|
$this->_queriesLog;
|
|
|
|
if($this->_queriesCnt >1)
|
|
{
|
|
$text = 'queries';
|
|
}
|
|
else
|
|
{
|
|
$text = 'query';
|
|
}
|
|
print("<table border=1>\n<tr><th colspan=7>{$this->_queriesCnt} {$text} took {$this->_queriesTime} ms</th></tr>\n");
|
|
print("<tr><td>Nr</td><td>Query</td><td>Error</td><td>Affected</td><td>Num. rows</td><td>Took (ms)</td></tr>\n");
|
|
|
|
foreach($log AS $k=>$i)
|
|
{
|
|
print("<tr><td>".($k+1)."</td><td>{$i['query']}</td><td>{$i['error']}</td><td align='right'>{$i['affected']}</td><td align='right'>{$i['numRows']}</td><td align='right'>{$i['took']}</td></tr>\n");
|
|
}
|
|
|
|
print("</table>\n");
|
|
}
|
|
|
|
/**
|
|
* Log given SQL query.
|
|
*
|
|
* @param string $sql SQL statement
|
|
*/
|
|
function logQuery($sql)
|
|
{
|
|
$this->_queriesCnt++;
|
|
$this->_queriesTime += $this->took;
|
|
|
|
$this->_queriesLog[] = array(
|
|
'query' => $sql,
|
|
'error' => $this->error,
|
|
'affected' => $this->affected,
|
|
'numRows' => $this->numRows,
|
|
'took' => $this->took
|
|
);
|
|
|
|
if (count($this->_queriesLog) > $this->_queriesLogMax)
|
|
{
|
|
array_pop($this->_queriesLog);
|
|
}
|
|
|
|
if ($this->error)
|
|
{
|
|
return false; // shouldn't we be logging errors somehow?
|
|
// TODO: Add hook to error log
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Output information about an SQL query. The SQL statement, number of rows in resultset,
|
|
* and execution time in microseconds. If the query fails, and error is output instead.
|
|
*
|
|
* @param string $sql
|
|
*/
|
|
function showQuery($sql)
|
|
{
|
|
$error = $this->error;
|
|
|
|
if (strlen($sql)>200 && !$this->fullDebug)
|
|
{
|
|
$sql = substr($sql, 0, 200) .'[...]';
|
|
}
|
|
|
|
if ($this->debug || $error)
|
|
{
|
|
print("<p style=\"text-align:left\"><b>Query:</b> {$sql} <small>[Aff:{$this->affected} Num:{$this->numRows} Took:{$this->took}ms]</small>");
|
|
if($error)
|
|
{
|
|
print("<br /><span style=\"color:Red;text-align:left\"><b>ERROR:</b> {$this->error}</span>");
|
|
}
|
|
print('</p>');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $fields
|
|
* @param unknown_type $values
|
|
* @return unknown
|
|
*/
|
|
function create(&$model, $fields = null, $values = null)
|
|
{
|
|
if ($fields == null)
|
|
{
|
|
unset($fields, $values);
|
|
$fields = array_keys($model->data);
|
|
$values = array_values($model->data);
|
|
}
|
|
|
|
foreach ($values as $value)
|
|
{
|
|
$valueInsert[] = $this->value($value);
|
|
}
|
|
|
|
if($this->execute('INSERT INTO '.$model->table.' ('.join(',', $fields).') VALUES ('.join(',', $valueInsert).')'))
|
|
{
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $queryData
|
|
* @param unknown_type $recursive
|
|
* @return unknown
|
|
*/
|
|
function read (&$model, $queryData = array(), $recursive = 1)
|
|
{
|
|
$this->__scrubQueryData($queryData);
|
|
$null = null;
|
|
$array = array();
|
|
$linkedModels = array();
|
|
$this->__bypass = false;
|
|
|
|
if(!empty($queryData['fields']))
|
|
{
|
|
$this->__bypass = true;
|
|
}
|
|
|
|
if ($recursive > 0)
|
|
{
|
|
foreach($model->__associations as $type)
|
|
{
|
|
foreach($model->{$type} as $assoc => $assocData)
|
|
{
|
|
$linkModel =& $model->{$assocData['className']};
|
|
if($model->name == $linkModel->name)
|
|
{
|
|
if (true === $this->generateSelfAssociationQuery($model, $linkModel, $type, $assoc, $assocData, $queryData, false, $null))
|
|
{
|
|
$linkedModels[] = $type.$assoc;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (true === $this->generateAssociationQuery($model, $linkModel, $type, $assoc, $assocData, $queryData, false, $null))
|
|
{
|
|
$linkedModels[] = $type.$assoc;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// Build final query SQL
|
|
$query = $this->generateAssociationQuery($model, $null, null, null, null, $queryData, false, $null);
|
|
$resultSet = $this->fetchAll($query);
|
|
|
|
if ($recursive > 0)
|
|
{
|
|
foreach($model->__associations as $type)
|
|
{
|
|
foreach($model->{$type} as $assoc => $assocData)
|
|
{
|
|
if (!in_array($type.$assoc, $linkedModels))
|
|
{
|
|
$linkModel =& $model->{$assocData['className']};
|
|
$this->queryAssociation($model, $linkModel, $type, $assoc, $assocData, $array, true, $resultSet, $recursive - 1);
|
|
//if ($recursive > 1)
|
|
//{
|
|
// $linkModel =& $model->{$assocData['className']};
|
|
// foreach($linkModel->__associations as $type1)
|
|
// {
|
|
// foreach($linkModel->{$type1} as $assoc1 => $assocData1)
|
|
// {
|
|
// $deepModel =& $linkModel->{$assocData1['className']};
|
|
// $this->queryAssociation($linkModel, $deepModel, $type1, $assoc1, $assocData, $array, true, $resultSet, $recursive - 1);
|
|
// }
|
|
// }
|
|
//}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return $resultSet;
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $linkModel
|
|
* @param unknown_type $type
|
|
* @param unknown_type $association
|
|
* @param unknown_type $assocData
|
|
* @param unknown_type $queryData
|
|
* @param unknown_type $external
|
|
* @param unknown_type $resultSet
|
|
* @param unknown_type $recursive
|
|
*/
|
|
function queryAssociation(&$model, &$linkModel, $type, $association, $assocData, &$queryData, $external = false, &$resultSet, $recursive = 1)
|
|
{
|
|
//$external = (($linkModel->db === $this) && $resultSet == null);
|
|
|
|
$query = $this->generateAssociationQuery($model, $linkModel, $type, $association, $assocData, $queryData, $external, $resultSet);
|
|
if ($query)
|
|
{
|
|
foreach ($resultSet as $i => $row)
|
|
{
|
|
$q = $this->insertQueryData($query, $resultSet, $association, $assocData, $model, $linkModel, $i);
|
|
$fetch = $this->fetchAll($q);
|
|
|
|
if (!empty($fetch) && is_array($fetch))
|
|
{
|
|
if (isset($fetch[0][$association]))
|
|
{
|
|
foreach ($fetch as $j => $row)
|
|
{
|
|
$resultSet[$i][$association][$j] = $row[$association];
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$plural = Inflector::pluralize($association);
|
|
foreach ($fetch as $j => $row)
|
|
{
|
|
$resultSet[$i][$plural][$j] = $row[$plural];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $linkModel
|
|
* @param unknown_type $type
|
|
* @param unknown_type $association
|
|
* @param unknown_type $assocData
|
|
* @param unknown_type $queryData
|
|
* @param unknown_type $external
|
|
* @param unknown_type $resultSet
|
|
* @return unknown
|
|
*/
|
|
function generateSelfAssociationQuery(&$model, &$linkModel, $type, $association = null, $assocData = array(), &$queryData, $external = false, &$resultSet)
|
|
{
|
|
$alias = $association;
|
|
if(!isset($queryData['selfJoin']))
|
|
{
|
|
$queryData['selfJoin'] = array();
|
|
|
|
$sql = 'SELECT ' . join(', ', $this->fields($model, $model->name, $queryData['fields'])). ', ';
|
|
$sql .= join(', ', $this->fields($linkModel, $alias, ''));
|
|
$sql .= ' FROM '.$model->table.' AS ' . $model->name;
|
|
$sql .= ' LEFT JOIN '.$linkModel->table.' AS ' . $alias;
|
|
$sql .= ' ON ';
|
|
$sql .= $this->name($model->name).'.'.$this->name($assocData['foreignKey']);
|
|
$sql .= ' = '.$this->name($alias).'.'.$this->name($linkModel->primaryKey);
|
|
if (!in_array($sql, $queryData['selfJoin']))
|
|
{
|
|
$queryData['selfJoin'][] = $sql;
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if(isset($this->__assocJoins))
|
|
{
|
|
$replace = ', ';
|
|
$replace .= join(', ', $this->__assocJoins['fields']);
|
|
$replace .= ' FROM';
|
|
}
|
|
else
|
|
{
|
|
$replace = 'FROM';
|
|
}
|
|
$sql = $queryData['selfJoin'][0];
|
|
$sql .= ' ' . join(' ', $queryData['joins']);
|
|
$sql .= $this->conditions($queryData['conditions']).' '.$this->order($queryData['order']);
|
|
$sql .= ' '.$this->limit($queryData['limit']);
|
|
$result = preg_replace('/FROM/', $replace, $sql);
|
|
return $result;
|
|
}
|
|
}
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $linkModel
|
|
* @param unknown_type $type
|
|
* @param unknown_type $association
|
|
* @param unknown_type $assocData
|
|
* @param unknown_type $queryData
|
|
* @param unknown_type $external
|
|
* @param unknown_type $resultSet
|
|
* @return unknown
|
|
*/
|
|
function generateAssociationQuery(&$model, &$linkModel, $type, $association = null, $assocData = array(), &$queryData, $external = false, &$resultSet)
|
|
{
|
|
$this->__scrubQueryData($queryData);
|
|
$joinedOnSelf = false;
|
|
if ($linkModel == null)
|
|
{
|
|
if(array_key_exists('selfJoin', $queryData))
|
|
{
|
|
return $this->generateSelfAssociationQuery($model, $linkModel, $type, $association, $assocData, $queryData, $external, $resultSet);
|
|
}
|
|
else
|
|
{
|
|
if(isset($this->__assocJoins))
|
|
{
|
|
$joinFields = ', ';
|
|
$joinFields .= join(', ', $this->__assocJoins['fields']);
|
|
}
|
|
else
|
|
{
|
|
$joinFields = null;
|
|
}
|
|
// Generates primary query
|
|
$sql = 'SELECT ' . join(', ', $this->fields($model, $model->name, $queryData['fields'])) .$joinFields. ' FROM ';
|
|
$sql .= $this->name($model->table).' AS ';
|
|
$sql .= $this->name($model->name).' ' . join(' ', $queryData['joins']).' ';
|
|
$sql .= $this->conditions($queryData['conditions']).' '.$this->order($queryData['order']);
|
|
$sql .= ' '.$this->limit($queryData['limit']);
|
|
}
|
|
return $sql;
|
|
}
|
|
|
|
$alias = $association;
|
|
if($model->name == $linkModel->name)
|
|
{
|
|
$joinedOnSelf = true;
|
|
}
|
|
|
|
switch ($type)
|
|
{
|
|
case 'hasOne':
|
|
if ($external)
|
|
{
|
|
if ($assocData['finderQuery'])
|
|
{
|
|
return $assocData['finderQuery'];
|
|
}
|
|
$sql = 'SELECT '.join(', ', $this->fields($linkModel, $alias, $assocData['fields']));
|
|
$sql .= ' FROM '.$this->name($linkModel->table).' AS '.$alias;
|
|
$conditions = $queryData['conditions'];
|
|
$condition = $model->escapeField($assocData['foreignKey']);
|
|
$condition .= '={$__cake_foreignKey__$}';
|
|
if (is_array($conditions))
|
|
{
|
|
$conditions[] = $condition;
|
|
}
|
|
else
|
|
{
|
|
if (trim($conditions) != '')
|
|
{
|
|
$conditions .= ' AND ';
|
|
}
|
|
$conditions .= $condition;
|
|
}
|
|
$sql .= $this->conditions($queryData['conditions']) . $this->order($queryData['order']);
|
|
$sql .= $this->limit($queryData['limit']);
|
|
return $sql;
|
|
}
|
|
else if($joinedOnSelf != true)
|
|
{
|
|
if(!isset($assocData['fields']))
|
|
{
|
|
$assocData['fields'] = '';
|
|
}
|
|
if($this->__bypass === false)
|
|
{
|
|
$fields = join(', ', $this->fields($linkModel, $alias, $assocData['fields']));
|
|
$this->__assocJoins['fields'][] = $fields;
|
|
}
|
|
else
|
|
{
|
|
$this->__assocJoins = null;
|
|
}
|
|
$sql = ' LEFT JOIN '.$this->name($linkModel->table);
|
|
$sql .= ' AS '.$this->name($alias).' ON '.$this->name($alias).'.';
|
|
$sql .= $this->name($assocData['foreignKey']).'='.$model->escapeField($model->primaryKey);
|
|
$sql .= $this->order($assocData['order']);
|
|
if (!in_array($sql, $queryData['joins']))
|
|
{
|
|
$queryData['joins'][] = $sql;
|
|
}
|
|
return true;
|
|
}
|
|
break;
|
|
case 'belongsTo':
|
|
if ($external)
|
|
{
|
|
pr('external');
|
|
$conditions = $assocData['conditions'];
|
|
$sql = 'SELECT * FROM '.$this->name($linkModel->table).' AS '.$this->name($alias);
|
|
|
|
$condition = $linkModel->escapeField($assocData['foreignKey']);
|
|
$condition .= '={$__cake_id__$}';
|
|
if (is_array($conditions))
|
|
{
|
|
$conditions[] = $condition;
|
|
}
|
|
else
|
|
{
|
|
if (trim($conditions) != '')
|
|
{
|
|
$conditions .= ' AND ';
|
|
}
|
|
$conditions .= $condition;
|
|
}
|
|
$sql .= $this->conditions($queryData['conditions']) . $this->order($queryData['order']);
|
|
$sql .= $this->limit($queryData['limit']);
|
|
return $sql;
|
|
}
|
|
else if($joinedOnSelf != true)
|
|
{
|
|
if(!isset($assocData['fields']))
|
|
{
|
|
$assocData['fields'] = '';
|
|
}
|
|
if($this->__bypass === false)
|
|
{
|
|
$fields = join(', ', $this->fields($linkModel, $alias, $assocData['fields']));
|
|
$this->__assocJoins['fields'][] = $fields;
|
|
}
|
|
else
|
|
{
|
|
$this->__assocJoins = null;
|
|
}
|
|
$sql = ' LEFT JOIN '.$this->name($linkModel->table);
|
|
$sql .= ' AS ' . $this->name($alias) . ' ON ';
|
|
$sql .= $this->name($model->name).'.'.$this->name($assocData['foreignKey']);
|
|
$sql .= '='.$this->name($alias).'.'.$this->name($linkModel->primaryKey);
|
|
if (!in_array($sql, $queryData['joins']))
|
|
{
|
|
$queryData['joins'][] = $sql;
|
|
}
|
|
return true;
|
|
}
|
|
break;
|
|
case 'hasMany':
|
|
if(isset($assocData['finderQuery']) && $assocData['finderQuery'] != null)
|
|
{
|
|
$sql = $assocData['finderQuery'];
|
|
}
|
|
else
|
|
{
|
|
$conditions = $assocData['conditions'];
|
|
$sql = 'SELECT '.join(', ', $this->fields($linkModel, $alias, $assocData['fields']));
|
|
$sql .= ' FROM '.$this->name($linkModel->table).' AS '. $this->name($alias);
|
|
|
|
$cond = $this->name($alias).'.'.$this->name($assocData['foreignKey']);
|
|
$cond .= '={$__cake_id__$}';
|
|
if (is_array($conditions))
|
|
{
|
|
$conditions[] = $cond;
|
|
}
|
|
else
|
|
{
|
|
if (trim($conditions) != '')
|
|
{
|
|
$conditions .= ' AND ';
|
|
}
|
|
$conditions .= $cond;
|
|
}
|
|
|
|
$sql .= $this->conditions($conditions);
|
|
$sql .= $this->order($assocData['order']);
|
|
}
|
|
return $sql;
|
|
break;
|
|
case 'hasAndBelongsToMany':
|
|
if(isset($assocData['finderQuery']) && $assocData['finderQuery'] != null)
|
|
{
|
|
$sql = $assocData['finderQuery'];
|
|
}
|
|
else
|
|
{
|
|
$joinTbl = $this->name($assocData['joinTable']);
|
|
|
|
$sql = 'SELECT '.join(', ', $this->fields($linkModel, $alias, $assocData['fields']));
|
|
$sql .= ' FROM '.$this->name($linkModel->table).' AS '.$this->name($alias);
|
|
$sql .= ' JOIN '.$joinTbl.' ON '.$joinTbl;
|
|
$sql .= '.'.$this->name($assocData['foreignKey']).'={$__cake_id__$}';
|
|
$sql .= ' AND '.$joinTbl.'.'.$this->name($assocData['associationForeignKey']);
|
|
$sql .= ' = '.$this->name($alias).'.'.$this->name($linkModel->primaryKey);
|
|
|
|
$sql .= $this->conditions($assocData['conditions']);
|
|
$sql .= $this->order($assocData['order']);
|
|
}
|
|
return $sql;
|
|
break;
|
|
}
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $fields
|
|
* @param unknown_type $values
|
|
* @return unknown
|
|
*/
|
|
function update (&$model, $fields = null, $values = null)
|
|
{
|
|
$updates = array();
|
|
foreach (array_combine($fields, $values) as $field => $value)
|
|
{
|
|
$updates[] = $this->name($field).'='.$this->value($value);
|
|
}
|
|
|
|
$sql = 'UPDATE '.$this->name($model->table);
|
|
$sql .= ' SET '.join(',', $updates);
|
|
$sql .= ' WHERE '.$this->name($model->primaryKey).'='.$this->value($model->getID());
|
|
|
|
return $this->execute($sql);
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $id
|
|
* @return unknown
|
|
*/
|
|
function delete (&$model, $id = null)
|
|
{
|
|
$_id = $model->id;
|
|
if ($id != null)
|
|
{
|
|
$model->id = $id;
|
|
}
|
|
if (!is_array($model->id))
|
|
{
|
|
$model->id = array($model->id);
|
|
}
|
|
foreach ($model->id as $id)
|
|
{
|
|
$result = $this->execute('DELETE FROM '.$this->name($model->table).' WHERE '.$this->name($model->primaryKey).'='.$this->value($id));
|
|
}
|
|
if ($result)
|
|
{
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $key
|
|
* @param unknown_type $assoc
|
|
* @return unknown
|
|
*/
|
|
function resolveKey($model, $key, $assoc = null)
|
|
{
|
|
if ($assoc == null)
|
|
{
|
|
$assoc = $model->name;
|
|
}
|
|
|
|
if (!strpos('.', $key))
|
|
{
|
|
return $this->name($model->table).'.'.$this->name($key);
|
|
}
|
|
return $key;
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $field
|
|
*/
|
|
function getColumnType (&$model, $field)
|
|
{
|
|
$columns = $model->loadInfo();
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $data
|
|
*/
|
|
function __scrubQueryData(&$data)
|
|
{
|
|
if (!isset($data['conditions']))
|
|
{
|
|
$data['conditions'] = ' 1 ';
|
|
}
|
|
if (!isset($data['fields']))
|
|
{
|
|
$data['fields'] = '';
|
|
}
|
|
if (!isset($data['joins']))
|
|
{
|
|
$data['joins'] = array();
|
|
}
|
|
if (!isset($data['order']))
|
|
{
|
|
$data['order'] = '';
|
|
}
|
|
if (!isset($data['limit']))
|
|
{
|
|
$data['limit'] = '';
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $model
|
|
* @param unknown_type $alias
|
|
* @param unknown_type $fields
|
|
* @return unknown
|
|
*/
|
|
function fields (&$model, $alias, $fields)
|
|
{
|
|
if (is_array($fields))
|
|
{
|
|
$fields = $fields;
|
|
}
|
|
else
|
|
{
|
|
if ($fields != null)
|
|
{
|
|
if (strpos($fields, ','))
|
|
{
|
|
$fields = explode(',', $fields);
|
|
}
|
|
else
|
|
{
|
|
$fields = array($fields);
|
|
}
|
|
$fields = array_map('trim', $fields);
|
|
}
|
|
else
|
|
{
|
|
foreach ($model->_tableInfo->value as $field)
|
|
{
|
|
$fields[]= $field['name'];
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
if (count($fields) > 1 && $fields[0] != '*')
|
|
{
|
|
for ($i = 0; $i < count($fields); $i++)
|
|
{
|
|
$fields[$i] = $this->name($alias).'.'.$this->name($fields[$i]);
|
|
}
|
|
}
|
|
return $fields;
|
|
}
|
|
|
|
/**
|
|
* Parses conditions array (or just passes it if it's a string)
|
|
*
|
|
* @param unknown_type $conditions
|
|
* @return string
|
|
*/
|
|
function conditions ($conditions)
|
|
{
|
|
$rt = '';
|
|
if (!is_array($conditions) && (!strpos(low($conditions), 'where') || strpos(low($conditions), 'where') === 0))
|
|
{
|
|
$rt = ' WHERE ';
|
|
}
|
|
|
|
if (is_string($conditions))
|
|
{
|
|
if (trim($conditions) == '')
|
|
{
|
|
$conditions = ' 1';
|
|
}
|
|
return $rt.$conditions;
|
|
}
|
|
elseif (is_array($conditions))
|
|
{
|
|
$out = array();
|
|
foreach ($conditions as $key => $value)
|
|
{
|
|
// Treat multiple values as an IN condition.
|
|
if (is_array($value))
|
|
{
|
|
$data = $key . ' IN (';
|
|
foreach ($value as $valElement)
|
|
{
|
|
$data .= $this->value($valElement) . ', ';
|
|
}
|
|
// Remove trailing ',' and complete clause.
|
|
$data[strlen($data)-2] = ')';
|
|
}
|
|
else
|
|
{
|
|
$slashedValue = $this->value($value);
|
|
//TODO: Remove the = below so LIKE and other compares can be used
|
|
$data = $key . '=';
|
|
if ($value === null)
|
|
{
|
|
$data .= 'null';
|
|
}
|
|
else
|
|
{
|
|
$data .= $slashedValue;
|
|
}
|
|
}
|
|
$out[] = $data;
|
|
}
|
|
return ' WHERE ' . join(' AND ', $out);
|
|
}
|
|
else
|
|
{
|
|
return $rt.' 1 ';
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
*/
|
|
function limit ()
|
|
{
|
|
}
|
|
|
|
/**
|
|
* Enter description here...
|
|
*
|
|
* @param unknown_type $key
|
|
* @param unknown_type $dir
|
|
* @return unknown
|
|
*/
|
|
function order ($key, $dir = '')
|
|
{
|
|
if (trim($key) == '')
|
|
{
|
|
return '';
|
|
}
|
|
return ' ORDER BY '.$key.' '.$dir;
|
|
}
|
|
|
|
/**
|
|
* Disconnects database, kills the connection and says the connection is closed,
|
|
* and if DEBUG is turned on, the log for this object is shown.
|
|
*
|
|
*/
|
|
function close ()
|
|
{
|
|
if ($this->fullDebug)
|
|
{
|
|
$this->showLog();
|
|
}
|
|
$this->disconnect();
|
|
$this->_conn = NULL;
|
|
$this->connected = false;
|
|
}
|
|
|
|
/**
|
|
* Destructor. Closes connection to the database.
|
|
*
|
|
*/
|
|
function __destruct()
|
|
{
|
|
if ($this->__transactionStarted)
|
|
{
|
|
$this->rollback();
|
|
}
|
|
$this->close();
|
|
parent::__destruct();
|
|
}
|
|
|
|
/**
|
|
* Checks if the specified table contains any record matching specified SQL
|
|
*
|
|
* @param string $table Name of table to look in
|
|
* @param string $sql SQL WHERE clause (condition only, not the "WHERE" part)
|
|
* @return boolean True if the table has a matching record, else false
|
|
*/
|
|
function hasAny($table, $sql)
|
|
{
|
|
$out = $this->one("SELECT COUNT(*) AS count FROM {$table}".($sql? " WHERE {$sql}":""));
|
|
return is_array($out)? $out[0]['count']: false;
|
|
}
|
|
}
|
|
?>
|