概述

当需要插入、更新或删除大量文档时，一次执行多个操作比分别执行每个操作要快得多。批量操作减少了网络往返次数，减少了 I/O 负载，并且可能允许数据库引擎更有效地利用内部缓存和其他资源。 在 MongoDB 中进行批量读写操作，有多种方法，可以使用 `insertMany`、`BulkWrite`、多线程等方法。本文以三个简单的示例，展示如何使用 Java 驱动程序进行批量读写操作。

示例

使用 `insertMany` `insertMany` 方法允许一次插入多个文档到一个集合中。语法如下： ```java BulkWriteResult result = collection.insertMany(List documents); ``` 示例代码如下： ```java import com.mongodb.MongoClient; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import org.bson.Document; public class InsertManyExample { public static void main(String[] args) { // 连接到 MongoDB MongoClient mongoClient = new MongoClient("localhost", 27017); // 获取数据库 MongoDatabase database = mongoClient.getDatabase("test"); // 获取集合 MongoCollection collection = database.getCollection("employees"); // 创建要插入的文档 List documents = new ArrayList<>(); documents.add(new Document("name", "John Doe").append("age", 30)); documents.add(new Document("name", "Jane Doe").append("age", 25)); // 执行批量插入 BulkWriteResult result = collection.insertMany(documents); // 打印插入的文档数 System.out.println(result.getInsertedCount()); //关闭连接 mongoClient.close(); } } ``` 使用 `BulkWrite` `BulkWrite` 方法允许一次执行多个写入操作到一个集合中。语法如下： ```java BulkWriteResult result = collection.bulkWrite(List operations); ``` 示例代码如下： ```java import com.mongodb.MongoClient; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import com.mongodb.client.model.InsertOneModel; import com.mongodb.client.model.UpdateOneModel; import com.mongodb.client.model.WriteModel; import org.bson.Document; import org.bson.conversions.Bson; public class BulkWriteExample { public static void main(String[] args) { // 连接到 MongoDB MongoClient mongoClient = new MongoClient("localhost", 27017); // 获取数据库 MongoDatabase database = mongoClient.getDatabase("test"); // 获取集合 MongoCollection collection = database.getCollection("employees"); // 创建要执行的写入操作 List > operations = new ArrayList<>(); operations.add(new InsertOneModel<>(new Document("name", "John Doe").append("age", 30))); operations.add(new UpdateOneModel<>(new Document("name", "Jane Doe"), new Document("$set", new Document("age", 26)))); // 执行批量写入 BulkWriteResult result = collection.bulkWrite(operations); // 打印插入的文档数和更新的文档数 System.out.println("Inserted: " + result.getInsertedCount()); System.out.println("Modified: " + result.getModifiedCount()); // 关闭连接 mongoClient.close(); } } ``` 使用多线程 对于大批量读写操作，使用多线程可以进一步提高性能。这里是一个简单的示例，使用多线程执行并行插入操作： ```java import com.mongodb.MongoClient; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import org.bson.Document; // 创建一个线程池 ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); public class ParallelInsertExample { public static void main(String[] args) { // 连接到 MongoDB MongoClient mongoClient = new MongoClient("localhost", 27017); // 获取数据库 MongoDatabase database = mongoClient.getDatabase("test"); // 获取集合 MongoCollection collection = database.getCollection("employees"); // 创建要插入的文档 List documents = new ArrayList<>(); for (int i = 0; i < 10000; i++) { documents.add(new Document("name", "John Doe " + i).append("age", 30 + i)); } // 将文档分块，每块 1000 个文档 List > documentChunks = Lists.partition(documents, 1000); // 为每个文档块创建一个任务 List > tasks = new ArrayList<>(); for (List chunk : documentChunks) { tasks.add(() -> { // 执行批量插入 collection.insertMany(chunk); // 返回插入的文档数 return chunk.size(); }); } // 提交并行任务 List > futures = executorService.invokeAll(tasks); // 计算总共插入的文档数 int totalInserted = 0; for (Future future : futures) { totalInserted += future.get(); } // 打印总共插入的文档数 System.out.println("Total inserted: " + totalInserted); // 关闭连接 mongoClient.close(); // 关闭线程池 executorService.shutdown(); } } ```

总结

通过使用 `insertMany`、`BulkWrite` 或多线程，可以显著提高 MongoDB 批量读写操作的性能。根据实际应用场景和数据量，选择最合适的批量操作方法，可以最大化应用程序的性能。

---

java直接操作mongodb语句

参考如下public class MongoDBJDBC {public static void main(String[] args) {try {// 实例化Mongo对象，连接端口Mongo mongo = new Mongo(localhost, );// 连接名为yourdb的数据库，假如数据库不存在的话，mongodb会自动建立DB db = (test);// Get collection from MongoDB, database named yourDB// 从Mongodb中获得名为yourColleection的数据集合，如果该数据集合不存在，Mongodb会为其新建立DBCollection collection = (test1);// 使用BasicDBObject对象创建一个mongodb的document,并给予赋值。 BasicDBObject document = new BasicDBObject();//(id, 1001);//(msg, hello world mongoDB in Java);// 将新建立的document保存到collection中去//(document);// 创建要查询的documentBasicDBObject searchQuery = new BasicDBObject();(name, chen);// 使用collection的find方法查找documentDBCursor cursor = (searchQuery);// 循环输出结果while (()) {(());}(Hello World);} catch (UnknownHostException e) {();} catch (MongoException e) {();}}}

如何用Java操作MongoDB

HelloWorld程序

学习任何程序的第一步，都是编写HelloWorld程序，我们也不例外，看下如何通过Java编写一个HelloWorld的程序。

首先，要通过Java操作Mongodb，必须先下载Mongodb的Java驱动程序，可以在这里下载。

新建立一个Java工程，将下载的驱动程序放在库文件路径下，程序代码如下：