使用“INSERT ... ON DUPLICATE KEY UPDATE”插入多条记录

Question

我的表格结构

表格：标记

我的目标： 我想用条件插入或更新多条记录

我目前正在通过此查询进行检查

第一步

SELECT * FROM `marks` WHERE `student` =115 AND `param` =1

第二步

if 
    records found by matching above criteria i just update record by my new values 
else
    insert new record into my table 

它会正常工作的。但我想减少代码并将其优化为单个查询。它可能与否？ 我在 MySQL 文档 INSERT ... ON DUPLICATE KEY UPDATE 上找到了这个。如果这是一个解决方案。如何通过查询实现？

注意：我使用的是 Yii 框架。也欢迎 Yii 的建议

已编辑： 此查询不会更新 rows 。但从插入正常工作中逃脱

INSERT INTO marks(`student`,`param,mark`,`created`,`lastmodified`,`status`) 
VALUES 
(11,30,10,'00-00-00 00:00:00','00-00-00 00:00:00','U')
ON DUPLICATE KEY UPDATE `mark`=VALUES(`mark`)

Answer 1

查看这篇文章Yii INSERT ... ON DUPLICATE UPDATE。他们建议您不要使用此功能。但我希望它使用，所以我从 CDbCommand 扩展了我自己的组件并为 ON DUPLICATE KEY UPDATE 添加方法：

public function insertDuplicate($table, $columns, $duplicates)
{
    $params=array();
    $names=array();
    $placeholders=array();
    foreach($columns as $name=>$value)
    {
        $names[]=$this->getConnection()->quoteColumnName($name);
        if($value instanceof CDbExpression)
        {
            $placeholders[] = $value->expression;
            foreach($value->params as $n => $v)
                $params[$n] = $v;
        }
        else
        {
            $placeholders[] = ':' . $name;
            $params[':' . $name] = $value;
        }
    }

    $d = array();
    foreach($duplicates as $duplicate)
    {
        $d[] = '`' . $duplicate . '` = VALUES(`'.$duplicate.'`)';
    }
    $sql='INSERT INTO ' . $this->getConnection()->quoteTableName($table)
        . ' (' . implode(', ',$names) . ') VALUES ('
        . implode(', ', $placeholders) . ') ON DUPLICATE KEY UPDATE ' . implode(', ', $d);
    return $this->setText($sql)->execute($params);
}

使用示例：

Yii::app()->db->createCommand()->insertDuplicate('user', [
   'id' => $this->id,
   'token' => $token,
   'updated' => date("Y-m-d H:i:s"),
], ['token', 'updated']);

如果记录存在，此命令将使用此参数创建用户或更新 token 和 updated 字段。

Answer 2

不要在您的编程中实现“INSERT ... ON DUPLICATE”，因为它是 MySQL 特定的。当您从 MySQL 迁移到其他数据库时，您的程序无法按照 Database Abstraction 的概念与新数据库通信

这样试试

    function actionName()
    {
        $id=$_POST['marks']['id']; //Pick the ID from your form values
        $model = Marks::model()->findByPk($id); //Check the records in the Marks table
        if (!$model) //If not found create a new Model for insertion. If records are there it will update the model
            $model = new Marks();
        $model->attributes = $_POST['marks']; //Assign the form values to attributes
        $model->save();
    }