java操作Mongodb数据库

public static void main(String[] args) {
MongoClientOptions option = MongoClientOptions.builder().connectTimeout(60000).build();
MongoClient monGoClient = new MongoClient(new ServerAddress("127.0.0.1", 27017), option);
//获取操作数据库
MongoDatabase db = monGoClient.getDatabase("runoob");
//获取集合。后面的操作,大部分都是基于集合操作
MongoCollection<Document> contections = db.getCollection("col");

//添加一条数据
contections.insertOne(new Document("name", "小明" + i).append("sex", "男"));

//添加多条数据
List<Document> documents = new ArrayList<>();
documents.add(new Document("name", "text111").append("sex", "女"));
documents.add(new Document("name", "chaoba4565").append("sex", "男"));
contections.insertMany(documents);

//更新一条数据
UpdateResult update1 = contections.updateOne(Filters.eq("name", "小明"), new Document("$set", new Document("name", "暮雪超霸")));

//更新多条数据
UpdateResult update = contections.updateMany(Filters.eq("name", "小明"), new Document("$set", new Document("name", "暮雪超霸")));

//更新,如果key不存在。则新插入一个文档
contections.updateOne(Filters.eq("name", "mumu"), new Document("$set", new Document("age", 20)), new UpdateOptions().upsert(true));

//查询所有一
FindIterable<Document> result = contections.find();
for (Document document : result) {
System.out.println(document);
}
//通过自带的迭代方法查询全部数据
MongoCursor result1 = contections.find().iterator();
while (result1.hasNext()) {
System.out.println(result1.next());
}

//查询单个
Document result3 = contections.find().first();
System.out.println(result3);

//根据条件查询
MongoCursor result4 = contections.find().filter(Filters.eq("name", "mumu")).iterator();
while (result4.hasNext()) {
System.out.println(result4.next());
}
//多条件查询
MongoCursor result5 = contections.find().filter(Filters.and(Filters.eq("name", "mumu"), Filters.eq("age", 20))).iterator();
while (result5.hasNext()) {
System.out.println(result5.next());
}

//删除
contections.deleteOne(Filters.eq("chaoba", 1));

}
原文地址:https://www.cnblogs.com/lovetl/p/11698561.html