. */ Doctrine::autoload('Doctrine_Query_Condition'); /** * Doctrine_Query_Where * * @package Doctrine * @license http://www.opensource.org/licenses/lgpl-license.php LGPL * @category Object Relational Mapping * @link www.phpdoctrine.com * @since 1.0 * @version $Revision$ * @author Konsta Vesterinen */ class Doctrine_Query_Where extends Doctrine_Query_Condition { public function parse($str, $append = false) { if ($append) { $this->query->addQueryPart('where', $this->_parse($str)); } else { $this->query->setQueryPart('where', $this->_parse($str)); } return $this->query; } /** * load * returns the parsed query part * * @param string $where * @return string */ public function load($where) { $where = trim($where); $e = Doctrine_Tokenizer::sqlExplode($where); if (count($e) > 1) { $tmp = $e[0] . ' ' . $e[1]; if (substr($tmp, 0, 6) == 'EXISTS') { return $this->parseExists($where, true); } elseif (substr($where, 0, 10) == 'NOT EXISTS') { return $this->parseExists($where, false); } } if (count($e) < 3) { $e = Doctrine_Tokenizer::sqlExplode($where, array('=', '<', '>', '!=')); } $r = array_shift($e); $a = explode('.', $r); if (count($a) > 1) { $field = array_pop($a); $count = count($e); $slice = array_slice($e, -1, 1); $value = implode('', $slice); $operator = trim(substr($where, strlen($r), -strlen($value))); $reference = implode('.', $a); $count = count($a); $pos = strpos($field, '('); if ($pos !== false) { $func = substr($field, 0, $pos); $value = trim(substr($field, ($pos + 1), -1)); $values = Doctrine_Query::sqlExplode($value, ','); $field = array_pop($a); $reference = implode('.', $a); $table = $this->query->load($reference, false); $field = $table->getColumnName($field); array_pop($a); $reference2 = implode('.', $a); $alias = $this->query->getTableAlias($reference2); $stack = $this->query->getRelationStack(); $relation = end($stack); $stack = $this->query->getTableStack(); switch ($func) { case 'contains': case 'regexp': case 'like': $operator = $this->getOperator($func); if (empty($relation)) { throw new Doctrine_Query_Exception('DQL functions contains/regexp/like can only be used for fields of related components'); } $where = array(); foreach ($values as $value) { $where[] = $alias . '.' . $relation->getLocal() . ' IN (SELECT '.$relation->getForeign() . ' FROM ' . $relation->getTable()->getTableName() . ' WHERE ' . $field . $operator . $value . ')'; } $where = implode(' AND ', $where); break; default: throw new Doctrine_Query_Exception('Unknown DQL function: '.$func); } } else { $map = $this->query->load($reference, false); $alias = $this->query->getTableAlias($reference); $table = $map['table']; $field = $table->getColumnName($field); // check if value is enumerated value $enumIndex = $table->enumIndex($field, trim($value, "'")); if (substr($value, 0, 1) == '(') { // trim brackets $trimmed = Doctrine_Tokenizer::bracketTrim($value); if (substr($trimmed, 0, 4) == 'FROM' || substr($trimmed, 0, 6) == 'SELECT') { // subquery found $q = new Doctrine_Query(); $value = '(' . $q->isSubquery(true)->parseQuery($trimmed)->getQuery() . ')'; } elseif (substr($trimmed, 0, 4) == 'SQL:') { $value = '(' . substr($trimmed, 4) . ')'; } else { // simple in expression found $e = Doctrine_Tokenizer::sqlExplode($trimmed, ','); $value = array(); foreach ($e as $part) { $index = $table->enumIndex($field, trim($part, "'")); if ($index !== false) { $value[] = $index; } else { $value[] = $this->parseLiteralValue($part); } } $value = '(' . implode(', ', $value) . ')'; } } elseif(substr($value, 0, 1) == ':' || $value === '?') { // placeholder found if ($table->getTypeOf($field) == 'enum') { $this->query->addEnumParam($value, $table, $field); } else { $this->query->addEnumParam($value, null, null); } } else { if ($enumIndex !== false) { $value = $enumIndex; } else { $value = $this->parseLiteralValue($value); } } switch ($operator) { case '<': case '>': case '=': case '!=': if ($enumIndex !== false) { $value = $enumIndex; } default: if ($this->query->getType() === Doctrine_Query::SELECT) { $fieldname = $alias ? $alias . '.' . $field : $field; } else { $fieldname = $field; } $where = $fieldname . ' ' . $operator . ' ' . $value; } } } return $where; } /** * parses an EXISTS expression * * @param string $where query where part to be parsed * @param boolean $negation whether or not to use the NOT keyword * @return string */ public function parseExists($where, $negation) { $operator = ($negation) ? 'EXISTS' : 'NOT EXISTS'; $pos = strpos($where, '('); if ($pos == false) { throw new Doctrine_Query_Exception("Unknown expression, expected '('"); } $sub = Doctrine_Tokenizer::bracketTrim(substr($where, $pos)); return $operator . ' (' . $this->query->createSubquery()->parseQuery($sub, false)->getQuery() . ')'; } /** * getOperator * * @param string $func * @return string */ public function getOperator($func) { switch ($func) { case 'contains': $operator = ' = '; break; case 'regexp': $operator = $this->query->getConnection()->getRegexpOperator(); break; case 'like': $operator = ' LIKE '; break; } return $operator; } }