mysql - ZF - 使用 CASE WHEN 的 MySQL SUM 查询

Question

尝试在 zend 框架 1 中编写以下查询:

SELECT
    SUM(CASE WHEN column2 = 'value1' THEN column3 END) AS 'mySpecialSum',
FROM `my_table` 
WHERE column4='value2' AND column5='value3'

为了测试我这样写:

$select = $this->select()
    ->from('my_table', array(
        'mySpecialSum'=>'SUM(CASE WHEN column2 = "value1" THEN column3 END)'
    ))
    ->where('column4=?', $value2)
    ->where('column5=?', $value3);
$data = $this->fetchAll($select);

这有效 - 但我需要知道如何将 value1 包含为变量 - 例如 $value1 - 最好使用占位符，以便语句已“准备好” - 以最小化SQL注入(inject)的机会。

当前正在尝试两个选项(不起作用):

$select = $this->select()
    ->from('my_table', array(
        'mySpecialSum'=>'SUM(CASE WHEN column2 = "{$value1}" THEN column3 END)'
    ))
    ->where('column4=?', $value2)
    ->where('column5=?', $value3);
$data = $this->fetchAll($select);

或者

$select = $this->select()
    ->from('my_table', array(
        'mySpecialSum'=>'SUM(CASE WHEN column2 = "{$this->_db->quote($value1)}" THEN column3 END)'
    ))
    ->where('column4=?', $value2)
    ->where('column5=?', $value3);
$data = $this->fetchAll($select);

Answer 1

经过一番研究here在准备好的陈述中，最好的方法似乎是:

$sql = 'SELECT SUM(CASE WHEN column2 = ? THEN column3 END) AS "mySpecialSum",
FROM my_table
WHERE content_type = ?
AND content_id = ?';

$preparedStatement = $this->getAdapter()->query($sql, array($value1, $value2, $value3));
$data = $preparedStatement->fetchAll();

两个选项也工作 - 但都感觉像是黑客(顺便说一句，也比上面的“准备好的语句”方法稍慢) - 是:

$select = $this->select()
    ->from('my_table', array(
        'mySpecialSum'=>'SUM(CASE WHEN column2 = "' . $value1 . '" THEN column3 END)'
    ))
    ->where('column4=?', $value2)
    ->where('column5=?', $value3);
$data = $this->fetchAll($select);

和:

$start = microtime();

$select = $this->select()
    ->from('my_table', array(
        'mySpecialSum'=>'SUM(CASE WHEN column2 = ' . $this->_db->quote($value1) . ' THEN column3 END)'
    ))
    ->where('column4=?', $value2)
    ->where('column5=?', $value3);
$data = $this->fetchAll($select);

$end = microtime();
$timeTaken = $end - $start;

之前和之后的 microtime() 是比较两种方法的速度测试:
...显示使用 zf $this->_db->quote() 或不使用 zf 的差异可以忽略不计

但是，奇怪的是，使用 $this->getAdapter()->select() 而不是简单地使用 $this->select() 时，速度提高了 5 倍>:

$select = $this->getAdapter()
    ->select()
    ->from('my_table', array(
        'mySpecialSum'=>'SUM(CASE WHEN column2 = ' . $this->_db->quote($value1) . ' THEN column3 END)'
    ))
    ->where('column4=?', $value2)
    ->where('column5=?', $value3);
$data = $this->getAdapter()->fetchAll($select);