Drupal
/
drupal
mirror of https://git.drupalcode.org/project/drupal.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Issue #3311562 by ravi.shankar, Berdir, andypost, catch: Set sqlQuery in Entity\Query\Sql Condition classes on own class

merge-requests/828/head^2
Alex Pott 2022-09-27 15:37:15 +01:00
parent d70f1b040d
commit 3098069a88
No known key found for this signature in database
GPG Key ID: BDA67E7EE836E5CE
2 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
core/lib/Drupal/Core/Entity/Query/Sql/Condition.php
View File

@ -25,6 +25,13 @@ class Condition extends ConditionBase {
*/
protected $query;
/**
* The current SQL query, set by parent condition compile() method calls.
*
* @var \Drupal\Core\Database\Query\SelectInterface
*/
protected $sqlQuery;
/**
* {@inheritdoc}
*/
@ -35,13 +42,13 @@ class Condition extends ConditionBase {
// SQL query object is only necessary to pass to Query::addField() so it
// can join tables as necessary. On the other hand, conditions need to be
// added to the $conditionContainer object to keep grouping.
$sql_query = $conditionContainer instanceof SelectInterface ? $conditionContainer : $conditionContainer->sqlQuery;
$sql_query = $conditionContainer instanceof SelectInterface ? $conditionContainer : $this->sqlQuery;
$tables = $this->query->getTables($sql_query);
foreach ($this->conditions as $condition) {
if ($condition['field'] instanceof ConditionInterface) {
$sql_condition = $sql_query->getConnection()->condition($condition['field']->getConjunction());
// Add the SQL query to the object before calling this method again.
$sql_condition->sqlQuery = $sql_query;
$condition['field']->sqlQuery = $sql_query;
$condition['field']->nestedInsideOrCondition = $this->nestedInsideOrCondition || strtoupper($this->conjunction) === 'OR';
$condition['field']->compile($sql_condition);
$conditionContainer->condition($sql_condition);

11
core/lib/Drupal/Core/Entity/Query/Sql/ConditionAggregate.php
View File

@ -12,6 +12,13 @@ use Drupal\Core\Entity\Query\QueryBase;
*/
class ConditionAggregate extends ConditionAggregateBase {
/**
* The current SQL query, set by parent condition compile() method calls.
*
* @var \Drupal\Core\Database\Query\SelectInterface
*/
protected $sqlQuery;
/**
* {@inheritdoc}
*/
@ -21,13 +28,13 @@ class ConditionAggregate extends ConditionAggregateBase {
// SQL query object is only necessary to pass to Query::addField() so it
// can join tables as necessary. On the other hand, conditions need to be
// added to the $conditionContainer object to keep grouping.
$sql_query = ($conditionContainer instanceof SelectInterface) ? $conditionContainer : $conditionContainer->sqlQuery;
$sql_query = ($conditionContainer instanceof SelectInterface) ? $conditionContainer : $this->sqlQuery;
$tables = new Tables($sql_query);
foreach ($this->conditions as $condition) {
if ($condition['field'] instanceof ConditionAggregateInterface) {
$sql_condition = $sql_query->getConnection()->condition($condition['field']->getConjunction());
// Add the SQL query to the object before calling this method again.
$sql_condition->sqlQuery = $sql_query;
$condition['field']->sqlQuery = $sql_query;
$condition['field']->compile($sql_condition);
$sql_query->condition($sql_condition);
}