12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616 |
- <?php
- require_once dirname(__FILE__) . '/query.inc';
- interface QueryExtendableInterface {
-
- public function extend($extender_name);
- }
- interface SelectQueryInterface extends QueryConditionInterface, QueryAlterableInterface, QueryExtendableInterface, QueryPlaceholderInterface {
-
-
- public function &getFields();
-
- public function &getExpressions();
-
- public function &getOrderBy();
-
- public function &getGroupBy();
-
- public function &getTables();
-
- public function &getUnion();
-
- public function getArguments(QueryPlaceholderInterface $queryPlaceholder = NULL);
-
-
- public function distinct($distinct = TRUE);
-
- public function addField($table_alias, $field, $alias = NULL);
-
- public function fields($table_alias, array $fields = array());
-
- public function addExpression($expression, $alias = NULL, $arguments = array());
-
- public function join($table, $alias = NULL, $condition = NULL, $arguments = array());
-
- public function innerJoin($table, $alias = NULL, $condition = NULL, $arguments = array());
-
- public function leftJoin($table, $alias = NULL, $condition = NULL, $arguments = array());
-
- public function rightJoin($table, $alias = NULL, $condition = NULL, $arguments = array());
-
- public function addJoin($type, $table, $alias = NULL, $condition = NULL, $arguments = array());
-
- public function orderBy($field, $direction = 'ASC');
-
- public function orderRandom();
-
- public function range($start = NULL, $length = NULL);
-
- public function union(SelectQueryInterface $query, $type = '');
-
- public function groupBy($field);
-
- public function countQuery();
-
- public function isPrepared();
-
- public function preExecute(SelectQueryInterface $query = NULL);
-
- public function havingCondition($field, $value = NULL, $operator = NULL);
-
- public function __clone();
-
- public function forUpdate($set = TRUE);
- }
- class SelectQueryExtender implements SelectQueryInterface {
-
- protected $query;
-
- protected $connection;
-
- protected $uniqueIdentifier;
-
- protected $placeholder = 0;
- public function __construct(SelectQueryInterface $query, DatabaseConnection $connection) {
- $this->uniqueIdentifier = uniqid('', TRUE);
- $this->query = $query;
- $this->connection = $connection;
- }
-
- public function uniqueIdentifier() {
- return $this->uniqueIdentifier;
- }
-
- public function nextPlaceholder() {
- return $this->placeholder++;
- }
-
- public function addTag($tag) {
- $this->query->addTag($tag);
- return $this;
- }
- public function hasTag($tag) {
- return $this->query->hasTag($tag);
- }
- public function hasAllTags() {
- $args = func_get_args();
- return call_user_func_array(array($this->query, 'hasAllTags'), $args);
- }
- public function hasAnyTag() {
- $args = func_get_args();
- return call_user_func_array(array($this->query, 'hasAnyTag'), $args);
- }
- public function addMetaData($key, $object) {
- $this->query->addMetaData($key, $object);
- return $this;
- }
- public function getMetaData($key) {
- return $this->query->getMetaData($key);
- }
-
- public function condition($field, $value = NULL, $operator = NULL) {
- $this->query->condition($field, $value, $operator);
- return $this;
- }
- public function &conditions() {
- return $this->query->conditions();
- }
- public function arguments() {
- return $this->query->arguments();
- }
- public function where($snippet, $args = array()) {
- $this->query->where($snippet, $args);
- return $this;
- }
- public function compile(DatabaseConnection $connection, QueryPlaceholderInterface $queryPlaceholder) {
- return $this->query->compile($connection, $queryPlaceholder);
- }
- public function compiled() {
- return $this->query->compiled();
- }
-
- public function havingCondition($field, $value = NULL, $operator = '=') {
- $this->query->havingCondition($field, $value, $operator);
- return $this;
- }
- public function &havingConditions() {
- return $this->query->havingConditions();
- }
- public function havingArguments() {
- return $this->query->havingArguments();
- }
- public function having($snippet, $args = array()) {
- $this->query->having($snippet, $args);
- return $this;
- }
- public function havingCompile(DatabaseConnection $connection) {
- return $this->query->havingCompile($connection);
- }
-
- public function extend($extender_name) {
-
-
- $class = $this->connection->getDriverClass($extender_name, array(), TRUE);
- return new $class($this, $this->connection);
- }
-
- public function &getFields() {
- return $this->query->getFields();
- }
- public function &getExpressions() {
- return $this->query->getExpressions();
- }
- public function &getOrderBy() {
- return $this->query->getOrderBy();
- }
- public function &getGroupBy() {
- return $this->query->getGroupBy();
- }
- public function &getTables() {
- return $this->query->getTables();
- }
- public function &getUnion() {
- return $this->query->getUnion();
- }
- public function getArguments(QueryPlaceholderInterface $queryPlaceholder = NULL) {
- return $this->query->getArguments($queryPlaceholder);
- }
- public function isPrepared() {
- return $this->query->isPrepared();
- }
- public function preExecute(SelectQueryInterface $query = NULL) {
-
- if (!isset($query)) {
- $query = $this;
- }
- return $this->query->preExecute($query);
- }
- public function execute() {
-
-
-
- if (!$this->preExecute($this)) {
- return NULL;
- }
- return $this->query->execute();
- }
- public function distinct($distinct = TRUE) {
- $this->query->distinct($distinct);
- return $this;
- }
- public function addField($table_alias, $field, $alias = NULL) {
- return $this->query->addField($table_alias, $field, $alias);
- }
- public function fields($table_alias, array $fields = array()) {
- $this->query->fields($table_alias, $fields);
- return $this;
- }
- public function addExpression($expression, $alias = NULL, $arguments = array()) {
- return $this->query->addExpression($expression, $alias, $arguments);
- }
- public function join($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->query->join($table, $alias, $condition, $arguments);
- }
- public function innerJoin($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->query->innerJoin($table, $alias, $condition, $arguments);
- }
- public function leftJoin($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->query->leftJoin($table, $alias, $condition, $arguments);
- }
- public function rightJoin($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->query->rightJoin($table, $alias, $condition, $arguments);
- }
- public function addJoin($type, $table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->query->addJoin($type, $table, $alias, $condition, $arguments);
- }
- public function orderBy($field, $direction = 'ASC') {
- $this->query->orderBy($field, $direction);
- return $this;
- }
- public function orderRandom() {
- $this->query->orderRandom();
- return $this;
- }
- public function range($start = NULL, $length = NULL) {
- $this->query->range($start, $length);
- return $this;
- }
- public function union(SelectQueryInterface $query, $type = '') {
- $this->query->union($query, $type);
- return $this;
- }
- public function groupBy($field) {
- $this->query->groupBy($field);
- return $this;
- }
- public function forUpdate($set = TRUE) {
- $this->query->forUpdate($set);
- return $this;
- }
- public function countQuery() {
- return $this->query->countQuery();
- }
- function isNull($field) {
- $this->query->isNull($field);
- return $this;
- }
- function isNotNull($field) {
- $this->query->isNotNull($field);
- 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;
- }
- public function __clone() {
- $this->uniqueIdentifier = uniqid('', TRUE);
-
-
- $this->query = clone($this->query);
- }
-
- public function __call($method, $args) {
- $return = call_user_func_array(array($this->query, $method), $args);
-
-
-
-
-
- if ($return instanceof SelectQueryInterface) {
- return $this;
- }
- else {
- return $return;
- }
- }
- }
- class SelectQuery extends Query implements SelectQueryInterface {
-
- protected $fields = array();
-
- protected $expressions = array();
-
- protected $tables = array();
-
- protected $order = array();
-
- protected $group = array();
-
- protected $where;
-
- protected $having;
-
- protected $distinct = FALSE;
-
- protected $range;
-
- protected $union = array();
-
- protected $prepared = FALSE;
-
- protected $forUpdate = FALSE;
- public function __construct($table, $alias = NULL, DatabaseConnection $connection, $options = array()) {
- $options['return'] = Database::RETURN_STATEMENT;
- parent::__construct($connection, $options);
- $this->where = new DatabaseCondition('AND');
- $this->having = new DatabaseCondition('AND');
- $this->addJoin(NULL, $table, $alias);
- }
-
- public function addTag($tag) {
- $this->alterTags[$tag] = 1;
- return $this;
- }
- public function hasTag($tag) {
- return isset($this->alterTags[$tag]);
- }
- public function hasAllTags() {
- $args = func_get_args();
- return !(boolean)array_diff($args, array_keys($this->alterTags));
- }
- public function hasAnyTag() {
- $args = func_get_args();
- return (boolean)array_intersect($args, array_keys($this->alterTags));
- }
- public function addMetaData($key, $object) {
- $this->alterMetaData[$key] = $object;
- return $this;
- }
- public function getMetaData($key) {
- return isset($this->alterMetaData[$key]) ? $this->alterMetaData[$key] : NULL;
- }
-
- public function condition($field, $value = NULL, $operator = NULL) {
- $this->where->condition($field, $value, $operator);
- return $this;
- }
- public function &conditions() {
- return $this->where->conditions();
- }
- public function arguments() {
- if (!$this->compiled()) {
- return NULL;
- }
- $args = $this->where->arguments() + $this->having->arguments();
- foreach ($this->tables as $table) {
- if ($table['arguments']) {
- $args += $table['arguments'];
- }
-
- if ($table['table'] instanceof SelectQueryInterface) {
- $args += $table['table']->arguments();
- }
- }
- foreach ($this->expressions as $expression) {
- if ($expression['arguments']) {
- $args += $expression['arguments'];
- }
- }
-
-
- foreach ($this->union as $union) {
- $args += $union['query']->arguments();
- }
- return $args;
- }
- public function where($snippet, $args = array()) {
- $this->where->where($snippet, $args);
- return $this;
- }
- public function isNull($field) {
- $this->where->isNull($field);
- return $this;
- }
- public function isNotNull($field) {
- $this->where->isNotNull($field);
- 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) {
- $this->where->compile($connection, $queryPlaceholder);
- $this->having->compile($connection, $queryPlaceholder);
- foreach ($this->tables as $table) {
-
- if ($table['table'] instanceof SelectQueryInterface) {
- $table['table']->compile($connection, $queryPlaceholder);
- }
- }
-
- foreach ($this->union as $union) {
- $union['query']->compile($connection, $queryPlaceholder);
- }
- }
- public function compiled() {
- if (!$this->where->compiled() || !$this->having->compiled()) {
- return FALSE;
- }
- foreach ($this->tables as $table) {
-
- if ($table['table'] instanceof SelectQueryInterface) {
- if (!$table['table']->compiled()) {
- return FALSE;
- }
- }
- }
- foreach ($this->union as $union) {
- if (!$union['query']->compiled()) {
- return FALSE;
- }
- }
- return TRUE;
- }
-
- public function havingCondition($field, $value = NULL, $operator = NULL) {
- $this->having->condition($field, $value, $operator);
- return $this;
- }
- public function &havingConditions() {
- return $this->having->conditions();
- }
- public function havingArguments() {
- return $this->having->arguments();
- }
- public function having($snippet, $args = array()) {
- $this->having->where($snippet, $args);
- return $this;
- }
- public function havingCompile(DatabaseConnection $connection) {
- return $this->having->compile($connection, $this);
- }
-
- public function extend($extender_name) {
- $override_class = $extender_name . '_' . $this->connection->driver();
- if (class_exists($override_class)) {
- $extender_name = $override_class;
- }
- return new $extender_name($this, $this->connection);
- }
- public function havingIsNull($field) {
- $this->having->isNull($field);
- return $this;
- }
- public function havingIsNotNull($field) {
- $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;
- }
- return $this;
- }
-
- public function &getFields() {
- return $this->fields;
- }
- public function &getExpressions() {
- return $this->expressions;
- }
- public function &getOrderBy() {
- return $this->order;
- }
- public function &getGroupBy() {
- return $this->group;
- }
- public function &getTables() {
- return $this->tables;
- }
- public function &getUnion() {
- return $this->union;
- }
- public function getArguments(QueryPlaceholderInterface $queryPlaceholder = NULL) {
- if (!isset($queryPlaceholder)) {
- $queryPlaceholder = $this;
- }
- $this->compile($this->connection, $queryPlaceholder);
- return $this->arguments();
- }
-
- public function isPrepared() {
- return $this->prepared;
- }
-
- public function preExecute(SelectQueryInterface $query = NULL) {
-
- if (!isset($query)) {
- $query = $this;
- }
-
- if ($query->isPrepared()) {
- return TRUE;
- }
-
- if (isset($this->alterTags)) {
- $hooks = array('query');
- foreach ($this->alterTags as $tag => $value) {
- $hooks[] = 'query_' . $tag;
- }
- drupal_alter($hooks, $query);
- }
- $this->prepared = TRUE;
-
- foreach ($this->tables as $table) {
- if ($table['table'] instanceof SelectQueryInterface) {
- $table['table']->preExecute();
- }
- }
- foreach ($this->union as $union) {
- $union['query']->preExecute();
- }
- return $this->prepared;
- }
- public function execute() {
-
-
- if (!$this->preExecute()) {
- return NULL;
- }
- $args = $this->getArguments();
- return $this->connection->query((string) $this, $args, $this->queryOptions);
- }
- public function distinct($distinct = TRUE) {
- $this->distinct = $distinct;
- return $this;
- }
- public function addField($table_alias, $field, $alias = NULL) {
-
- if (empty($alias)) {
- $alias = $field;
- }
-
- if (!empty($this->fields[$alias])) {
- $alias = $table_alias . '_' . $field;
- }
-
- $alias_candidate = $alias;
- $count = 2;
- while (!empty($this->fields[$alias_candidate])) {
- $alias_candidate = $alias . '_' . $count++;
- }
- $alias = $alias_candidate;
- $this->fields[$alias] = array(
- 'field' => $field,
- 'table' => $table_alias,
- 'alias' => $alias,
- );
- return $alias;
- }
- public function fields($table_alias, array $fields = array()) {
- if ($fields) {
- foreach ($fields as $field) {
-
- $this->addField($table_alias, $field);
- }
- }
- else {
-
- $this->tables[$table_alias]['all_fields'] = TRUE;
- }
- return $this;
- }
- public function addExpression($expression, $alias = NULL, $arguments = array()) {
- if (empty($alias)) {
- $alias = 'expression';
- }
- $alias_candidate = $alias;
- $count = 2;
- while (!empty($this->expressions[$alias_candidate])) {
- $alias_candidate = $alias . '_' . $count++;
- }
- $alias = $alias_candidate;
- $this->expressions[$alias] = array(
- 'expression' => $expression,
- 'alias' => $alias,
- 'arguments' => $arguments,
- );
- return $alias;
- }
- public function join($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->addJoin('INNER', $table, $alias, $condition, $arguments);
- }
- public function innerJoin($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->addJoin('INNER', $table, $alias, $condition, $arguments);
- }
- public function leftJoin($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->addJoin('LEFT OUTER', $table, $alias, $condition, $arguments);
- }
- public function rightJoin($table, $alias = NULL, $condition = NULL, $arguments = array()) {
- return $this->addJoin('RIGHT OUTER', $table, $alias, $condition, $arguments);
- }
- public function addJoin($type, $table, $alias = NULL, $condition = NULL, $arguments = array()) {
- if (empty($alias)) {
- if ($table instanceof SelectQueryInterface) {
- $alias = 'subquery';
- }
- else {
- $alias = $table;
- }
- }
- $alias_candidate = $alias;
- $count = 2;
- while (!empty($this->tables[$alias_candidate])) {
- $alias_candidate = $alias . '_' . $count++;
- }
- $alias = $alias_candidate;
- if (is_string($condition)) {
- $condition = str_replace('%alias', $alias, $condition);
- }
- $this->tables[$alias] = array(
- 'join type' => $type,
- 'table' => $table,
- 'alias' => $alias,
- 'condition' => $condition,
- 'arguments' => $arguments,
- );
- return $alias;
- }
- public function orderBy($field, $direction = 'ASC') {
-
- $direction = strtoupper($direction) == 'DESC' ? 'DESC' : 'ASC';
- $this->order[$field] = $direction;
- return $this;
- }
- public function orderRandom() {
- $alias = $this->addExpression('RAND()', 'random_field');
- $this->orderBy($alias);
- return $this;
- }
- public function range($start = NULL, $length = NULL) {
- $this->range = func_num_args() ? array('start' => $start, 'length' => $length) : array();
- return $this;
- }
- public function union(SelectQueryInterface $query, $type = '') {
-
- switch ($type) {
-
- case 'DISTINCT':
- case '':
- $type = 'UNION';
- break;
- case 'ALL':
- $type = 'UNION ALL';
- default:
- }
- $this->union[] = array(
- 'type' => $type,
- 'query' => $query,
- );
- return $this;
- }
- public function groupBy($field) {
- $this->group[$field] = $field;
- return $this;
- }
- public function countQuery() {
-
- $count = clone($this);
- $group_by = $count->getGroupBy();
- $having = $count->havingConditions();
- if (!$count->distinct && !isset($having[0])) {
-
-
-
-
- $fields =& $count->getFields();
- foreach (array_keys($fields) as $field) {
- if (empty($group_by[$field])) {
- unset($fields[$field]);
- }
- }
- $expressions =& $count->getExpressions();
- foreach (array_keys($expressions) as $field) {
- if (empty($group_by[$field])) {
- unset($expressions[$field]);
- }
- }
-
-
- foreach ($count->tables as $alias => &$table) {
- unset($table['all_fields']);
- }
- }
-
-
- $count->addExpression('1');
-
-
- $orders = &$count->getOrderBy();
- $orders = array();
- if ($count->distinct && !empty($group_by)) {
-
-
- $count->distinct = FALSE;
- }
- $query = $this->connection->select($count);
- $query->addExpression('COUNT(*)');
- return $query;
- }
- public function __toString() {
-
-
-
-
- if (!$this->compiled()) {
- $this->compile($this->connection, $this);
- }
-
- $comments = $this->connection->makeComment($this->comments);
-
- $query = $comments . 'SELECT ';
- if ($this->distinct) {
- $query .= 'DISTINCT ';
- }
-
- $fields = array();
- foreach ($this->tables as $alias => $table) {
- if (!empty($table['all_fields'])) {
- $fields[] = $this->connection->escapeTable($alias) . '.*';
- }
- }
- foreach ($this->fields as $alias => $field) {
-
-
- $fields[] = (isset($field['table']) ? $this->connection->escapeTable($field['table']) . '.' : '') . $this->connection->escapeField($field['field']) . ' AS ' . $this->connection->escapeAlias($field['alias']);
- }
- foreach ($this->expressions as $alias => $expression) {
- $fields[] = $expression['expression'] . ' AS ' . $this->connection->escapeAlias($expression['alias']);
- }
- $query .= implode(', ', $fields);
-
- $query .= "\nFROM ";
- foreach ($this->tables as $alias => $table) {
- $query .= "\n";
- if (isset($table['join type'])) {
- $query .= $table['join type'] . ' JOIN ';
- }
-
- if ($table['table'] instanceof SelectQueryInterface) {
-
- $subquery = $table['table'];
- $subquery->preExecute();
- $table_string = '(' . (string) $subquery . ')';
- }
- else {
- $table_string = '{' . $this->connection->escapeTable($table['table']) . '}';
- }
-
-
- $query .= $table_string . ' ' . $this->connection->escapeTable($table['alias']);
- if (!empty($table['condition'])) {
- $query .= ' ON ' . $table['condition'];
- }
- }
-
- if (count($this->where)) {
-
- $query .= "\nWHERE " . $this->where;
- }
-
- if ($this->group) {
- $query .= "\nGROUP BY " . implode(', ', $this->group);
- }
-
- if (count($this->having)) {
-
- $query .= "\nHAVING " . $this->having;
- }
-
- if ($this->order) {
- $query .= "\nORDER BY ";
- $fields = array();
- foreach ($this->order as $field => $direction) {
- $fields[] = $field . ' ' . $direction;
- }
- $query .= implode(', ', $fields);
- }
-
-
-
-
-
- if (!empty($this->range)) {
- $query .= "\nLIMIT " . (int) $this->range['length'] . " OFFSET " . (int) $this->range['start'];
- }
-
-
- if ($this->union) {
- foreach ($this->union as $union) {
- $query .= ' ' . $union['type'] . ' ' . (string) $union['query'];
- }
- }
- if ($this->forUpdate) {
- $query .= ' FOR UPDATE';
- }
- return $query;
- }
- public function __clone() {
-
-
-
- $this->where = clone($this->where);
- $this->having = clone($this->having);
- foreach ($this->union as $key => $aggregate) {
- $this->union[$key]['query'] = clone($aggregate['query']);
- }
- }
- }
|