0、前置工作

创建Maven工程，导入依赖：

<dependency><groupId>org.mongodb</groupId><artifactId>mongo-java-driver</artifactId><version>3.12.7</version></dependency>

1、连接MongoDB并测试

注意：确保已经启动MongoDB，最好是把MongoDB设置为自启程序。

//连接MongoDB服务器，自带连接池效果MongoClient mongoClient = MongoClients.create("mongodb://127.0.0.1:27017");//获取数据库，如果数据库不存在，为该数据库存储数据时自动创建数据库。MongoDatabase database = mongoClient.getDatabase("test");//获取集合，如果集合不存在，首次存储数据时，自动创建集合MongoCollection<Document> collection = database.getCollection("teachers");//获取数据，获取集合中第一个文档，并转为json打印System.out.println(collection.find().first().toJson());    //测试//关闭客户端if (mongoClient != null){mongoClient.close();}

如果有用户名和密码的话，连接的地址应该修改为：

mongodb://username:password@host/?authSource=admin

2、Java 操作集合

2.1、创建集合

创建集合有多种方式：创建普通的集合，创建固定大小的集合（capped）、创建带校验规则的集合：

1、创建普通集合

/*** 创建无限定集合* @param name 集合名称*/public void createCollection(String name){database.createCollection(name);}

2、创建固定大小的集合

/*** 创建固定大小的集合* @param name 集合名称* @param size 集合大小*/public void createCollection(String name,long size){database.createCollection(name,new CreateCollectionOptions().capped(true).sizeInBytes(size));}

3、创建带校验规则的集合

 /*** 创建带校验规则的集合* 在插入文档时必须存在两个字段：existsFiledName1和existsFiledName2* @param name 集合名称* @param existsFiledName1 字段1* @param existsFiledName2 字段2*/public void createCollectionWithFilter(String name,String existsFiledName1,String existsFiledName2){ValidationOptions validationOptions = new ValidationOptions().validator(Filters.or(Filters.exists(existsFiledName1), Filters.exists(existsFiledName2)));database.createCollection(name,new CreateCollectionOptions().validationOptions(validationOptions));}

 

2.2、获取集合

 public MongoCollection<Document> getCollection(String name){return database.getCollection(name);}

2.3、删除集合

/*** 删除集合*/public void dropCollection(String collectionName){MongoCollection<Document> collection = getCollection(collectionName);collection.drop();}

3、Java 操作文档

3.1、插入单个文档

/*** 插入一个文档* 创建一个文档对象，参数可以接收键值对，也可以直接接收一个Map对象* 文档对象的本质是BSON类型，还类型对应java中的Map，BSON数组对应Java中的List* Document.append(String key,Object value);    键指的是字段名 值可以是字符串可以是Document对象或者List数组*/public void insertDocument(String collectionName,Map<String,Object> map){Document doc = new Document();for (String key : map.keySet()) {doc.append(key,map.get(key));}MongoCollection<Document> collection = getCollection(collectionName);collection.insertOne(doc);}

3.2、插入多个文档

/*** 插入多个文档*/public void insertDocuments(String collectionName,List<Document> documents){MongoCollection<Document> collection = getCollection(collectionName);collection.insertMany(documents);}

3.3、修改单个文档

这里用的是 Filters.eq() 相当于判断是否等于，如果有数值型的字段，可以用Filters.lt() 表示小于、Filters.gt() 表示大于...

 /**** @param collectionName 集合名称* @param conditionFiledName 查询条件字段名* @param value 查询条件字段对应的值* @param updateList 更新后的字段键值对列表 注意：这里需要传入一个List<Document>集合，其中，Document对象的key应该为"$set",值为新的Document对象*/public void updateDocument(String collectionName,String conditionFiledName,String value,List<Document> updateList){MongoCollection<Document> collection = getCollection(collectionName);collection.updateOne(Filters.eq(conditionFiledName,value),updateList);}

3.4、修改多个文档

//修改多个文档 所有订单数量<100的订单全部+1MongoCollection<Document> collection = getCollection("orders");
//给满足条件的订单的订单数目全部+100UpdateResult updateResult = collection.updateMany(Filters.eq("order_nums",100), Updates.inc("order_nums", 100));System.out.println(updateResult.getModifiedCount());

3.5、删除文档

 //删除单个条件文档MongoCollection<Document> collection = getCollection("orders");collection.deleteOne(Filters.eq("order_id","0003"));
//删除多个满足条件文档
collection.deleteOne(Filters.eq("order_num","100"));

4、Java 查询文档

4.1、查询所有文档

MongoCollection<Document> collection = getCollection("students");//查询所有文档MongoCursor<Document> cursor = collection.find().iterator();
//        MongoCursor<Document> cursor = collection.find().limit(100);//只看前100行
//        MongoCursor<Document> cursor = collection.find().first();//只看第一行try {while (cursor.hasNext()) {System.out.println(cursor.next().toJson());}}finally {cursor.close();}

4.2、条件查询

主要依靠Filters类进行拦截过滤。

//多条件查询 60<=score<80 并且 address="山西"（如果address是数组，则"山西"包含在内即可）FindIterable<Document> documents = collection.find(new Document("score", new Document("$gte", 60).append("$lt", 80)).append("address", "山西"));//等价于上面的collection.find(Filters.and(Filters.gte("score",60),Filters.lt("score",80),Filters.eq("address","山西")));

4.3、投影

投影就是选择展示的字段，因为默认是全部展示的。即使设置了想要展示的字段，"_id"字段也会被展示，需要用专门指定"_id"为0或者使用 Projections.excludeId()。

 //投影collection.find(Filters.eq("name","李大喜")).projection(new Document("name",1).append("sex",1).append("age",1).append("_id",0));//等价于上面的投影 Projections.excludeId() 不展示 _idcollection.find(Filters.eq("name","李大喜")).projection(Projections.fields(Projections.include("name","sex","age"),Projections.excludeId()));

 

4.4、排序

//排序 先按照年龄排序 年龄一样的安照工资排序//asc 升序//desc 降序collection.find(Filters.lt("age",50)).sort(Sorts.ascending("age","sal"));