轻松搞定MongoDB，核心诀窍全在这里

后端

2023-06-04 13:06:30

MongoDB：玩转文档数据库的实用指南

在数据蓬勃发展的时代，选择合适的数据库至关重要。MongoDB 以其灵活性、强大的查询功能和文档结构而闻名，成为开发者的宠儿。本文将深入浅出地介绍 MongoDB 的核心操作，助力你轻松驾驭这款文档数据库。

基础使用

连接数据库

要连接到 MongoDB 数据库，请使用 MongoClient 类。根据需要，你可以指定主机名、端口号、用户名和密码等连接选项。

操作数据库

连接后，即可对数据库进行操作，包括查询、插入、更新和删除。

查询

find() 方法是查询 MongoDB 数据库的利器。它提供丰富的查询条件，让你灵活地检索所需数据。

MongoCollection<Document> collection = mongoClient.getDatabase("test").getCollection("users");
FindIterable<Document> iterable = collection.find(new Document("name", "John Doe"));

插入

使用 insertOne() 方法插入单个文档，或使用 insertMany() 方法同时插入多个文档。

collection.insertOne(new Document("name", "Jane Doe"));
collection.insertMany(Arrays.asList(new Document("name", "John Smith"), new Document("name", "Mary Johnson")));

更新

updateOne() 方法更新单个文档，而 updateMany() 方法则用于更新多个文档。

collection.updateOne(new Document("name", "John Doe"), new Document("$set", new Document("age", 30)));
collection.updateMany(new Document("age", new Document("$gt", 25)), new Document("$inc", new Document("age", 1)));

删除

deleteOne() 方法删除单个文档，而 deleteMany() 方法则删除多个文档。

collection.deleteOne(new Document("name", "John Doe"));
collection.deleteMany(new Document("age", new Document("$gt", 50)));

高级使用

聚合

聚合操作让你对数据分组、排序、统计等，从大量数据中提取有价值的信息。

MongoCollection<Document> collection = mongoClient.getDatabase("test").getCollection("orders");
AggregationPipeline aggregationPipeline = AggregationPipeline.newAggregationPipeline(
    new GroupField("_id", "$product"),
    new SumField("quantity"),
    new SortField(Direction.DESCENDING, "quantity")
);
AggregationResults<Document> results = collection.aggregate(aggregationPipeline);

索引

索引通过创建数据结构，提高查询性能。MongoDB 提供单字段索引、复合索引和全文索引等多种索引类型。

collection.createIndex(new Document("name", 1));
collection.createIndex(new Document("age", 1).append("name", 1));
collection.createIndex(new Document("text", "text"));

事务

MongoDB 支持事务，但仍处于实验阶段。如果你需要使用事务，请注意其限制。

try {
    SessionContext sessionContext = mongoClient.startSession();
    ClientSession session = sessionContext.getClientSession();
    session.startTransaction();

    // 执行事务操作

    session.commitTransaction();
} catch (MongoException e) {
    session.abortTransaction();
} finally {
    sessionContext.close();
}

安全

MongoDB 提供用户管理、角色管理和访问控制等安全特性，你可以配置合适的安全策略。

mongoClient.getDatabase("test").createUser(
    "john",
    new PasswordHash("password"),
    Collections.singletonList(new Role("readWrite", "test"))
);

mongoClient.getDatabase("test").createRole(
    new Role("readWrite", "test"),
    Arrays.asList(
        new Privilege("find", "test.users"),
        new Privilege("insert", "test.users"),
        new Privilege("update", "test.users"),
        new Privilege("delete", "test.users")
    )
);