怎么使用java操作mongodb更新整个文档

Posted 2023-04-04

参考技术A 上篇博客介绍了java操作mongoDB进行对文件的处理。现在来介绍一下对文档的处理。和对文件的处理一样，也是通过java驱动中提供的几个类相互作用完成的。这几个类分别是：
DBCollection类：指定数据库中指定集合的实例，提供了增删改查等一系列操作。在关系型数据库中，对数据的增删改查操作是建立在表的基础上的，在mongodb中是建立在集合的基础上进行的。
DBObject接口：DBObject是键值的映射，因此，可以将DBObject的实现类作为查询的返回结果，也可以作为查询条件
DBCursor：游标，返回结果的集合。
下面是部分实例：

[java] view plaincopy
Mongo mongo = new Mongo();
DB db = mongo.getDB("myMongoDB");
DBCollection course = db.getCollection("course");//对myMongoDB数据库中course集合进行操作

//添加操作
//下面分别是创建文档的几种方式：1. .append() 2. .put() 3. 通过map 4. 将json转换成DBObject对象
DBObject english = new BasicDBObject().append("name","english").append("score", 5).append("id",1);
course.insert(english);

DBObject math = new BasicDBObject();
math.put("id", 2);
math.put("name", "math");
math.put("score", 10);
course.insert(math);

Map<String,Object> map = new HashMap<String,Object>();
map.put("name","physics" );
map.put("score", 10);
map.put("id", 3);
DBObject physics= new BasicDBObject(map);
course.insert(physics);

String json ="'name':'chemistry','score':10,'id':4";
DBObject chemistry =(DBObject)JSON.parse(json);
course.insert(chemistry);

List<DBObject> courseList = new ArrayList<DBObject>();
DBObject chinese = new BasicDBObject().append("name","chinese").append("score", 10).append("id", 5);
DBObject history = new BasicDBObject().append("name", "history").append("score", 10).append("id", 6);
courseList.add(chinese);
courseList.add(history);
course.insert(courseList);

//添加内嵌文档
String json2 =" 'name':'english','score':10,'teacher':['name':'柳松','id':'1','name':'柳松松','id':2]";
DBObject english2= (DBObject)JSON.parse(json);
course.insert(english2);

List<DBObject> list = new ArrayList<DBObject>();
list.add(new BasicDBObject("name","柳松").append("id",1));
list.add(new BasicDBObject("name","柳松松").append("id",2));
DBObject english3= new BasicDBObject().append("name","english").append("score",10).append("teacher",list);

//查询
//查询所有、查询一个文档、条件查询
DBCursor cur = course.find();
while(cur.hasNext())
DBObject document = cur.next();
System.out.println(document.get("name"));


DBObject document = course.findOne();
String name=(String)document.get("name");
System.out.println(name);

//查询学分=5的
DBObject query1 = new BasicDBObject("score",5);
DBObject query2 = new BasicDBObject("score",new BasicDBObject("$gte",5));
DBCursor cur2 = course.find(query2);
//条件表达式：$ge(>) $get(>=) $lt(<) $lte(<=) $ne(<>) $in $nin $all $exists $or $nor $where $type等等

//查找并修改
DBObject newDocument = course.findAndModify(new BasicDBObject("score",5), new BasicDBObject("score",15));

//更新操作
//q：更新条件 o:更新后的对象
course.update(new BasicDBObject("score",10), new BasicDBObject("test",15));
course.update(new BasicDBObject("score",15), new BasicDBObject("$set",new BasicDBObject("isRequired",true)));
//两个的区别是，第一个更新是将"test":15这个文档替换原来的文档，
//第二个更新添加了条件表达式$set，是在原来文档的基础上添加"isRequired"这个键
//条件表达式：$set $unset $push $inc $push $push $addToSet $pull $pullAll $pop等等

//当_id相同时，执行save方法相当于更新操作
course.save(new BasicDBObject("name","math").append("_id", 1));
course.save(new BasicDBObject("name","数学").append("_id", 1));

//删除符合条件的文档
course.remove(new BasicDBObject("score",15));

//删除集合及所有文档
course.drop();<span style="font-family:Arial, Helvetica, sans-serif;"><span style="white-space: normal;">
</span></span>

上面只是介绍了一些简单的操作，具体复杂的查询更新可以根据需求再去查找文档资料。其实，不管操作简单还是复杂，其核心都是对DBObject和DBCollection的操作，主要掌握DBObject如何构造键值对，以及一些条件表达式。本回答被提问者和网友采纳

如何使用 Java 对 MongoDB 中的文档进行批量更新？

【中文标题】如何使用 Java 对 MongoDB 中的文档进行批量更新？

【英文标题】：How to perform a bulk update of documents in MongoDB with Java?

【发布时间】：2016-06-21 03:57:05

【问题描述】：

我正在使用 MongoDB 3.2 和 MongoDB Java 驱动程序 3.2。我有一个包含数百个更新文档的数组，现在应该保存/存储在 MongoDB 中。为了做到这一点，我遍历数组并为这个数组中的每个文档调用updateOne() 方法。

现在，我想通过批量更新重新实现这个逻辑。我尝试使用 MongoDB Java Driver 3.2 在 MongoDB 3.2 中查找批量更新的示例。

我试过这段代码：

MongoClient mongo = new MongoClient("localhost", 27017);

DB db = (DB) mongo.getDB("test1");
DBCollection collection = db.getCollection("collection");
BulkWriteOperation builder = collection.initializeUnorderedBulkOperation();

builder.find(new BasicDBObject("_id", 1001)).upsert()
    .replaceOne(new BasicDBObject("_id", 1001).append("author", "newName"));

builder.execute();

但似乎这种方法基于过时的 MongoDB Java 驱动程序，例如 2.4，并且使用了已弃用的方法。

我的问题： 如何使用 MongoDB Java Driver 3.2 批量更新 MongoDB 3.2 中的文档？

【问题讨论】：

看详细例子***.com/a/39356860/4437074

【参考方案1】：

使用新 bulkWrite() API 手册中的示例，考虑以下包含以下文档的测试集合：

 "_id" : 1, "char" : "Brisbane", "class" : "monk", "lvl" : 4 ,
 "_id" : 2, "char" : "Eldon", "class" : "alchemist", "lvl" : 3 ,
 "_id" : 3, "char" : "Meldane", "class" : "ranger", "lvl" : 3 

以下bulkWrite()对characters集合执行多项操作：

---

Mongo shell：

try 
    db.characters.bulkWrite([
         
            insertOne:
                "document":
                    "_id" : 4, "char" : "Dithras", "class" : "barbarian", "lvl" : 4
                
            
        ,
         
            insertOne:
                "document": 
                    "_id" : 5, "char" : "Taeln", "class" : "fighter", "lvl" : 3
                
            
        ,
         
            updateOne: 
                "filter" :  "char" : "Eldon" ,
                "update" :  $set :  "status" : "Critical Injury"  
            
        ,
         
            deleteOne:  "filter" :  "char" : "Brisbane" 
        ,
         
            replaceOne: 
               "filter" :  "char" : "Meldane" ,
               "replacement" :  "char" : "Tanys", "class" : "oracle", "lvl" : 4 
            
        
    ]);

catch (e)   print(e); 

打印输出：

   "acknowledged" : true,
   "deletedCount" : 1,
   "insertedCount" : 2,
   "matchedCount" : 2,
   "upsertedCount" : 0,
   "insertedIds" : 
      "0" : 4,
      "1" : 5
   ,
   "upsertedIds" : 

   

---

等效的 Java 3.2 实现如下：

MongoCollection<Document> collection = db.getCollection("characters");
List<WriteModel<Document>> writes = new ArrayList<WriteModel<Document>>();
writes.add(
    new InsertOneModel<Document>(
        new Document("_id", 4)
            .append("char", "Dithras")
            .append("class", "barbarian")
            .append("lvl", 3)
    )
);
writes.add(
    new InsertOneModel<Document>(
        new Document("_id", 5)
            .append("char", "Taeln")
            .append("class", "fighter")
            .append("lvl", 4)
    )
);
writes.add(
    new UpdateOneModel<Document>(
        new Document("char", "Eldon"), // filter
        new Document("$set", new Document("status", "Critical Injury")) // update
    )
);
writes.add(new DeleteOneModel<Document>(new Document("char", "Brisbane")));
writes.add(
    new ReplaceOneModel<Document>(
        new Document("char", "Meldane"), 
        new Document("char", "Tanys")
            .append("class", "oracle")
            .append("lvl", 4)           
    )
);

BulkWriteResult bulkWriteResult = collection.bulkWrite(writes);

---

对于您的问题，请使用 replaceOne() 方法，这将被实现为

MongoCollection<Document> collection = db.getCollection("collection");
List<WriteModel<Document>> writes = Arrays.<WriteModel<Document>>asList(
    new ReplaceOneModel<Document>(
        new Document("_id", 1001), // filter
        new Document("author", "newName"), // update
        new UpdateOptions().upsert(true) // options
    )   
);

BulkWriteResult bulkWriteResult = collection.bulkWrite(writes);

【讨论】：

我不知道，但MongoDB Limits and Thresholds 仍然适用。

太好了，谢谢。两个问题。 1. MongoDB中的单次更新到批量更新有什么规定吗？我的意思是从规则的文件数量来看。 2.关于replaceOne()，我所有更新的文档都包含一二字段的更新。为什么我应该使用这种方法而不是updateOne()？据我了解，replaceOne() 会替换整个文档，而updateOne() 可能只是更新特定字段的值，应该更快吧？

@MikeB。我认为这需要一个新问题，因为这与您最初提出的问题不同。如果您发布另一个问题，我会像其他人一样乐意回答。这里的一般情况是一问一答。我可以回答您的其他问题，但这应该完全是另一个问题。请单独发布。

@MikeB。一般的答案是replaceOne 替换集合中与过滤器匹配的单个文档。如果多个文档匹配，replaceOne 将仅替换第一个匹配的文档。 updateOne() 根据过滤器更新集合中的单个文档。如果指定了upsert: true 选项并且没有文档匹配过滤器，则使用过滤器中的相等比较和更新中的修改创建一个新文档。如果过滤器只有比较操作，那么只有更新中的修改将应用于新文档。

我发布了一个单独的问题：***.com/questions/35848688/…