Bulk.find.upsert（）_MonogDB 中文网

MongoDB 中文手册

介绍
安装
mongo shell
MongoDB CRUD操作
文字搜寻
地理空间查询
聚合
资料模型
指标
安全
更改流
复写
分片
管理
数据中心意识
存储
经常问的问题
参考
经营者
数据库命令
mongo Shell方法
收集方法
游标方法
数据库方法
查询计划缓存方法
批量操作方法
db.collection.initializeOrderedBulkOp（）
db.collection.initializeUnorderedBulkOp（）
块（）
Bulk.execute（）
Bulk.find（）
Bulk.find.arrayFilters（）
Bulk.find.collation（）
Bulk.find.hint（）
Bulk.find.remove（）
Bulk.find.removeOne（）
Bulk.find.replaceOne（）
Bulk.find.updateOne（）
Bulk.find.update（）
Bulk.find.upsert（）
Bulk.getOperations（）
Bulk.insert（）
Bulk.tojson（）
Bulk.toString（）
用户管理方法
角色管理方法
复制方法
分片方法
免费监控方法
对象构造器和方法
连接方式
Native Methods
客户端字段级加密方法
MongoDB软件包组件
配置文件选项
MongoDB服务器参数
MongoDB限制和阈值
系统集合
连接字符串URI格式
校对
MongoDB Wire协议
日志信息
退出代码和状态
词汇表
默认的MongoDB端口
服务器会话
发行说明
技术支持

参考 > 参考 > mongo Shell方法 > 批量操作方法 > Bulk.find.upsert（）

在本页面

描述
行为

小费

从3.2版开始，MongoDB还提供了db.collection.bulkWrite()执行批量写入操作的方法。

描述¶

Bulk.find.upsert（）¶

将更新或替换操作的upsert选项设置为true，并具有以下语法：

复制

Bulk.find(<query>).upsert().update(<update>);
Bulk.find(<query>).upsert().updateOne(<update>);
Bulk.find(<query>).upsert().replaceOne(<replacement>);

将upsert选项设置为true，如果条件不存在匹配的文档Bulk.find()，则更新或替换操作将执行插入。如果存在匹配的文档，则更新或替换操作将执行指定的更新或替换。

使用Bulk.find.upsert()具有以下写操作：

行为¶

下面描述了与结合使用时各种写入操作的插入行为Bulk.find.upsert()。

插入`Bulk.find.replaceOne()`¶

该Bulk.find.replaceOne()方法接受仅包含字段和值对的替换文档作为其参数：

复制

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { item: "abc123" } ).upsert().replaceOne(
   {
     item: "abc123",
     status: "P",
     points: 100,
   }
);
bulk.execute();

如果使用该Bulk.find.upsert() 选项进行替换操作执行插入操作，则插入的文档就是替换文档。如果替换文档和查询文档均未指定_id字段，则MongoDB将添加该_id字段：

复制

{
  "_id" : ObjectId("52ded3b398ca567f5c97ac9e"),
  "item" : "abc123",
  "status" : "P",
  "points" : 100
}

插入`Bulk.find.updateOne()`¶

该Bulk.find.updateOne()方法接受以下参数作为其参数：

仅包含字段和值对（与相同Bulk.find.replaceOne()）的替换文档，
仅包含更新运算符表达式的更新文档，或者
聚合管道（从MongoDB 4.2开始）。

字段和值对¶

如果参数是仅包含字段和值对的替换文档：

复制

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "P" } ).upsert().updateOne(
   {
     item: "TBD",
     points: 0,
     inStock: true,
     status: "I"
   }
);
bulk.execute();

然后，如果使用该Bulk.find.upsert() 选项进行更新操作执行插入操作，则插入的文档就是替换文档。如果替换文档和查询文档均未指定_id字段，则MongoDB将添加该_id字段：

复制

{
  "_id" : ObjectId("52ded5a898ca567f5c97ac9f"),
  "item" : "TBD",
  "points" : 0,
  "inStock" : true,
  "status" : "I"
}

更新运算符表达式¶

如果参数是仅包含更新运算符表达式的更新文档：

复制

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "P", item: null } ).upsert().updateOne(
   {
     $setOnInsert: { qty: 0, inStock: true },
     $set: { points: 0 }
   }
);
bulk.execute();

然后，如果带有Bulk.find.upsert() 选项的更新操作执行插入操作，则更新操作将插入带有Bulk.find()方法查询文档中具有字段和值的文档，然后应用更新文档中的指定更新。如果更新文档和查询文档均未指定_id字段，则MongoDB将添加该_id字段：

复制

{
   "_id" : ObjectId("5e28d1a1500153bc2872dadd"),
   "item" : null,
   "status" : "P",
   "inStock" : true,
   "points" : 0,
   "qty" : 0
}

聚合管道¶

从4.2版开始，更新方法可以接受聚合管道。例如，以下用途：

该$replaceRoot阶段可以提供与$setOnInsert 更新运算符表达式类似的行为，
$set可以提供与$set更新运算符表达式相似的行为的阶段，
聚合变量NOW，它解析为当前日期时间，并且可以提供与$currentDate更新运算符表达式类似的行为。

复制

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { item: "Not Found", status: "P" } ).upsert().updateOne(
   [
      { $replaceRoot: { newRoot: { $mergeObjects: [ { qty: 0, inStock: true }, "$$ROOT"  ] } } },
      { $set: { points: 0, lastModified: "$$NOW" } }
   ]
);
bulk.execute();

然后，如果带有该Bulk.find.upsert() 选项的更新操作执行插入操作，则更新操作将插入具有该Bulk.find() 方法的查询文档中的字段和值的文档，然后应用指定的聚合管道。如果更新文档和查询文档均未指定_id字段，则MongoDB将添加该_id字段：

{
   "_id" : ObjectId("5e28cf1e500153bc2872d49f"),
   "qty" : 0,
   "inStock" : true,
   "item" : "Not Found",
   "status" : "P",
   "points" : 0,
   "lastModified" : ISODate("2020-01-22T22:39:26.789Z")
}

插入`Bulk.find.update()`¶

当使用upsert()与多文档更新方法Bulk.find.update()，如果没有文件匹配查询条件，更新操作插入一个单一的文件。

该Bulk.find.update()方法接受以下参数作为其参数：

仅包含更新运算符表达式的更新文档，或者
聚合管道（从MongoDB 4.2开始）。

更新运算符表达式¶

如果参数是仅包含更新运算符表达式的更新文档：

复制

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "P" } ).upsert().update(
   {
     $setOnInsert: { qty: 0, inStock: true },
     $set: { status: "I", points: "0" }
   }
);
bulk.execute();

然后，如果带有Bulk.find.upsert() 选项的更新操作执行插入操作，则更新操作将插入具有Bulk.find()方法查询文档中字段和值的单个文档，然后从更新文档中应用指定的更新。如果更新文档和查询文档均未指定_id字段，则MongoDB将添加该_id字段：

复制

{
   "_id": ObjectId("52ded81a98ca567f5c97aca1"),
   "status": "I",
   "qty": 0,
   "inStock": true,
   "points": "0"
}

聚合管道¶

从4.2版开始，更新方法可以接受聚合管道。例如，以下用途：

该$replaceRoot阶段可以提供与$setOnInsert 更新运算符表达式类似的行为，
$set可以提供与$set更新运算符表达式相似的行为的阶段，
聚合变量NOW，它解析为当前日期时间，并且可以提供与$currentDate更新运算符表达式类似的行为。在NOW整个管道中，的值保持不变。要访问聚合变量，请在变量前加双美元符号 $$并用引号引起来。

复制

var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { item: "New Item", status: "P" } ).upsert().update(
   [
      { $replaceRoot: { newRoot: { $mergeObjects: [ { qty: 0, inStock: true }, "$$ROOT"  ] } } },
      { $set: { points: 0, lastModified: "$$NOW" } }
   ]
);
bulk.execute();

然后，如果带有Bulk.find.upsert() 选项的更新操作执行插入操作，则更新操作将插入单个文档以及该Bulk.find()方法的查询文档中的字段和值，然后应用聚合管道。如果更新文档和查询文档均未指定 _id字段，则MongoDB将添加该_id字段：

{
   "_id" : ObjectId("5e2920a5b4c550aad59d18a1"),
   "qty" : 0,
   "inStock" : true,
   "item" : "New Item",
   "status" : "P",
   "points" : 0,
   "lastModified" : ISODate("2020-01-23T04:27:17.780Z")
}

也可以看看

MongoDB 中文手册

Bulk.find.upsert（）

描述¶

行为¶

插入Bulk.find.replaceOne()¶

插入Bulk.find.updateOne()¶

字段和值对¶

更新运算符表达式¶

聚合管道¶

插入Bulk.find.update()¶

更新运算符表达式¶

聚合管道¶

插入`Bulk.find.replaceOne()`¶

插入`Bulk.find.updateOne()`¶

插入`Bulk.find.update()`¶