adulau/cakephp2-php8
1
0
Fork 0
mirror of https://github.com/kamilwylegala/cakephp2-php8.git synced 2024-11-15 19:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Adding first implementation of hasMany associations using one select statement.

Browse source 
git-svn-id: https://svn.cakephp.org/repo/branches/1.2.x.x@4826 3807eeeb-6ff5-0310-8944-8be069107fe0
This commit is contained in:
phpnut 2007-04-09 08:54:25 +00:00
parent cff6ea0ee8
commit 00be91c954
2 changed files with 277 additions and 238 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

83
cake/libs/model/datasources/dbo_source.php
View file

@ -720,12 +720,48 @@ class DboSource extends DataSource {
} }
return null; return null;
} }
$count = count($resultSet); $count = count($resultSet);
if($type === 'hasMany') {
$ins = array();
for($i = 0; $i < $count; $i++) {
$ins[] = $this->insertQueryData('{$__cakeID__$}', $resultSet[$i], $association, $assocData, $model, $linkModel, $stack);
}
if(!empty($ins)){
$query = r('{$__cakeID__$}', join(', ',$ins), $query);
$fetch = $this->fetchAll($query, $model->cacheQueries, $model->name);
} else {
$fetch = array();
}
if (!empty($fetch) && is_array($fetch)) {
if ($recursive > 0) {
foreach($linkModel->__associations as $type1) {
foreach($linkModel->{$type1} as $assoc1 => $assocData1) {
$deepModel =& $linkModel->{$assocData1['className']};
if ($deepModel->alias != $model->name) {
$tmpStack = $stack;
$tmpStack[] = $assoc1;
if ($linkModel->useDbConfig == $deepModel->useDbConfig) {
$db =& $this;
} else {
$db =& ConnectionManager::getDataSource($deepModel->useDbConfig);
}
$db->queryAssociation($linkModel, $deepModel, $type1, $assoc1, $assocData1, $queryData, true, $fetch, $recursive - 1, $tmpStack);
}
}
}
}
}
return $this->__mergeHasMany($resultSet, $fetch, $association, $model, $linkModel, $recursive);
}
for($i = 0; $i < $count; $i++) { for($i = 0; $i < $count; $i++) {
$row =& $resultSet[$i]; $row =& $resultSet[$i];
$q = $this->insertQueryData($query, $resultSet[$i], $association, $assocData, $model, $linkModel, $stack); $q = $this->insertQueryData($query, $resultSet[$i], $association, $assocData, $model, $linkModel, $stack);
if($q != false){ if($q != false){
$fetch = $this->fetchAll($q, $model->cacheQueries, $model->name); $fetch = $this->fetchAll($q, $model->cacheQueries, $model->name);
} else { } else {
@ -761,6 +797,29 @@ class DboSource extends DataSource {
} }
} }
} }
function __mergeHasMany(&$resultSet, $merge, $association, &$model, &$linkModel){
foreach($resultSet as $key => $value) {
$merged[$association] = array();
$count = 0;
foreach ($merge as $assoc => $data) {
if($value[$model->name][$model->primaryKey] === $data[$association][$model->hasMany[$association]['foreignKey']]) {
if(count($data) > 1) {
$temp[] = Set::pushDiff($data[$association], $data);
unset($temp[$count][$association]);
$merged[$association] = $temp;
} else {
$merged[$association][] = $data[$association];
}
}
$count++;
}
$resultSet[$key] = Set::pushDiff($resultSet[$key], $merged);
unset($merged);
unset($temp);
}
}
/** /**
* Enter description here... * Enter description here...
* *
@ -1018,7 +1077,7 @@ class DboSource extends DataSource {
break; break;
case 'hasMany': case 'hasMany':
$query = array( $query = array(
'in' => $this->__mergeConditions(array("{$alias}.{$assocData['foreignKey']}" => array('{$__cakeID__$}')), $assocData['conditions']), 'conditions' => $this->__mergeConditions(array("{$alias}.{$assocData['foreignKey']}" => array('{$__cakeID__$}')), $assocData['conditions']),
'fields' => $this->fields($linkModel, $alias, $assocData['fields']), 'fields' => $this->fields($linkModel, $alias, $assocData['fields']),
'table' => $this->fullTableName($linkModel), 'table' => $this->fullTableName($linkModel),
'alias' => $alias, 'alias' => $alias,
@ -1092,12 +1151,6 @@ class DboSource extends DataSource {
} }
} }
} }
if(isset($query['in'])) {
$query['conditions'] = $query['in'];
return $this->renderInStatement($query, $model);
}
return $this->renderStatement(array( return $this->renderStatement(array(
'conditions' => $this->conditions($query['conditions']), 'conditions' => $this->conditions($query['conditions']),
'fields' => join(', ', $query['fields']), 'fields' => join(', ', $query['fields']),
@ -1109,20 +1162,6 @@ class DboSource extends DataSource {
)); ));
} }
function renderInStatement($query, $model) {
$replace[] = '{$__cakeID__$}';
$replace[] = $this->renderStatement(array(
'conditions' => $this->conditions($query['conditions']),
'fields' => join(', ', $query['fields']),
'table' => $query['table'],
'alias' => $this->alias . $this->name($query['alias']),
'order' => $this->order($query['order']),
'limit' => $this->limit($query['limit'], $query['offset']),
'joins' => join(' ', $query['joins'])
));
return $replace[1];
}
function renderJoinStatement($data) { function renderJoinStatement($data) {
extract($data); extract($data);
return trim("{$type} JOIN {$table} {$alias} ON ({$conditions})"); return trim("{$type} JOIN {$table} {$alias} ON ({$conditions})");