import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.FindIterable;
import org.bson.Document;
public class MongoDBExample {
public static void main(String[] args) {
// 连接到MongoDB服务
MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
// 连接到数据库
MongoDatabase database = mongoClient.getDatabase("mydb");
// 连接到集合
MongoCollection<Document> collection = database.getCollection("test");
// 插入文档
Document doc = new Document("name", "Alice").append("age", 24);
collection.insertOne(doc);
// 查询文档
FindIterable<Document> result = collection.find();
for (Document d : result) {
System.out.println(d.toJson());
}
// 更新文档
collection.updateOne(new Document("name", "Alice"), new Document("$set", new Document("age", 25)));
// 删除文档
collection.deleteOne(new Document("name", "Alice"));
// 关闭连接
mongoClient.close();
}
}
这段代码展示了如何使用MongoDB的Java驱动进行基本的增删改查操作。首先,它连接到本地的MongoDB实例,然后选择数据库和集合,接着执行插入、查询、更新和删除操作,最后关闭连接。这是一个简化的例子,实际应用中你可能需要处理更多的异常和配置选项。