SpringBoot 中 mongo多数据源配置新姿势

SpringBoot对常用的数据库支持外，对NoSQL 数据库也进行了封装自动化。这一篇主要讲springboot与mongo多数据源相关的配置

1、mongo的介绍

MongoDB是一个高性能，开源，无模式的文档型数据库，是当前NoSql数据库中比较热门的一种。它在许多场景下可用于替代传统的关系型数据库或键/值存储方式,这里不再多做说明。详细介绍参考mongo入门

2、项目构建

添加pom文件

1. <dependency>

2. <groupId>org.springframework.boot</groupId>

3. <artifactId>spring-boot-starter-data-mongodb</artifactId>

4. </dependency>

3、在application.properties中添加配置

1. ##start mongodb for basic

2. #----------------------------------------------

3. basic.mongodb.host= 127.0.0.1

4. basic.mongodb.port= 27017

5. basic.mongodb.database= basic

6. #----------------------------------------------

7. ##end mongodb for spirit

9. ##start mongodb for basic

10. #----------------------------------------------

11. order.mongodb.host= 127.0.0.2

12. order.mongodb.port= 27017

13. order.mongodb.database= order

14. #----------------------------------------------

15. ##end mongodb for spirit

4、配置相应的数据源

这里我们采用mongoTemplate这种模式去做mongo的相关操作

先写一个基础的抽象类

1. public abstract class AbstractMongoConfigure {

3. private String host, database;

4. private int port;

5. /*

6. * Method that creates MongoDbFactory

7. * Common to both of the MongoDb connections

8. */

9. public MongoDbFactory mongoDbFactory() throws Exception {

11. return new SimpleMongoDbFactory(new MongoClient(host, port), database);

12. }

14. /*

15. * Factory method to create the MongoTemplate

16. */

17. abstract public MongoTemplate getMongoTemplate() throws Exception;

19. public String getHost() {

20. return host;

21. }

23. public void setHost(String host) {

24. this.host = host;

25. }

27. public String getDatabase() {

28. return database;

29. }

31. public void setDatabase(String database) {

32. this.database = database;

33. }

35. public int getPort() {

36. return port;

37. }

39. public void setPort(int port) {

40. this.port = port;

41. }

42. }

3.1)接下来第一个库的封装

1. @Configuration

2. @EnableMongoRepositories(basePackages = {"com.sunliangliang.service.basic"}, mongoTemplateRef = "basicMongoTemplate")

3. @ConfigurationProperties(prefix = "basic.mongodb")

4. public class BasicMongoConfigure extends AbstractMongoConfigure {

5. @Override

6. @Bean(name = "basicMongoTemplate")

7. public MongoTemplate getMongoTemplate() throws Exception {

8. return new MongoTemplate(mongoDbFactory());

9. }

10. }

其中 basePackages 的值是该库应用于相应的基础包，prefix即为相应的applications中的配置值

3.2)接下来第两个库的封装

1. @Configuration

2. @EnableMongoRepositories(basePackages = {"com.sunliangliang.service.order"}, mongoTemplateRef = "orderMongoTemplate")

3. @ConfigurationProperties(prefix = "order.mongodb")

4. public class OrderMongoConfigure extends AbstractMongoConfigure{

5. @Primary

6. @Override

7. @Bean(name = "orderMongoTemplate")

8. public MongoTemplate getMongoTemplate() throws Exception {

9. return new MongoTemplate(mongoDbFactory());

10. }

11. }

封装完成后接下来进行相应实体的配置

4、创建数据实体

1. public class UserInfo implements Serializable{

2. private long id;

3. private String username;

4. private String password;

5. private String nickname;

6. private int age;

7. private String name;

9. public long getId() {

10. return id;

11. }

13. public void setId(long id) {

14. this.id = id;

15. }

17. public String getUsername() {

18. return username;

19. }

21. public void setUsername(String username) {

22. this.username = username;

23. }

25. public String getPassword() {

26. return password;

27. }

29. public void setPassword(String password) {

30. this.password = password;

31. }

33. public String getNickname() {

34. return nickname;

35. }

37. public void setNickname(String nickname) {

38. this.nickname = nickname;

39. }

41. public int getAge() {

42. return age;

43. }

45. public void setAge(int age) {

46. this.age = age;

47. }

49. public String getName() {

50. return name;

51. }

53. public void setName(String name) {

54. this.name = name;

55. }

56. }

4、添加对实体的操作

在这里我写了一个公用的接口用于基础的增删改查

1. public interface BaseService<T> {

2. Boolean save(T entity);

4. Boolean update(T entity);

6. Boolean delete(Long id);

8. T getById(Long id);

10. List<T> listAll();

12. List<T> listAll(T entity);

13. }

接下来接口的实现

1. @Service

2. public class UserInfoService implements BaseService<UserInfo>{

3. @Autowired

4. @Qualifier("basicMongoTemplate")

5. private MongoTemplate mongoTemplate;

6. @Override

7. public Boolean save(UserInfo entity) {

8. mongoTemplate.save(entity);

9. return true;

10. }

12. @Override

13. public Boolean update(UserInfo entity) {

14. return null;

15. }

17. @Override

18. public Boolean delete(Long id) {

19. return null;

20. }

22. @Override

23. public UserInfo getById(Long id) {

24. return null;

25. }

27. @Override

28. public List<UserInfo> listAll() {

29. return mongoTemplate.findAll(UserInfo.class);

30. }

32. @Override

33. public List<UserInfo> listAll(UserInfo entity) {

34. return null;

35. }

36. }

注意此处@Qualifier(“basicMongoTemplate”)中即为相应的具体实现类。

这里只写了添加和查询列表的实现，其他的查询相应的api即可

1. @RunWith(SpringJUnit4ClassRunner.class)

2. @SpringBootTest

3. public class UserInfoServiceTest {

4. @Autowired

5. private UserInfoService userInfoService;

6. @Test

7. public void save() throws Exception {

8. UserInfo userInfo = new UserInfo();

9. userInfo.setAge(23);

10. userInfo.setId(1000l);

11. userInfo.setName("管理员");

12. userInfo.setNickname("hehe");

13. userInfo.setPassword("123456");

14. userInfo.setUsername("admin");

15. userInfoService.save(userInfo);

16. }

18. @Test

19. public void listAll() throws Exception {

20. userInfoService.listAll();

21. }

22. }

若库不存在，会自动生成相应的库和文档 如图：

另一个order相关库的配置就不再这里写了，相应的请参考代码

github中lessons-5

本文分享自微信公众号 - 码农小胖哥（Felordcn）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。