前言

之前写了各种nosql数据库的比较，以及相关理论，现在我在本地以springboot+MongoDB框架，探究了具体的运行流程，下面总结一下，分享给大家。

 

运行前准备

安装并启动MongoDB应用程序

参考网址：

windows

http://www.runoob.com/mongodb/mongodb-window-install.html

linux

http://www.runoob.com/mongodb/mongodb-linux-install.html

 

在MongoDB应用工具中查询数据增删改效果（rebo3t）

下载地址：https://robomongo.org/download

 

lombok安装

参考网址：https://www.cnblogs.com/fqszywz/p/7733703.html

 

代码运行

代码下载：https://github.com/a123demi/spring-boot-integration

 

代码主要讲解

主要依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> </dependency>

 

 

数据库连接

spring.application.name=spirngboot-int-mongodbeg spring.data.mongodb.database=admin spring.data.mongodb.host=127.0.0.1 spring.data.mongodb.password=root spring.data.mongodb.port=27017 spring.data.mongodb.username=root

 

 

通过MongoTemplate来调用各种增删改查的语句，比如

Query query=new Query(Criteria.where("userName").is(userName)); UserEntity user = mongoTemplate.findOne(query , UserEntity.class);

 

 

涉及的主要关键函数有

增 mongoTemplate.save(user); 删 mongoTemplate.remove(query,UserEntity.class); 改 Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord()); //更新查询返回结果集的第一条 WriteResult result =mongoTemplate.updateFirst(query,update,UserEntity.class); 查 Query query=new Query(Criteria.where("userName").is(userName)); UserEntity user = mongoTemplate.findOne(query , UserEntity.class);

 

 高级查询

分页查询

//利用工具类拼装分页信息 SpringbootMongoDBPageable pageable = new SpringbootMongoDBPageable(); MongoDBPageModel pm=new MongoDBPageModel(); pm.setPagesize(3); pm.setPagenumber(1); List<Order> orders = new ArrayList<>(); //排序信息 orders.add(new Order(Direction.DESC, "age")); Sort sort = new Sort(orders); pm.setSort(sort); pageable.setPage(pm); //拼装查询信息 Query query = new Query(); Criteria criteria = new Criteria(); query.addCriteria(criteria.where("age").gte(6).lte(18)); //检索6-18岁的 query.addCriteria(criteria.where("name").regex("文")); //模糊查询名字 Long count = mongoTemplate.count(query, OrdersData.class); //查询总记录数 List<Entry> list = mongoTemplate.find(query.with(pageable), Entry.class); //分页聚合查询（多表多条件关联分页查询） //mongodb中有两个表，一个是人物表 一个是宠物表，一个人可以有多个宠物 //人物表字段为 String id, Integer age,String remark; //宠物表字段为 String id, String manId,String age,String remark; //拼装分页信息 SpringbootMongoDBPageable pageable = new SpringbootMongoDBPageable(); MongoDBPageModel pm=new MongoDBPageModel(); pm.setPagesize(2); pm.setPagenumber(1); List<Order> orders = new ArrayList<>(); //排序 orders.add(new Order(Direction.DESC, "age")); Sort sort = new Sort(orders); pm.setSort(sort); pageable.setPage(pm); //拼装关联信息 LookupOperation lookupOperation = LookupOperation.newLookup(). from("dogData"). //关联表名 localField("_id"). //关联字段 foreignField("manId").//主表关联字段对应的次表字段 as("dogs");//查询结果集合名 //拼装具体查询信息 //次表 Criteria ordercri = Criteria.where("dogs").not().size(0);//只查询有宠物的人 ordercri.and("age").gte(1).lte(5);//只查询1岁到5岁的宠物 AggregationOperation match = Aggregation.match(ordercri); //主表 Criteria qqq=Criteria.where("name").regex("文");//只查询名字中带有文的人 AggregationOperation match1= Aggregation.match(qqq); //分页查询 Aggregation aggregation = Aggregation.newAggregation(match1,lookupOperation,match,Aggregation.sort(pageable.getSort()),//排序 Aggregation.skip(pageable.getPageNumber()>1?(pageable.getPageNumber()-1)*pageable.getPageSize():0),//pagenumber Aggregation.limit(pageable.getPageSize()));//pagesize //总数查询 Aggregation counts = Aggregation.newAggregation(match1,lookupOperation,match).; int count = mongoTemplate.aggregate(counts, "manEntry", BasicDBObject.class).getMappedResults().size(); List<BasicDBObject> results = mongoTemplate.aggregate(aggregation, "manEntry", BasicDBObject.class).getMappedResults(); //查询出的结果集为BasicDBObject类型 //解析过程 for (BasicDBObject b :results ) { //转化为jsonobject对象 JSONObject jsonObject = new JSONObject(b); String id = jsonObject.get("id").toString(); Integer age = ((int) jsonObject.get("age")); String remark = jsonObject.get("remark").toString(); //转化为jsonarray JSONArray dogs = jsonObject.getJSONArray("dogs"); if (dogs.size() > 0) { for (int i = 0; i < dogs.size(); i++) { JSONObject job = dogs.getJSONObject(i); String dogId = job.get("id").toString(); String manId = job.get("manId").toString(); } } } }

 可参考网址：https://blog.csdn.net/weixin_39804646/article/details/82155898#commentBox

 

转载于:https://www.cnblogs.com/yanduanduan/p/10578254.html