db.collection.findAndModify()

    在本页面

    • 定义

    • Return 数据

    • 行为

    • 例子

      定义

    • db.collection. findAndModify(文件)

      • 修改并返回单个文档。默认情况下,返回的文档不包括对更新所做的修改。要通过对更新进行的修改来回显文档,请使用new选项。 findAndModify()方法是findAndModify命令周围的 shell 助手。

    findAndModify()方法具有以下形式:

    更改了 version 3.6.

    1. db.collection.findAndModify({
    2. query: <document>,
    3. sort: <document>,
    4. remove: <boolean>,
    5. update: <document>,
    6. new: <boolean>,
    7. fields: <document>,
    8. upsert: <boolean>,
    9. bypassDocumentValidation: <boolean>,
    10. writeConcern: <document>,
    11. collation: <document>,
    12. arrayFilters: [ <filterdocument1>, ... ]
    13. });

    db.collection.findAndModify()方法采用带有以下嵌入文档字段的文档参数:

    参数 类型 描述
    query document 可选的。修改的选择标准。 query字段使用与db.collection.find()方法中使用的query selectors相同的query selectors。虽然查询可能匹配多个文档,但findAndModify() 只会选择一个文档来修改
    如果未指定,则默认为空文档。
    从 MongoDB 3.6.14(和 3.4.23)开始,如果查询参数不是文档,则操作错误。
    sort document 可选的。如果查询选择多个文档,则确定操作修改的文档。 findAndModify()修改此参数指定的 sort order 中的第一个文档。
    从 MongoDB 3.6.14(和 3.4.23)开始,如果 sort 参数不是文档,则操作错误。
    remove boolean 必须指定removeupdate字段。删除query字段中指定的文档。将其设置为true以删除所选文档。默认值为false
    update document 必须指定removeupdate字段。执行所选文档的更新。 update字段使用相同的更新 operators或field: value规范来修改所选文档。
    new boolean 可选的。当true时,返回修改后的文档而不是原始文档。 findAndModify()方法忽略remove操作的new选项。默认值为false
    fields document 可选的。 return 的字段子集。 fields文档指定包含1的字段,如:fields: { <field1>: 1, <field2>: 1, ... }。见投影。
    从 MongoDB 3.6.14(和 3.4.23)开始,如果 fields 参数不是文档,则操作错误。
    upsert boolean 可选的。与update字段结合使用。
    true,findAndModify()时:
    如果没有文件匹配query,则创建一个新文档。有关详细信息,请参阅upsert 行为。
    更新与query匹配的单个文档。
    要避免多次 upsert,请确保query字段为唯一索引。
    默认为false
    bypassDocumentValidation boolean 可选的。允许db.collection.findAndModify在操作期间绕过文档验证。这使您可以更新不符合验证要求的文档。
    version 3.2 中的新内容。
    writeConcern document 可选的。表示写关注的文件。省略使用默认写入问题。
    version 3.2 中的新内容。
    maxTimeMS integer 可选的。指定处理操作的 time 限制(以毫秒为单位)。
    collation document 可选的。
    指定要用于操作的整理。
    整理允许用户为 string 比较指定 language-specific 规则,例如字母和重音标记的规则。
    排序规则选项具有以下语法:
    排序规则:{
    locale:<string>,
    caseLevel:<boolean>,
    caseFirst:<string>,
    strength:<int>,
    numericOrdering:<boolean>,
    alternate:<string>,
    maxVariable:<string>,
    backwards :<boolean>
    }
    指定排序规则时,locale字段是必填字段;所有其他校对字段都是可选的。有关字段的说明,请参阅整理文件。
    如果未指定排序规则但集合具有默认排序规则(请参阅db.createCollection()),则操作将使用为集合指定的排序规则。
    如果没有为集合或操作指定排序规则,MongoDB 使用先前版本中用于 string 比较的简单二进制比较。
    您无法为操作指定多个排序规则。对于 example,您不能为每个字段指定不同的排序规则,或者如果使用排序执行查找,则不能对查找使用一个排序规则,而对排序使用另一个排序规则。
    version 3.4 中的新内容。
    arrayFilters array 可选的。过滤器文档的 array,用于确定要在 array 字段上为更新操作修改哪些 array 元素。
    在更新文档中,使用$ [<identifier>]过滤后的位置 operator 来定义标识符,然后在 array 过滤器文档中进行 reference。如果标识符未包含在更新文档中,则不能为标识符提供 array 过滤器文档。
    注意
    <identifier>必须以小写字母开头,并且只包含字母数字字符。
    您可以在更新文档中多次包含相同的标识符;但是,对于更新文档中的每个不同标识符($[identifier]),您必须指定恰好一个对应的 array 过滤器文档。也就是说,您不能为同一标识符指定多个 array 过滤器文档。对于 example,如果 update 语句包含标识符x(可能多次),则不能为arrayFilters指定以下内容,其中包含 2 个单独的x过滤器文档:
    [
    { “x.a”: { $gt: 85 } },
    { “x.b”: { $gt: 80 } }
    ]
    但是,您可以在同一标识符上指定复合条件单个过滤器文档,例如以下示例:
    // Example 1
    [
    { $or: [{“x.a”: {$gt: 85}}, {“x.b”: {$gt: 80}}] }
    ]
    // Example 2
    [
    { $and: [{“x.a”: {$gt: 85}}, {“x.b”: {$gt: 80}}] }
    ]
    // Example 3
    [
    { “x.a”: { $gt: 85 }, “x.b”: { $gt: 80 } }
    ]
    例如,请参阅为 Array Update Operations 指定 arrayFilters。
    version 3.6 中的新内容。

    Return 数据

    对于删除操作,如果查询与文档匹配,findAndModify()将返回已删除的文档。如果查询未匹配要删除的文档,findAndModify()将返回null

    对于更新操作,findAndModify()返回以下之一:

    • 如果未设置new参数或false
      • 如果查询与文档匹配,则为 pre-modification 文档;
      • 否则,null
    • 如果newtrue
      • 修改后的文档,如果查询返回 match;
      • 插入的文档,如果upsert: true,没有文档与查询匹配;
      • 否则,null

    更改 version 3.0:在以前的版本中,如果更新,sort已指定,upsert: truenew选项未设置或new: false,db.collection.findAndModify()将返回空文档{}而不是null

    行为

    Upsert 和 Unique Index

    当findAndModify()包含upsert: true选项并且查询 field(s)没有唯一索引时,该方法可以在某些情况下多次插入文档。

    在下面的示例中,不存在 name Andy的文档,并且多个 clients 发出以下命令:

    1. db.people.findAndModify({
    2. query: { name: "Andy" },
    3. sort: { rating: 1 },
    4. update: { $inc: { score: 1 } },
    5. upsert: true
    6. })

    然后,如果这些 clients 的findAndModify()方法在任何命令启动modify阶段之前完成query阶段,name字段上没有唯一索引,则命令可以全部执行 upsert,创建多个重复文档。

    要防止使用相同的 name 创建多个重复文档,请在name字段上创建独特的指数。有了这个唯一索引,多个方法将表现出以下行为之一:

    • 正好一个findAndModify()成功插入一个新文档。
    • 零个或多个findAndModify()方法更新新插入的文档。
    • 零个或多个findAndModify()方法在尝试 Insert 具有相同 name 的文档时失败。如果由于name字段上的唯一索引约束违规而导致方法失败,则可以重试该方法。如果没有删除文档,则重试不应失败。

      Sharded Collections

    在分片环境中使用findAndModify时,query 必须包含针对分片集合的分片 cluster 的所有操作的碎片 key。

    findAndModify针对非分片集合的mongos实例发出的操作正常运行。

    从MongoDB 4.2开始,您可以更新文档的分片键值,除非分片键字段是不可变_id字段。有关更新分片键的详细信息,请参见更改文档的分片键值。

    在MongoDB 4.2之前,文档的分片键字段值是不可变的。

    文件验证

    db.collection.findAndModify()方法添加了对bypassDocumentValidation选项的支持,该选项允许您在使用验证规则插入或更新集合中的文档时绕过文件验证。

    与update方法的比较

    更新文档时,findAndModify()和update()方法的操作方式不同:

    • 默认情况下,两个操作都会修改单个文档。但是,带有multi选项的update()方法可以修改多个文档。
    • 如果多个文档匹配更新条件,对于findAndModify(),您可以指定sort以提供对要更新的文档的某种控制措施。

    使用update()方法的默认行为,您无法在多个文档 match 时指定要更新的单个文档。

    • 默认情况下,findAndModify()返回文档的 pre-modified version。要获取更新的文档,请使用new选项。

      update()方法返回包含操作状态的写结果 object。要 return 更新的文档,请使用find()方法。但是,其他更新可能已在您的更新和文档检索之间修改了文档。此外,如果更新仅修改了单个文档但匹配了多个文档,则需要使用其他逻辑来标识更新的文档。

    修改单个文档时,findAndModify()和update()方法都会自动更新文档。有关这些方法的操作的交互和顺序的更多详细信息,请参阅原子性和 Transactions。

    事务

    db.collection.findAndModify()可以在多文档交易中使用。

    重要

    在大多数情况下,与单文档写入相比,多文档事务产生的性能成本更高,并且多文档事务的可用性不应替代有效的架构设计。在许多情况下, 非规范化数据模型(嵌入式文档和数组)将继续是您的数据和用例的最佳选择。也就是说,在许多情况下,适当地对数据建模将最大程度地减少对多文档交易的需求。

    有关其他事务使用方面的注意事项(例如运行时限制和操作日志大小限制),另请参见 生产注意事项。

    现有的收藏和交易

    在事务内部,您可以指定对现有集合的读/写操作。如果db.collection.findAndModify()导致upsert,则该集合必须已经存在。

    写的担忧和事务

    如果在事务中运行,请不要为操作明确设置写关注点。要对事务使用写关注,请参见 事务和写关注。

    例子

    更新和 Return

    以下方法更新并返回文档与查询条件匹配的人员集合中的现有文档:

    1. db.people.findAndModify({
    2. query: { name: "Tom", state: "active", rating: { $gt: 10 } },
    3. sort: { rating: 1 },
    4. update: { $inc: { score: 1 } }
    5. })

    此方法执行以下操作:

    • querypeople集合中查找name字段具有 value Tomstate字段具有 value activerating字段具有 value greater than 10 的文档。

    • sort以升序 order 命令查询结果。如果多个文档符合query条件,则该方法将选择修改此sort所订购的第一个文档。

    • 更新increments score字段的 value 为 1。

    • 该方法返回为此更新选择的原始(i.e.pre-modification)文档:

      1. {
      2. "_id" : ObjectId("50f1e2c99beb36a0f45c6453"),
      3. "name" : "Tom",
      4. "state" : "active",
      5. "rating" : 100,
      6. "score" : 5
      7. }

    要 return 修改的文档,请将new:true选项添加到方法中。

    如果没有文档与query条件匹配,则该方法返回null

    UPSERT

    以下方法包括update选项的upsert: true选项,用于更新匹配的文档;如果不存在匹配的文档,则创建新文档:

    1. db.people.findAndModify({
    2. query: { name: "Gus", state: "active", rating: 100 },
    3. sort: { rating: 1 },
    4. update: { $inc: { score: 1 } },
    5. upsert: true
    6. })

    如果方法找到匹配的文档,则该方法执行更新。

    如果方法找到匹配的文档,则该方法创建一个新文档。因为该方法包含sort选项,所以它返回一个空文档{ }作为原始(pre-modification)文档:

    1. { }

    如果方法确实**不包含sort选项,则该方法返回null

    1. null

    返回新文档

    以下方法包括upsert: true选项和new:true选项。该方法更新匹配的文档并返回更新的文档,或者,如果不存在匹配的文档,则插入文档并在value字段中返回新插入的文档。

    在以下 example 中,people集合中的任何文档都不匹配query条件:

    1. db.people.findAndModify({
    2. query: { name: "Pascal", state: "active", rating: 25 },
    3. sort: { rating: 1 },
    4. update: { $inc: { score: 1 } },
    5. upsert: true,
    6. new: true
    7. })

    该方法返回新插入的文档:

    1. {
    2. "_id" : ObjectId("50f49ad6444c11ac2448a5d6"),
    3. "name" : "Pascal",
    4. "rating" : 25,
    5. "score" : 1,
    6. "state" : "active"
    7. }

    排序和删除

    通过在rating字段上包含sort规范,以下 example 将从people集合中删除state value 为active且匹配文档中最低rating的单个文档:

    1. db.people.findAndModify(
    2. {
    3. query: { state: "active" },
    4. sort: { rating: 1 },
    5. remove: true
    6. }
    7. )

    该方法返回已删除的文档:

    1. {
    2. "_id" : ObjectId("52fba867ab5fdca1299674ad"),
    3. "name" : "XYZ123",
    4. "score" : 1,
    5. "state" : "active",
    6. "rating" : 3
    7. }

    指定排序规则

    version 3.4 中的新内容。

    整理允许用户为 string 比较指定 language-specific 规则,例如字母和重音标记的规则。

    集合myColl具有以下文档:

    1. { _id: 1, category: "café", status: "A" }
    2. { _id: 2, category: "cafe", status: "a" }
    3. { _id: 3, category: "cafE", status: "a" }

    以下操作包括整理选项:

    1. db.myColl.findAndModify({
    2. query: { category: "cafe", status: "a" },
    3. sort: { category: 1 },
    4. update: { $set: { status: "Updated" } },
    5. collation: { locale: "fr", strength: 1 }
    6. });

    该操作返回以下文档:

    1. { "_id" : 1, "category" : "café", "status" : "A" }

    为 Array Update Operations 指定 arrayFilters

    注意

    arrayFilters 不适用于使用聚合管道的更新。

    version 3.6 中的新内容。

    从 MongoDB 3.6 开始,在更新 array 字段时,您可以指定arrayFilters来确定要更新的 array 元素。

    更新元素 Match arrayFilters Criteria

    使用以下文档创建集合students

    1. db.students.insert([
    2. { "_id" : 1, "grades" : [ 95, 92, 90 ] },
    3. { "_id" : 2, "grades" : [ 98, 100, 102 ] },
    4. { "_id" : 3, "grades" : [ 95, 110, 100 ] }
    5. ])

    要修改grades array 中大于或等于100的所有元素,请使用过滤后的位置 operator $ [<identifier> ]和db.collection.findAndModify方法中的arrayFilters选项:

    1. db.students.findAndModify({
    2. query: { grades: { $gte: 100 } },
    3. update: { $set: { "grades.$[element]" : 100 } },
    4. arrayFilters: [ { "element": { $gte: 100 } } ]
    5. })

    该操作更新单个文档的grades字段,在操作之后,该集合具有以下文档:

    1. { "_id" : 1, "grades" : [ 95, 92, 90 ] }
    2. { "_id" : 2, "grades" : [ 98, 100, 100 ] }
    3. { "_id" : 3, "grades" : [ 95, 110, 100 ] }

    更新 Array 文档的特定元素

    使用以下文档创建集合students2

    1. db.students2.insert([
    2. {
    3. "_id" : 1,
    4. "grades" : [
    5. { "grade" : 80, "mean" : 75, "std" : 6 },
    6. { "grade" : 85, "mean" : 90, "std" : 4 },
    7. { "grade" : 85, "mean" : 85, "std" : 6 }
    8. ]
    9. },
    10. {
    11. "_id" : 2,
    12. "grades" : [
    13. { "grade" : 90, "mean" : 75, "std" : 6 },
    14. { "grade" : 87, "mean" : 90, "std" : 3 },
    15. { "grade" : 85, "mean" : 85, "std" : 4 }
    16. ]
    17. }
    18. ])

    要修改grades array 中等级大于或等于85的所有元素的mean字段的 value,请使用过滤后的位置 operator $ [<identifier> ]和db.collection.findAndModify方法中的arrayFilters

    1. db.students2.findAndModify({
    2. query: { },
    3. update: { $set: { "grades.$[elem].mean" : 100 } },
    4. arrayFilters: [ { "elem.grade": { $gte: 85 } } ]
    5. })

    该操作更新单个文档的grades字段,在操作之后,该集合具有以下文档:

    1. {
    2. "_id" : 1,
    3. "grades" : [
    4. { "grade" : 80, "mean" : 75, "std" : 6 },
    5. { "grade" : 85, "mean" : 100, "std" : 4 },
    6. { "grade" : 85, "mean" : 100, "std" : 6 }
    7. ]
    8. }
    9. {
    10. "_id" : 2,
    11. "grades" : [
    12. { "grade" : 90, "mean" : 75, "std" : 6 },
    13. { "grade" : 87, "mean" : 90, "std" : 3 },
    14. { "grade" : 85, "mean" : 85, "std" : 4 }
    15. ]
    16. }

    使用聚合管道进行更新

    从MongoDB 4.2开始,db.collection.findAndModify()可以接受聚合管道进行更新。管道可以包括以下阶段:

    • $addFields及其别名 $set
    • $project及其别名 $unset
    • $replaceRoot及其别名$replaceWith

    使用聚合管道可以实现更具表达力的更新语句,例如根据当前字段值表达条件更新,或使用另一个字段的值更新一个字段。

    例如,students2使用以下文档创建一个集合:

    1. db.students2.insert([
    2. {
    3. "_id" : 1,
    4. "grades" : [
    5. { "grade" : 80, "mean" : 75, "std" : 6 },
    6. { "grade" : 85, "mean" : 90, "std" : 4 },
    7. { "grade" : 85, "mean" : 85, "std" : 6 }
    8. ]
    9. },
    10. {
    11. "_id" : 2,
    12. "grades" : [
    13. { "grade" : 90, "mean" : 75, "std" : 6 },
    14. { "grade" : 87, "mean" : 90, "std" : 3 },
    15. { "grade" : 85, "mean" : 85, "std" : 4 }
    16. ]
    17. }
    18. ])

    以下操作将查找一个_id字段等于 的文档,1并使用聚合管道total从该grades字段中计算一个新 字段:

    1. db.students2.findAndModify( {
    2. query: { "_id" : 1 },
    3. update: [ { $set: { "total" : { $sum: "$grades.grade" } } } ], // The $set stage is an alias for ``$addFields`` stage
    4. new: true
    5. } )

    注意

    $set管道中的使用是指聚集阶段 $set,而不是更新操作$set。

    该操作返回更新的文档:

    1. {
    2. "_id" : 1,
    3. "grades" : [ { "grade" : 80, "mean" : 75, "std" : 6 }, { "grade" : 85, "mean" : 90, "std" : 4 }, { "grade" : 85, "mean" : 85, "std" : 6 } ],
    4. "total" : 250
    5. }

    也可以看看

    可线性化通过 findAndModify 读取

    译者:李冠飞

    校对:

    参见

    原文 - db.collection.findAndModify()