MongoDatabase.getCollection批量增加
时间: 2023-12-27 09:03:24 浏览: 75
可以使用`MongoCollection.insertMany`方法批量插入多个文档。该方法接受一个`List`参数,其中每个元素都是一个待插入的文档。示例代码如下:
```java
List<Document> documents = new ArrayList<>();
for (int i = 0; i < 10; i++) {
Document document = new Document("key", "value" + i);
documents.add(document);
}
MongoCollection<Document> collection = database.getCollection("your_collection");
collection.insertMany(documents);
```
上述代码会向名为`your_collection`的集合中插入10个文档。
相关问题
public void deleteDocument(){ mongoDatabase =MongoUtils.getMongoConn(); MongoCollection<Document>comment =mongoDatabase.getCollection("hhlmy1collection"); comment.deleteOne(Filters.eq("_id","20")); }
这段代码是用于删除MongoDB中指定集合中的一条或多条文档数据。具体来说,它使用了MongoDB Java Driver提供的MongoDatabase对象来连接MongoDB数据库,然后通过调用getCollection()方法获取指定名称的集合对象。接着,调用deleteOne()方法并传入Filters.eq("_id","20")作为参数,表示删除该集合中_id为20的文档。如果需要删除多个文档,则可以使用deleteMany()方法并传入相应的条件参数。需要注意的是,删除文档操作会直接删除指定的文档数据,因此在进行该操作时需要谨慎,以免误删数据。
补全代码public class MongoDBJDBC{ public static void main( String args[] ){ try{ //连接到mongodb服务 MongoClient mongoClient = new MongoClient(_ (1)_ ); ; // 连接到数据库 MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol"); mongoDatabase._ (2)_ ("test"); MongoCollection collection = mongoDatabase.getCollection("test"); collection.insertOne(new Document0._ (3)_ ("name"," zhangsan")); System.out.printIn("Connect to database sucessfly"); Findlterable findlterable=collection.find(); MongoCursor mongoCursor = findlterable._ (4)_ ; while(mongoCursor._ (5)_ ){ System.out.println(mongoCursor.next(); } System.out.printIn("文档插入成功"); }catch(Exception e){ System.err.printIn( e.getClass0.getName0 + ": " + e.getMessage0 ); } } }
补全代码如下:
public class MongoDBJDBC{
public static void main( String args[] ){
try{
//连接到mongodb服务
MongoClient mongoClient = new MongoClient("localhost", 27017); ;
// 连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
mongoDatabase.createCollection("test");
MongoCollection<Document> collection = mongoDatabase.getCollection("test");
collection.insertOne(new Document("name"," zhangsan"));
System.out.println("Connect to database successfully");
FindIterable<Document> findIterable=collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}
System.out.println("文档插入成功");
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
}
}
阅读全文