diff options
author | Angie Byron <webchick@24967.no-reply.drupal.org> | 2010-12-31 20:43:43 +0000 |
---|---|---|
committer | Angie Byron <webchick@24967.no-reply.drupal.org> | 2010-12-31 20:43:43 +0000 |
commit | 98f287b55a88d06199cda88b6929af589c182e23 (patch) | |
tree | 50b7a7a71eb8c54e417cbaa8f4d6f1a975e9d72f /includes/database/select.inc | |
parent | 0c8931dd76d066c5332846d478964d1145c5c6c2 (diff) | |
download | brdo-98f287b55a88d06199cda88b6929af589c182e23.tar.gz brdo-98f287b55a88d06199cda88b6929af589c182e23.tar.bz2 |
#1001242 by agentrickard, pwolanin, Crell, chx: Add DBTNG support for EXISTS conditions.
Diffstat (limited to 'includes/database/select.inc')
-rw-r--r-- | includes/database/select.inc | 32 |
1 files changed, 31 insertions, 1 deletions
diff --git a/includes/database/select.inc b/includes/database/select.inc index 7f44063a2..43f92671e 100644 --- a/includes/database/select.inc +++ b/includes/database/select.inc @@ -810,6 +810,16 @@ class SelectQueryExtender implements SelectQueryInterface { return $this; } + public function exists(SelectQueryInterface $select) { + $this->query->exists($select); + return $this; + } + + public function notExists(SelectQueryInterface $select) { + $this->query->notExists($select); + return $this; + } + public function __toString() { return (string) $this->query; } @@ -1022,6 +1032,16 @@ class SelectQuery extends Query implements SelectQueryInterface { return $this; } + public function exists(SelectQueryInterface $select) { + $this->where->exists($select); + return $this; + } + + public function notExists(SelectQueryInterface $select) { + $this->where->notExists($select); + return $this; + } + public function compile(DatabaseConnection $connection, QueryPlaceholderInterface $queryPlaceholder = NULL) { return $this->where->compile($connection, isset($queryPlaceholder) ? $queryPlaceholder : $this); } @@ -1069,7 +1089,17 @@ class SelectQuery extends Query implements SelectQueryInterface { $this->having->isNotNull($field); return $this; } - + + public function havingExists(SelectQueryInterface $select) { + $this->having->exists($select); + return $this; + } + + public function havingNotExists(SelectQueryInterface $select) { + $this->having->notExists($select); + return $this; + } + public function forUpdate($set = TRUE) { if (isset($set)) { $this->forUpdate = $set; |