php - Symfony2 Doctrine - WHERE IN 成对

Question

基本上我想做这样的查询:

SELECT * FROM `table` WHERE (`c1`,`c2`) in (('a','b'),('c','d')) 

我尝试了一些方法，但找不到任何关于如何实现的建议。我尝试了一些类似的东西:

foreach ($pairs as $pair) {
    $columns[] = "(" . $pair->getc1() . "," . $pair->getc2() . ")";
}

$query = $this->entityManager->getRepository('AcmeTestBundle:Combinations')->createQueryBuilder('c')
                ->select()
                ->where('(c.c1,c.c2) in (:pairs)')
                ->setParameter('pairs', $columns)
                ->getQuery();

这显然对我不起作用，你知道如何在 where in 语句中使用多个值吗？

编辑:

我设法做到了这种卑鄙的方式。我怀疑这是最好的方法，我仍然认为应该有更好的解决方案，所以我很乐意看到它。

$query = $this->entityManager
    ->getRepository('AcmeTestBundle:Combinations')
    ->createQueryBuilder('c')
    ->select();

$expr = $query->expr();

$i = 1;
foreach ($pairs as $pair) {
    $query = $query->orWhere($expr->andX($expr->eq('c.c1', ':c1' . $i), $expr->eq('c.c2', ':c2' . $i)))
            ->setParameter('c1' . $i, $pair->getc1())
            ->setParameter('c2' . $i, $pair->getc2()) 
    ;

    $i++;
}

$query = $query->getQuery();

Answer 1

我找到了一些您肯定不喜欢的解决方案，但它以某种方式起作用。

基本上存在三个问题:1. DOCTRINE 中不能有 WHERE (col1, col2)2. 您不能将数组的数组作为参数传递(以构建对)3. 没有比较就不能有 where 表达式。

但请检查我的解决方法。

扩展类:

/*
 * This file is part of the Acme package.
 *
 * (c) Denis V.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Acme\Bundle\AcmeBundle\Query;

use Doctrine\ORM\Query\AST\Functions\FunctionNode,
    Doctrine\ORM\Query\Lexer,
    Doctrine\ORM\Query\Parser,
    Doctrine\ORM\Query\SqlWalker;

/**
 * Class Pairs
 *
 * @author Denis V.
 *
 * @package Acme\Bundle\AcmeBundle\Query
 */
class Pairs extends FunctionNode
{
    public $cols = array();
    public $pathExp = array();

    /**
     * {@inheritdoc}
     */
    public function parse(Parser $parser)
    {
        $parser->match(Lexer::T_IDENTIFIER);
        $parser->match(Lexer::T_OPEN_PARENTHESIS);

        $lexer = $parser->getLexer();

        // first Path Expression is mandatory
        $this->pathExp = array();
        $parser->match(Lexer::T_OPEN_PARENTHESIS);
        $this->cols[] = $parser->SingleValuedPathExpression();
        while ($lexer->isNextToken(Lexer::T_COMMA)) {
            $parser->match(Lexer::T_COMMA);
            $this->cols[] = $parser->SingleValuedPathExpression();
        }
        $parser->match(Lexer::T_CLOSE_PARENTHESIS);

        $j = 1;
        while ($lexer->isNextToken(Lexer::T_COMMA)) {
            $parser->match(Lexer::T_COMMA);
            $parser->match(Lexer::T_OPEN_PARENTHESIS);
            $this->pathExp[$j] = array($parser->StringPrimary());
            while ($lexer->isNextToken(Lexer::T_COMMA)) {
                $parser->match(Lexer::T_COMMA);
                $this->pathExp[$j][] = $parser->StringPrimary();
            }

            // commented out as it should be possible to accept array parameters
            //if (count($this->cols) != count($this->pathExp[$j])) {
            //    $parser->semanticalError('Number of columns must be the same as number of compared values');
            //}

            $parser->match(Lexer::T_CLOSE_PARENTHESIS);
            $j++;
        }

        $parser->match(Lexer::T_CLOSE_PARENTHESIS);
    }

    /**
     * {@inheritdoc}
     */
    public function getSql(SqlWalker $sqlWalker)
    {
        $fields = array();
        foreach ($this->cols as $col) {
            $fields[] = $col->dispatch($sqlWalker);
        }

        $result = sprintf('(%s)', implode(', ', $fields));

        $result .= ' IN ';

        $expr = array();
        foreach ($this->pathExp as $pathExp) {
            $fields = array();
            foreach ($pathExp as $item) {
                $fields[] = $item->dispatch($sqlWalker);
            }
            $expr[] = sprintf('(%s)', implode(', ', $fields));
        }

        $result .= sprintf('(%s)', implode(', ', $expr));

        return $result;
    }

}

现在您可以执行以下操作(假设您在实体存储库中):

    $qb = $this
        ->createQueryBuilder('c')
        ->where('PAIRS((c.c1, c.c2), (:pair)) != \'dummy\'')
        ->setParameter('pair', array('val1', 'val2'));
    $q = $qb->getQuery();

    return $q;

您可能会注意到代码中有 != 'dummy'。这是因为你不能在没有比较的情况下传递 WHERE 表达式。我检查过，它实际上以这种方式与 MySQL 一起工作。但您可以使用自定义 SqlWalker 将其删除。

要传递更多对，您将需要使用循环，因为您不能将数组的数组作为单个参数传递。

像这样:

$dqlParts = array();
foreach ($pairs as $i => $pair) {
    $dqlParts[] = sprintf('(?%d)', $i);
    $qb->setParameter($i, $pair);
}
$dqlPartsStr = implode(', ', $dqlParts);

然后在您的 DQL 中使用这个 $dqlPartsStr(注意:最后一个代码块是在未经测试的情况下在 StackOverflow 上编写的)。

我知道，这看起来更像是 hack，但这就是你在 Doctrine2 中所能做的。如果您有任何问题，请告诉我。