MongoDB怎样处理批量update违反唯一约束的key,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
创新互联建站是一家专业提供奇台企业网站建设,专注与成都网站建设、成都网站设计、H5开发、小程序制作等业务。10年已为奇台众多企业、政府机构等服务。创新互联专业网站设计公司优惠进行中。
MongoDB批量update一般使用upsert即可,但是这样更新可能会违反唯一建约束导致全部都没有更新(关系型数据库亦是如此),针对这个情况可以一条条更新或者加判断进行更新来保证:不违反唯一约束的行都能得到更新。下面是处理方式,供有需求的人进行参考
【背景说明】
集合名:kk_device_likes_game
唯一索引:{"device_id" : 1,
"target_type" : 1,
"target_id" : 1
}
更新内容为:db.kk_device_likes_game.update({"target_type":5,"target_id":NumberLong(1030)},{"$set":{"target_id":NumberLong(1031)}},true,true)
将满足条件为"target_type":5,"target_id":NumberLong(1030)的target_id键值的NumberLong(1030)改为NumberLong(1031)
更新会失败,因为这个集合更新字段上面有复合唯一索引,使得更新后的键值与已有的其他键值冲突。这样导致能被更新的键值却不能更新。报错如下:
【问题解决】
针对上面情况:有两条思路
方式一:遍历满足条件集合,逐条更新
思路:获取满足条件的键值,遍历其每一个_id进行逐条更新,类似sql为update … where target_type=5 and target_id=1030 and _id =…
语法如下:
var cursor = db.kk_device_likes_game.find({"target_type":5,"target_id":NumberLong(1030)}) while (cursor.hasNext()) { doc=cursor.next(); a=db.kk_device_likes_game.update({_id:doc._id,"target_type":5,"target_id":NumberLong(1030)},{"$set":{"target_id":NumberLong(1031)}}) print(a) } |
方式二:判断如果会违反约束就不更新该行
思路:获取满足条件的键值,根据复合唯一索引{"device_id" : 1,"target_type" : 1,"target_id" : 1},将device_id值跟条件为 target_type=5 and target_id=1031的 device_id进行比对,如果有一样的device_id则该行不更新。类似sql为update …where target_type=5 and target_id=1030 and device_id not in (select device_id from where target_type=5 and target_id=1031 )
语法如下:
var cursor = db.kk_device_likes_game.find({"target_type":5,"target_id":NumberLong(1030)}) while (cursor.hasNext()) { doc=cursor.next(); a=db.kk_device_likes_game.find({device_id:doc.device_id,"target_type":5,"target_id":NumberLong(1031)}).count() if ( a == 0 ){ db.kk_device_likes_game.update({_id:doc._id,"target_type":5,"target_id":NumberLong(1030)},{"$set":{"target_id":NumberLong(1031)}}); } else { print("_id:" + doc._id + "违反唯一性约束无法更新" ); } } |
【自我校验】
待更新完后,查看满足更新条件却没更新的条目数 跟 更新后会违反唯一键条目数是否相等,如果相等说明本次更新成功
查看更新会违反唯一约束的条目数:
i=0 var cursor = db.kk_device_likes_game.find({"target_type":5,"target_id":NumberLong(1030)}) while (cursor.hasNext()) { doc=cursor.next(); a=db.kk_device_likes_game.find({device_id:doc.device_id,"target_type":5,"target_id":NumberLong(1031)}).count() i=i+a } |
结果为431
查看满足更新条件却没更新的条目数:
db.kk_device_likes_game.find({"target_type":5,"target_id":NumberLong(1030)}).count() |
结果为431
二者结果一致,本次更新成功!
看完上述内容,你们掌握MongoDB怎样处理批量update违反唯一约束的key的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!