logo标签列表

Zend Framework 1.5中是否有一种方法可以执行“INSERT...ON DUPLICATE KEY UPDATE”操作？

phpmysqlzend-frameworkinsert-update
48

我想在Zend Framework 1.5中使用ON DUPLICATE KEY UPDATE，这是可能的吗？

示例

INSERT INTO sometable (...)
VALUES (...)
ON DUPLICATE KEY UPDATE ...
7个回答
54

我曾在Zend工作，专门从事Zend_Db的工作。

不，没有针对ON DUPLICATE KEY UPDATE语法的API支持。 对于这种情况，您必须使用query()并自己形成完整的SQL语句。

我不建议像harvejs展示的那样将值插入SQL中。 请使用查询参数。

编辑：您可以使用VALUES()表达式避免重复参数。

$sql = "INSERT INTO sometable (id, col2, col3) VALUES (:id, :col2, :col3)
  ON DUPLICATE KEY UPDATE col2 = VALUES(col2), col3 = VALUES(col3)";

$values = array("id"=>1, "col2"=>327, "col3"=>"active");
1
不，Zend_Db 中没有这样的方法。ZF 产品的目标始终是为最常见的80%情况提供简单的解决方案。 - Bill Karwin
1
你可以轻松地扩展它并添加这个功能 ;) - Tomáš Fejfar
当然可以，但另一个目标是避免为任何品牌的数据库制作专门的专有SQL功能方法。 - Bill Karwin
小细节：你应该在数组键周围使用引号，否则 PHP 会尝试将它们作为常量进行评估。 - Decent Dabbler
数组键必须采用':id'的形式，而不是'id'，否则您将会从Zend得到列不匹配的错误。 - jmkgreen
显示剩余2条评论
6
作为侧边栏，您可以通过使用VALUES()简化ON DUPLICATE KEY UPDATE子句并减少脚本需要处理的数量：
$sql = 'INSERT INTO ... ON DUPLICATE KEY UPDATE id = VALUES(id), col2 = VALUES(col2), col3 = VALUES(col3)';

请查看http://dev.mysql.com/doc/refman/5.1/en/insert-on-duplicate.html获取更多相关信息。
5

@Bill Karwin: 很棒的解决方案！但是如果使用命名占位符（“：id”，“：col1”等）而不是问号，那就更好了。这样您就不需要通过array_marge来重复值。此外，如果使用“INSERT”的“SET”语法而不是“VALUES”，则代码更容易自动生成任何字段集。

$sql = 'INSERT INTO sometable SET id = :id, col2 = :col2, col3 = :col3
    ON DUPLICATE KEY UPDATE id = :id, col2 = :col2, col3 = :col3';
我认为这取决于您正在使用的适配器。 - Justin Johnson
4
$arrayData = array('column1' => value1, 'column2' => value2, ...)

class Model_Db_Abstract extends Zend_Db_Table_Abstract
{
    protected $_name;
    protected $_primaryKey;

    public function insertOrUpdate($arrayData)
    {
        $query = 'INSERT INTO `'. $this->_name.'` ('.implode(',',array_keys($arrayData)).') VALUES ('.implode(',',array_fill(1, count($arrayData), '?')).') ON DUPLICATE KEY UPDATE '.implode(' = ?,',array_keys($arrayData)).' = ?';
        return $this->getAdapter()->query($query,array_merge(array_values($arrayData),array_values($arrayData)));
    }

}

用法:

例如：Model_Db_Contractors.php

class Model_Db_Contractors extends Model_Db_Abstract 
{

    protected $_name = 'contractors';
    protected $_primaryKey = 'contractor_id';

    ...
}

IndexController.php

class IndexController extends Zend_Controller_Action
{
 public function saveAction()
 {
  $contractorModel = new Model_Db_Contractors();
  $aPost = $this->getRequest()->getPost();

  /* some filtering, checking, etc */

  $contractorModel->insertOrUpdate($aPost);
 }
}
1
不确定为什么要使用 array_merge(array_values($arrayData),array_values($arrayData))，但是 array_values($arrayData) 就足够了。 - Patrioticcow
好问题，我不记得为什么把它放在那里了。 - Pawel
正确的SQL查询需要将查询的第二部分（ON DUPLICATE KEY UPDATE ... = ?）与数组值绑定。 - Pawel
1
请使用以下代码：
REPLACE INTO sometable SET field ='value'.....

如果存在则更新，否则插入。这是标准mysql api的一部分。

4
不，它不会这样做。REPLACE 会删除任何匹配的现有行并插入一个新行。如果您没有插入所有值，这将导致不良行为。例如：您有一个带有 time_created 的表。如果您使用 UPDATE 而没有设置值，它将保持与创建该行时相同。如果您使用 REPLACE，则该行将被删除，一个新行将被插入，并且 time_created 将被设置为当前时间。 - apfelbox
0

更新Pawel的答案以支持单独的插入和更新数据，并且支持Zend Db表达式

  class Model_Db_Abstract extends Zend_Db_Table_Abstract
    {
        protected $_name;
        protected $_primaryKey;

        public function insertOrUpdate($arrayData)
        {
            $insertDataValuesForQuery = [];
            $queryParams = [];
            foreach ($insertData as $key => $value) {
                if (gettype($value) == "object") {
                    array_push($insertDataValuesForQuery, $value->__toString());
                    continue;
                }
                array_push($insertDataValuesForQuery, "?");
                array_push($queryParams, $value);
            }

            $updateDataValuesForQuery = [];
            foreach ($updateData as $key => $value) {
                if (gettype($value) == "object") {
                    array_push($updateDataValuesForQuery, $key . " = " . $value->__toString());
                    continue;
                }
                array_push($updateDataValuesForQuery, $key . " = ?");
                array_push($queryParams, $value);
            }

            $query = 'INSERT INTO ' . $this->_name . ' (' . implode(',', array_keys($insertData)) . ') VALUES (' . implode(',', $insertDataValuesForQuery) . ') ON DUPLICATE KEY UPDATE ' . implode(' , ', $updateDataValuesForQuery);
            return $this->getAdapter()->query($query, $queryParams);
     }
}
-8

你可以简单地这样做：

在你的id上设置唯一索引

然后

try {
   do insert here
} catch (Exception $e) {
   do update here
}
2
你可以这样做。这可能是一个可行的解决方案。但它相当低效。这就是为什么人们会对它进行负面评价的原因。 - Valery
网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接