无法使用 Bulkwrite 更新 mongo 集合

Question

我有以下字段的 mongo 集合

Sno1 Sno2 位置

集合中的数据格式

Sno1    Sno2   Location
--------------------------------
1000    2000   Hyderabad

我想将位置更新为“Chennai”。当我在 MongoCollection 类上使用 bulkWrite 方法时，它返回以下异常

Here is the snippet

mongoColl.bulkWrite(docs, writeOptions);  --> docs is List<InsertOneModel<Document>> 


BulkWriteError(index=0, code=11000, message='E11000 duplicate key error collection'

在 Sno1 和 Sno2 字段上创建了一个索引。如何更新收藏？我不想删除索引。任何想法将不胜感激

Answer 1

您可以使用com.mongodb.client.model.UpdateOneModel，因此 mongo 将尝试更新现有文档的一个（或多个）字段。

MongoDatabase db = client.getDatabase("test");
MongoCollection<Document> collection = db.getCollection("test");

List<UpdateOneModel<Document>> updateList = List.of(
                new UpdateOneModel<>(new Document(Map.of("col1", "val1")), Updates.set("field", "1")),
                new UpdateOneModel<>(new Document(Map.of("col1", "val2")), Updates.set("field", "2")));
BulkWriteOptions options = new BulkWriteOptions().ordered(false);
collection.bulkWrite(updateList, options);

如果您需要 upsert 行为，可以使用 com.mongodb.client.model.ReplaceOneModel 和 ReplaceOptions.upsert(true)：

ReplaceOptions replaceOptions = new ReplaceOptions().upsert(true);
List<ReplaceOneModel<Document>> replaceList = List.of(
                new ReplaceOneModel<>(new Document(Map.of("col1", "val3")), new Document(Map.of("col1", "val3", "field", "1")), replaceOptions),
                new ReplaceOneModel<>(new Document(Map.of("col1", "val4")), new Document(Map.of("col1", "val4", "field", "2")), replaceOptions));
collection.bulkWrite(replaceList, options);