mongoDB在go中使用是单表查询,每条数据的插入都是按照:数据唯一字段是否存在,存在则报错,反之,就正常插入。mongo提供了两种插入方法,insert和upsert
insert介绍
insert是插入方法,这是一个根据拼接数据库字段,自动插入的方法,但是这个方法需要我们自己提前去判断数据是否存在,然后将我们定义的body体数据给插入到mongo库中。所以就会造成我们需要两次操作数据库表。
在这里插入图片描述

在这里插入图片描述
如上图:1.我们需要定义条件,2.根据条件查询数据库判断数据是否重复,
3.自己生成一个id交给数据库,4,若是按照模拟java的MVC分层模式,那么需要对定义的参数体schema类转换为实体类entity。最后我们根据转换的实体类作为真正需要添加的body体,然后再次调用数据库操作insert插入数据。返回自定义数据id。

加粗样式这样我们发现insert需要两次去进行数据库操作,所以为了简便这个方式,mongo提供了一个可以一步直接插入的方式,即:upsert

upsert
upsert官方给出的解释是如果数据存在,则进行更新操作,如果数据不存在,则进行插入数据(也就是插入一条数据)
这里需要注意的是,在构建bson.M{}时中间有个$符号,表明需要进行什么样的操作,具体如下:

  1. update = bson.M{“$set”: insertMap} // 存在(局部)更新,不存在则插入一条数据
  2. update = bson.M{“$setOnInsert”: insertMap} // 存在什么也不做,不存在的话插入一条数据
  3. update = insertMap // 存在覆盖原数据(删除原数据后添加,相当于update),不存在则插入一条数据。
    这里的insertMap 都是转换后的map类型
    在这里插入图片描述
    如上图:1.获取可查询唯一字段,作为条件。2,这一步类似更新操作,因为这个方法参数是entity类下的参数,所以我们需要将参数给转换为map类型,这样能够保证我们对传参时没有赋值的字段进行直接剔除,不会造成传进来空结果进来(或者类似更新时,没有传递的字段,会被默认为空,覆盖掉数据库中对应的字段的值),转换map就能够解决这样的情况。3.将参数封装进bson.M{}中,这里要注意使用的是setOnInsert,这点和mongo的update方法类似。4,使用upsert方法upsert(selector,update)这个方法参数和update是一样的。5,可以根据返回结果info中的方法UpsertId获取数据库为我们自动产生的id,无需我么手动添加id了。

总结:
我的项目结构是按照MVC模式进行构架的,其中schema文件下放置的相当于java中的dto包,entity就是真正的数据关系映射。每个数据库方法传递的参数都是从schema中拿到的,所以在insert时需要我们人工进行参数转换为entity,这个主要也是为了应对上mvc这种格式,实际也可以直接传递entity类,也就是insert方法图中第四步;insert方法需要我们提前设置好判断条件,优先查询数据是否存在或者唯一字段命名是否重复等,然后在进行数据转换为entity类,最后调用insert,这是需要两次对数据库进行操作。
upsert可以理解为insert和update的结合,也就是插入之前判断数据是否存在,存在更新操作,反之插入数据。upsert类似update,需要两个sql条件,即判断条件和插入body体数据。
这两种写法都行,但是对于不同业务场景可以根据自己的需求进行使用。
小问题点:upsert在超过100个线程同时访问的情况下,可能会出现重复数据插入的问题,超过500以上,一定会出现重复插入数据问题(这个是测试得到的,数值仅仅适合我)所以需要注意到这个点。
解决办法,官网给了两种,我只用了第一种,也就是添加索引,可以是联合索引。

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐