MongoDB 提供了 Java 驱动程序，使 Java 开发者能够方便地与 MongoDB 数据库进行交互。使用 MongoDB Java 驱动程序，你可以轻松执行 CRUD 操作、处理聚合查询、事务等。
1. MongoDB Java 驱动程序简介
MongoDB 的 Java 驱动程序是与 MongoDB 数据库交互的标准库，它支持 MongoDB 的各种功能，包括但不限于 CRUD 操作、索引、聚合、事务、连接池等。
MongoDB Java 驱动程序的版本管理比较严格，通常会有与 MongoDB 服务器兼容的版本。例如，mongodb-driver-sync 是用于同步操作的驱动程序。
官方 Maven 依赖
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-sync</artifactId>
<version>4.7.0</version> <!-- 确保使用兼容的版本 -->
</dependency>对于异步操作，MongoDB 还提供了 mongodb-driver-async。
2. MongoDB Java 驱动程序的基本配置
首先，你需要创建一个 MongoClient 实例，来连接 MongoDB 数据库。
建立与 MongoDB 的连接
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
public class MongoDBExample {
public static void main(String[] args) {
// 使用 MongoDB URI 来连接
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient mongoClient = new MongoClient(uri);
// 使用数据库
mongoClient.getDatabase("test");
}
}通过 MongoClientURI 可以配置连接到 MongoDB 实例的连接字符串，支持指定主机、端口、认证信息、连接池等。
3. 连接 MongoDB 数据库和集合
一旦你创建了 MongoDB 客户端，你就可以连接到指定的数据库和集合进行操作。
连接到数据库和集合
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
public class MongoDBExample {
public static void main(String[] args) {
MongoClient client = new MongoClient("localhost", 27017); // 创建 MongoClient 实例
MongoDatabase database = client.getDatabase("test"); // 连接到 test 数据库
MongoCollection<Document> collection = database.getCollection("users"); // 获取 users 集合
// 执行查询操作
Document document = collection.find().first();
System.out.println(document.toJson());
}
}getDatabase("test")用于获取指定名称的数据库。getCollection("users")获取指定名称的集合。
4. CRUD 操作
MongoDB Java 驱动程序提供了方法来执行常见的 CRUD（创建、读取、更新、删除）操作。
插入数据
Document document = new Document("name", "Alice")
.append("age", 25)
.append("city", "New York");
collection.insertOne(document);查询数据
Document myDoc = collection.find(eq("name", "Alice")).first();
System.out.println(myDoc.toJson());更新数据
collection.updateOne(eq("name", "Alice"),
new Document("$set", new Document("age", 26)));删除数据
collection.deleteOne(eq("name", "Alice"));查询多个文档
FindIterable<Document> docs = collection.find(eq("city", "New York"));
for (Document doc : docs) {
System.out.println(doc.toJson());
}5. 聚合查询
MongoDB 的聚合框架在 Java 中也可以使用。通过 aggregate() 方法可以进行复杂的查询和数据处理。
示例：使用聚合查询计算年龄的平均值
List<Bson> pipeline = Arrays.asList(
Aggregates.match(Filters.gte("age", 20)),
Aggregates.group(null, Accumulators.avg("avgAge", "$age"))
);
MongoIterable<Document> result = collection.aggregate(pipeline);
for (Document doc : result) {
System.out.println(doc.toJson());
}聚合管道操作符
match：类似 SQL 中的 WHERE。group：类似 SQL 中的 GROUP BY。project：用于投影（选择字段）。sort：用于排序。
6. 事务支持
MongoDB 4.0 引入了多文档事务，MongoDB Java 驱动程序也支持该功能。你可以在一个事务中执行多个操作，以确保事务的一致性。
事务示例：
import com.mongodb.client.ClientSession;
import com.mongodb.client.TransactionBody;
ClientSession session = mongoClient.startSession();
session.startTransaction();
try {
MongoCollection<Document> collection = database.getCollection("users");
collection.insertOne(session, new Document("name", "Bob").append("age", 30));
session.commitTransaction(); // 提交事务
} catch (Exception e) {
session.abortTransaction(); // 出错时回滚事务
}7. 异步操作
MongoDB Java 驱动程序还支持异步操作，允许你执行非阻塞的数据库操作。使用 MongoClient 的异步版本 MongoClientAsync，可以执行异步查询。
异步查询示例：
import com.mongodb.async.client.MongoClients;
import com.mongodb.async.client.MongoCollection;
import org.bson.Document;
public class AsyncMongoDBExample {
public static void main(String[] args) {
MongoClient client = MongoClients.create("mongodb://localhost:27017");
MongoDatabase database = client.getDatabase("test");
MongoCollection<Document> collection = database.getCollection("users");
collection.find().first((document, throwable) -> {
if (throwable != null) {
throwable.printStackTrace();
} else {
System.out.println(document.toJson());
}
});
}
}8. MongoDB 连接池
MongoDB Java 驱动程序支持连接池，它可以有效管理与数据库的连接，减少每次查询时的连接开销。连接池的大小可以根据负载进行配置。
MongoClientOptions options = MongoClientOptions.builder()
.connectionsPerHost(10)
.build();
MongoClient client = new MongoClient(new ServerAddress("localhost", 27017), options);9. 常用的 Bson 操作符
在 MongoDB Java 驱动程序中，Bson 操作符用于创建查询条件、更新操作等。
常见操作符：
eq：等于gt：大于lt：小于gte：大于或等于lte：小于或等于ne：不等于in：在某个范围内and：多个条件的 AND 查询or：多个条件的 OR 查询
import static com.mongodb.client.model.Filters.*;
collection.find(eq("age", 25)); // age == 25
collection.find(gt("age", 20)); // age > 20总结
MongoDB Java 驱动程序使得 Java 开发者能够方便地与 MongoDB 进行交互，支持基本的 CRUD 操作、聚合查询、事务处理、异步操作等功能。通过这些功能，你可以在 Java 应用中灵活、高效地管理和处理 MongoDB 数据。更多详细内容请关注其他相关文章！