(sequelize)bulkCreate函数中的updateOnDuplicate参数使用


前言:

Sequelize中提供的增删改查相关的函数都能转成原生的sql语句。本篇文章介绍一个不是很常见但是有时候批量插入很方便的函数——bulkCreate。

bulkCreate讲解

官方文档理解

bulkCreate() - 创建多条记录

bulkCreate(records, [options]) -> Promise.<Array.<Instance>>
复制代码

批量创建并保存多个实例。

处理成功后,会在回调函数中返回一个包含多个实例的数组。

参数

名称 类型 说明
records Array 要创建实例的对象(键/值 对)列表
[options] Object  
[options.fields] Array 要插入的字段。默认全部
[options.validate=true] Boolean 插入每条记录前进行验证
[options.hooks=true] Boolean 在执行前/后创建钩子
[options.individualHooks=false] Boolean 在执行前/后为每个实例创建钩子
[options.ignoreDuplicates=false] Boolean 忽略重复主键(Postgres不支持)
[options.updateOnDuplicate] Array 如果行键已存在是否更新(mysql & mariadb支持). 默认为更新
[options.transaction] Transaction 在事务中执行查询

注意:options.updateOnDuplicate参数中的行键已存在我的理解是:数据库表中现有的记录的唯一索引或者主键如果已经存在,执行更新操作

对应原生sql语句讲解

在MySQL数据库中,如果在insert语句后面带上ON DUPLICATE KEY UPDATE 子句。

  • 要插入的行与表中现有记录的惟一索引或主键中产生重复值,那么就会发生旧行的更新;
  • 如果插入的行数据与现有表中记录的唯一索引或者主键不重复,则执行新纪录插入操作。

 

await CompositionAnswer.bulkCreate(answerList, { updateOnDuplicate: ['answer', 'updatedAt'] })


以上代码可以实现插入多个数据时,若其中有重复的数据,只对 answer和updatedAt进行更新。

那么关键来了,怎么判定数据重复,如果我不想使用表的默认主键(比如id),怎么办?

 

答案就是 ,设置unique索引!!!

  static options = { indexes: [ { name: 'composition_answer_index', fields: [ 'exercise_id' ] }, { name: 'composition_answer_index_unique', unique: true, fields: ['exercise_id', 'question_id', 'question_material_id'] } ] } static init (sequelize) { super.init({ sequelize, attributes: this.attributes, tableName: 'composition_answer', options: this.options }) } 

composition_answer_index_unique 就是我们的唯一索引,当出现重复的数据时,不会进行插入,而是更新。

但是sequelize对于uniqueKeys设置有bug(目前最新版本6.2.3),只到上边那一步时,bulkCreate时还是没有识别到唯一索引。

hack方式就是,在attributes的字段,设置上 索引名称。

static attributes = { exerciseId: { unique: 'composition_answer_index_unique', //就是他!!! type: DataTypes.INTEGER, field: 'exercise_id' }, questionId: { unique: 'composition_answer_index_unique', // 和他!!! type: DataTypes.INTEGER, field: 'question_id' }, questionMaterialId: { unique: 'composition_answer_index_unique', // 还有他!!! type: DataTypes.INTEGER, field: 'question_material_id', allowNull: true } } 

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM