JAVAEE操作MongoDB CRUD

MongoDB提供的Java操作API可以说是对Mongo数据库命令的Java翻译，熟悉Mongo命令，熟悉Java操作数据库的基本思路，很容易掌握基本操作。

一.增加 Create

//Document document = new Document();
//document.put("name","zhangsan123");
//document.put("age",11);
//document.put("addr","shanghai");
//document.put("date",new Date());
//collection.insertOne(document);
//插入多条文档;
Document d2=new Document();
d2.put("name","lisi");
d2.put("age",22);
d2.put("addr","zhegzhou");
d2.put("date",new Date());
Document d3=new Document();
d3.put("name","tom");
d3.put("age",33);
d3.put("addr","shanghai");
d3.put("date",new Date());

List<Document>list=new ArrayList<>();
list.add(d2);
list.add(d3);
collection.insertMany(list);

修改 Update

//获取所有文档;
//获取集合
BasicDBObject old=new BasicDBObject();
old.put("name","lisi");
BasicDBObject newObj=new BasicDBObject();
newObj.put("name","李四");
//更新
BasicDBObject update=new BasicDBObject("$set",newObj);
collection.updateOne(old,update);

2. 查询

@Test
public void testQuery(){
MongoClient client1=new MongoClient("localhost",27017);
MongoDatabase db=client1.getDatabase("test_edu");
//获取所有文档;
//获取集合

MongoCollection collection = db.getCollection("account");
MongoCursor it = collection.find().iterator();
while (it.hasNext()){
       System.out.println(it.next().toString());
}
it.close();
}

@Test
public void teslSel(){
MongoClient client1=new MongoClient("localhost",27017);
MongoDatabase db=client1.getDatabase("test_edu");
MongoCollection collection = db.getCollection("account");
//and查询 ；
//Bson eq = Filters.eq("name", "zhangsan123");
//Bson age = Filters.gt("age", 10);

BasicDBObject bbd=new BasicDBObject();
bbd.put("name","zhangsan123");
bbd.append("age",new BasicDBObject("$gte",8));
FindIterable<Document> findIterable = collection.find(bbd);

for (Document oo : findIterable) {
        System.out.println(oo);
}

System.out.println("------------多条件查询--------------");
//多个查询条件；
BasicDBList dbList=new BasicDBList();
dbList.add(new BasicDBObject("name","李四"));
dbList.add(new BasicDBObject("age",4));
//结合之前的BasicDbObject
BasicDBObject dbObject=new BasicDBObject();
dbObject.put("$or",dbList);
//查询

FindIterable<Document> fit = collection.find(dbObject);
for (Document d22 : fit) {
      System.out.println(d22);
}
FindIterable<Document> iterable8 = collection.find(
Filters.in("name","zhangsan123"));
for (Document doc :iterable8){
     System.out.println(doc.toJson());
}
System.out.println("查询条件sort 按年龄排序（升序） **************************************");
FindIterable<Document> iterable9 = collection.find().sort(new Document("age",1));
for (Document doc :iterable9){
      System.out.println(doc.toJson());
}

System.out.println("查询条件 分页 第二页 每页三条 **************************************");
FindIterable<Document> iterable10 = collection.find().limit(1).skip(1);
for (Document doc :iterable10){
     System.out.println(doc.toJson());
}

3. 删除

BasicDBObject obj = new BasicDBObject();

obj.put("name","wangwu");

collection.deleteOne(obj);