查看: 254|回复: 0

[Java学习] springboot Mongodb的集成与使用实例详解

发表于 2018-5-5 09:30:29

说说springboot与大叔lind.ddd的渊源

Mongodb在Lind.DDD中被二次封装过(大叔的.net和.net core),将它当成是一种仓储来使用,对于开发人员来说只公开curd几个标准的接口即可,而在springboot框架里,它与大叔lind有些类似之处,同样是被二次封装了,开发人员只需要关注自己的业务即可,而标准的curd操作完成由springboot帮助我们来实现,一般地,我们会设计一个与实体对象的接口仓储,让它去继承mongo的标准接口,然后在springboot的依赖注入框架里把标准的实现注入进来,这一切都是框架帮助我们实现的!

在项目中实现mongodb

如果项目需要使用mongodb去持久化数据,一般可以经过下面几个步骤来实现:

1 添加包依赖build.gradle

  1. compile('org.springframework.boot:spring-boot-starter-data-mongodb')
复制代码

如果有单元测试项目,可以使用内嵌的mongodb,这样它不需要与外部资源进行通信,工作原理:从远程下载mongodb包,启动它,测试完成后删除生成的集合

  1. testCompile('de.flapdoodle.embed:de.flapdoodle.embed.mongo:2.0.3')
复制代码

2 添加默认的配置项application.yml

  1. spring:
  2. data:
  3. mongodb:
  4. uri: mongodb://192.168.99.100:27017/Test
  5. password: guest
  6. username: guest
复制代码

3 添加mongodb集合对应的实体类

  1. /**
  2. * 地址.
  3. */
  4. @Data
  5. @NoArgsConstructor
  6. @AllArgsConstructor
  7. public class Address {
  8. /**
  9. * 编号.
  10. */
  11. @Id
  12. private String id;
  13. /**
  14. * 省.
  15. */
  16. private String province;
  17. /**
  18. * 市.
  19. */
  20. private String city;
  21. /**
  22. * 区.
  23. */
  24. private String district;
  25. /**
  26. * 状态.
  27. */
  28. private Status status;
  29. }
复制代码

4 添加实体所对应的仓库类,它需要继承extends标准的mongodb仓储,同时Mongodb仓储支持自动定约定的方法,开发人员可以通过@Query注释来确定返回的字段列表,这对于大数据文档是很必要的,如果默认的接口不能满足我们的要求,我们需要定义个性化的接口,并去实现它,下面的例子中,我们的AddressExtRepository就是一个个性化接口,我们对外的接口AddressRepository 需要继承它,注意,大叔认为这样破获了面向对象的开闭原则,元芳,你怎么看!

  1. /**
  2. * 对外提供的地址仓储接口,继承所有地址相关的接口.
  3. */
  4. public interface AddressRepository extends
  5. AddressExtRepository,
  6. MongoRepository<Address, String> {
  7. /**
  8. * 根据省,拿地址列表.
  9. *
  10. * @param province
  11. * @return
  12. */
  13. @Query(fields = "{'province': 0}")
  14. List<Address> findAddressesByProvince(String province);
  15. /**
  16. * 根据省和省,拿地址列表.
  17. *
  18. * @param province
  19. * @param city
  20. * @return
  21. */
  22. @Query()//fields表示包含的字段
  23. List<Address> findAddressesByProvinceAndCityAndDistrict(String province, String city, String district);
  24. }
复制代码

个性化仓储实现,使用MongoTemplate对象与mongodb数据库进行交互!

  1. /**
  2. * 特殊规则的仓储实现.
  3. */
  4. public class AddressExtRepositoryImpl implements AddressExtRepository {
  5. @Autowired
  6. MongoTemplate mongoTemplate;
  7. @Override
  8. public Address findByProvinceAndCity(String province, String city) {
  9. Query query = new Query(Criteria.where("province").is(province).and("city").is(city));
  10. return mongoTemplate.findOne(query, Address.class, "address");
  11. }
  12. }
复制代码

5 controller中直接通过@Autowired注解来访问仓储和业务对象即可

  1. @RestController
  2. public class MongoController {
  3. // 仓储.
  4. @Autowired
  5. private AddressRepository repository;
  6. // 用户业务.
  7. @Autowired
  8. private UserService userService;
  9. /**
  10. * 得到地址列表.
  11. *
  12. * @return
  13. */
  14. @RequestMapping("/address/{province}")
  15. public Address getAddress(@PathVariable("province") String province) {
  16. System.out.println("1,province=" + province);
  17. return userService.getAddress(province);
  18. }
  19. }
复制代码

总结

以上所述是小编给大家介绍的springboot Mongodb的集成与使用实例详解,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对程序员之家网站的支持!



回复

使用道具 举报