zoukankan      html  css  js  c++  java
  • MongoDB 文档的更新操作

    在MongoDB中,更新单个doc的操作是原子性的。默认情况下,如果一个update操作更新多个doc,那么对每个doc的更新是原子性的,但是对整个update 操作而言,不是原子性的,可能存在前面的doc更新成功,而后面的doc更新失败的情况。由于更新单个doc的操作是原子性的,如果两个更新同时发生,那么一个更新操作会阻塞另外一个,doc的最终结果值是由时间靠后的更新操作决定的。

    通过使用 $isolated option,能够确保更新多个doc的写操作是原子性的,任何查询操作都会读取到更新操作,直到该操作完成(成功或失败)。 

    Prevents a write operation that affects multiple documents from yielding to other reads or writes once the first document is written. By using the $isolated option, you can ensure that no client sees the changes until the operation completes or errors out.

    MongoDB在新增和更新数据的时候,不会实时写入到Disk中,可能会丢失数据。

    一,语法

    默认情况下,update只会更新single doc,如果需要更新多个doc,必须显式设置doc: multi:true。

    db.collection.update(
       <query>,
       <update>,
       {
         upsert: <boolean>,
         multi: <boolean>,
         writeConcern: <document>
       }
    )

    upsert:Optional. If set to true, creates a new document when no document matches the query criteria. The default value is false, which does not insert a new document when no match is found.

    multi:Optional. If set to true, updates multiple documents that meet the query criteria. If set to false, updates one document. The default value is false.

    二,更新示例

    在users collection中有三个doc,插入代码如下

    user1={ name:"t1", age:21}
    user2={ name:"t2", age:22}
    user3={ name:"t3", age:23}
    
    db.users.insert([user1,user2,user3])

    1,upsert option usage

    upsert option的含义是,如果collection中存在匹配的doc,那么更新该doc;如果不匹配任何doc,那么插入一条新的doc。

    使用update命令和 upsert选项,插入一条新的user,name=“t4”

    db.users.update({name:"t4"},{name:"t4"},{upsert:true})

    对新插入的user新增field:age=24,必须将doc的所有field都显式指定。

    db.users.update({age:24},{name:"t4",age:24})

    如果在Update doc中,只包含age=24,那么将失去name field,例如

     db.users.update({name:"t4"},{age:24})

    2,multi option usage

    在使用multi option更新多个doc之前,先考虑一个问题,如果把age的年纪都加1,那么在age加1时,保持其他field不变。这种情况需要用到$inc operator,用于将指定字段的值递增,同时不会影响其他字段。

    { $inc: { <field1>: <amount1>, <field2>: <amount2>, ... } }

    示例,将符合条件的User的age 加 1

    db.users.update({age:{$lt:24}},{$inc:{age:1}},{multi:true})

    3,为所有的user 增加字段

    这种scenario需要用到$set operator,用于替换指定字段的值,或新增字段。

    { $set: { <field1>: <value1>, ... } }

    The $set operator replaces the value of a field with the specified value. If the field does not exist, $set will add a new field with the specified value, provided that the new field does not violate a type constraint. If you specify a dotted path for a non-existent field, $set will create the embedded documents as needed to fulfill the dotted path to the field.

    示例,为所有的user增加sex字段,默认值是femal。

    db.users.update({},{$set:{sex:"femal"}},{multi:true})

    三,原子更新multiple doc

    在query filter中加入 $isolated:1,表示对于查询到的所有doc,update操作将会在一个原子操作中完成。

    db.users.update({$isolated:1},{$set:{sex:"femal"}},{multi:true})

    四,更新doc的结构

    1,将doc的sex field删除

    Step1,使用FindOne找到name=t4的User

    t4=db.users.findOne({name:"t4"})

    Step2,使用delete command 删除sex field

    delete t4.sex;

    Step3,使用Updae 替换原来的doc

     db.users.update({name:"t4"},t4);

    step4,使用find 查看doc的数据更新

    2,使用db.collection.replaceOne替换doc

    db.collection.replaceOne(
       <filter>,
       <replacement>,
       {
         upsert: <boolean>,
         writeConcern: <document>
       }
    )

    step1,使用findOne()查找一个doc

     t4=db.users.findOne({name:"t4"})

    step2,为doc增加一个sex field

    t4.sex="femal"

    step3,使用replaceOne函数替换doc

    db.users.replaceOne({name:"t4"},t4)

    3,使用$set对所有符合query filter的doc批量修改doc结构

    db.users.update({age:{$lte:23,$gte:21}},{$set:{sex:"femal"}},{multi:true});

    4,使用$unset对所有符合query filter的doc批量删除doc的field

    db.users.update({$and:[{age:{$lte:23}},{age:{$gte:21}}]},{$unset:{sex:"femal"}},{multi:true})
    
    --or 
    db.users.update({age:{$lte:23,$gte:21}},{$set:{sex:"femal"}},{multi:true});

    参考doc:

    Update Documents

    Atomicity and Transactions

    $isolated

    $set

  • 相关阅读:
    设计模式之单一职责原则
    设计模式之策略模式
    设计模式之简单工厂模式
    基于 Docker 的微服务架构实践
    深入理解Redis内存模型
    Spring核心——设计模式与IoC
    P9架构师讲解从单机至亿级流量大型网站系统架构的演进过程
    大型分布式网站架构:缓存在分布式系统中的应用
    阿里架构师的日志:带你快速理解微服务架构;理解微服务架构的核心
    Spring核心——Bean的定义与控制
  • 原文地址:https://www.cnblogs.com/ljhdo/p/5792938.html
Copyright © 2011-2022 走看看