• springboot 简单配置mongodb多数据源

    准备工作：

    1. 本地mongodb一个
    2. 创建两个数据库 student 和 student-two

    所需jar包：

    1. # springboot基于的版本
    3.     org.springframework.boot
    4.     spring-boot-starter-parent
    5.     2.2.1.RELEASE
    6.     
    8.  
    9. # maven 关键jar包
    11.     org.springframework.boot
    12.     spring-boot-starter-web
    15.     org.projectlombok
    16.     lombok
    17.     true
    20.     org.springframework.boot
    21.     spring-boot-starter-data-mongodb
    24.     org.springframework.boot
    25.     spring-boot-configuration-processor
    26.     true

    配置文件：

    1. # uri 配置样例: mongodb://myDBReader:DifficultPassword@mongodb0.example.com:27017/admin 
    2. # 如果用户名或密码包含at符号@，冒号：，斜杠/或百分号％字符，请使用百分比编码方式消除歧义
    3. # uri 集群配置样例： mongodb://myDBReader:D1fficultP%40ssw0rd@mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/admin?replicaSet=myRepl
    4. douzi:
    5.   mongo:
    6.     primary:
    7.       uri: mongodb://127.0.0.1:27017/student
    8.       repository-package: com.douzi.mongo.dao.primary
    9.     secondary:
    10.       uri: mongodb://127.0.0.1:27017/student-two
    11.       repository-package: com.douzi.mongo.dao.secondary

    多数据源配置类 MultipleMongoConfig：

    1. package com.douzi.mongo.config;
    2.  
    3. import org.springframework.beans.factory.annotation.Qualifier;
    4. import org.springframework.beans.factory.annotation.Value;
    5. import org.springframework.context.annotation.Bean;
    6. import org.springframework.context.annotation.Configuration;
    7. import org.springframework.context.annotation.Primary;
    8. import org.springframework.data.mongodb.MongoDbFactory;
    9. import org.springframework.data.mongodb.core.MongoTemplate;
    10. import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
    11. import org.springframework.util.StringUtils;
    12.  
    13. import com.mongodb.MongoClientURI;
    14.  
    15. /**
    16.  * @Author douzi
    17.  * @Title: MultipleMongoConfig
    18.  * @Description: 读取对应的配置信息并且构造对应的MongoTemplate
    19.  * @Date 2023-09-27
    20.  */
    21. @Configuration
    22. public class MultipleMongoConfig {
    23. 	@Value("${douzi.mongo.primary.uri}")
    24. 	private String primaryUri;
    25. 	@Value("${douzi.mongo.secondary.uri}")
    26. 	private String secondaryUri;
    27.  
    28.     /**
    29.      * 配置主数据源template
    30.      * @return 主数据源template
    31.      */
    32.     @Primary
    33.     @Bean(name = PrimaryMongoConfig.MONGO_TEMPLATE)
    34.     public MongoTemplate primaryMongoTemplate() {
    35.         return new MongoTemplate(primaryFactory());
    36.     }
    37.  
    38.     /**
    39.      * 配置从数据源template
    40.      * @return 从数据源template
    41.      */
    42.     @Bean
    43.     @Qualifier(SecondaryMongoConfig.MONGO_TEMPLATE)
    44.     public MongoTemplate secondaryMongoTemplate() {
    45.         return new MongoTemplate(secondaryFactory());
    46.     }
    47.  
    48.     /**
    49.      * 配置主数据源db工厂
    50.      * @param mongo 属性配置信息
    51.      * @return 主数据源db工厂
    52.      */
    53.     @Bean
    54.     @Primary
    55.     public MongoDbFactory primaryFactory() {
    56.     	if (StringUtils.isEmpty(primaryUri)) {
    57.     		throw new RuntimeException("必须配置mongo primary Uri");
    58.     	}
    59.         return new SimpleMongoDbFactory(new MongoClientURI(primaryUri));
    60.     }
    61.  
    62.     /**
    63.      * 配置从数据源db工厂
    64.      * @param mongo 属性配置信息
    65.      * @return 从数据源db工厂
    66.      */
    67.     @Bean
    68.     public MongoDbFactory secondaryFactory() {
    69.     	return new SimpleMongoDbFactory(new MongoClientURI(secondaryUri));
    70.     }
    71. }

     主数据源配置 PrimaryMongoConfig：

    1. package com.douzi.mongo.config;
    2.  
    3. import org.springframework.context.annotation.Configuration;
    4. import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
    5.  
    6. /**
    7.  * @Author douzi
    8.  * @Title: PrimaryMongoConfig
    9.  * @Description: 主数据源配置
    10.  * @date 2023-09-27 
    11.  */
    12. @Configuration
    13. @EnableMongoRepositories(basePackages = "${douzi.mongo.primary.repository-package}", mongoTemplateRef = PrimaryMongoConfig.MONGO_TEMPLATE)
    14. public class PrimaryMongoConfig {
    15.     protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
    16. }

    副数据源配置 SecondaryMongoConfig：

    1. package com.douzi.mongo.config;
    2.  
    3. import org.springframework.context.annotation.Configuration;
    4. import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
    5.  
    6. /**
    7.  * @Author douzi
    8.  * @Title: SecondaryMongoConfig
    9.  * @Description: 从数据源配置
    10.  * @Date 2023-09-27
    11.  */
    12. @Configuration
    13. @EnableMongoRepositories(basePackages = "${douzi.mongo.secondary.repository-package}", mongoTemplateRef = SecondaryMongoConfig.MONGO_TEMPLATE)
    14. public class SecondaryMongoConfig {
    15.     protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
    16. }

    以下是辅助测试类 高手可以自行测试：

    dao层：

    1. package com.douzi.mongo.dao.primary;
    2.  
    3. import lombok.Data;
    4. import org.springframework.data.annotation.Id;
    5. import org.springframework.data.mongodb.core.mapping.Document;
    6.  
    7. import java.io.Serializable;
    8. import java.math.BigDecimal;
    9. import java.util.Date;
    10.  
    11. /**
    12.  * @Author douzi
    13.  * @Title: PrimaryStudent
    14.  * @Description: 主数据源学生对象
    15.  * @Date 2023/09/24 13:33
    16.  */
    17. @Data
    18. @Document(collection = "first_students")
    19. public class PrimaryStudent implements Serializable {
    20.  
    21.     /**
    22.      * id
    23.      */
    24.     @Id
    25.     private Integer id;
    26.     /**
    27.      * 姓名
    28.      */
    29.     private String name;
    30.     /**
    31.      * 生活费
    32.      */
    33.     private BigDecimal salary;
    34.     /**
    35.      * 生日
    36.      */
    37.     private Date birth;
    38.  
    39. }
    40.  
    41. ##################################分隔符########################################
    42.  
    43. package com.douzi.mongo.dao.primary;
    44.  
    45. import org.springframework.data.mongodb.repository.MongoRepository;
    46.  
    47. /**
    48.  * @Author douzi
    49.  * @Title: PrimaryRepository
    50.  * @Description: 主数据源dao层
    51.  * @Date 2023/09/24 16:01
    52.  */
    53. public interface PrimaryRepository extends MongoRepository {
    54.     /**
    55.      * 通过名字查找学生
    56.      *
    57.      * @param name 名字
    58.      * @return 学生信息
    59.      */
    60.     PrimaryStudent findByName(String name);
    61.  
    62.     /**
    63.      * 通过名字删除学生
    64.      *
    65.      * @param name 名字
    66.      * @return 学生信息
    67.      */
    68.     PrimaryStudent removeStudentByName(String name);
    69. }
    70.  
    71. ##################################分隔符########################################
    72.  
    73. package com.douzi.mongo.dao.secondary;
    74.  
    75. import lombok.Data;
    76. import org.springframework.data.annotation.Id;
    77. import org.springframework.data.mongodb.core.mapping.Document;
    78.  
    79. import java.io.Serializable;
    80. import java.math.BigDecimal;
    81. import java.util.Date;
    82.  
    83. /**
    84.  * 
    85.  * @Author douzi
    86.  * @Title: PrimaryStudent
    87.  * @Description: 副数据源学生对象
    88.  * @Date 2023/09/24 13:33
    89.  */
    90. @Data
    91. @Document(collection = "secondary_students")
    92. public class SecondaryStudent implements Serializable {
    93.  
    94.     /**
    95.      * id
    96.      */
    97.     @Id
    98.     private Integer id;
    99.     /**
    100.      * 姓名
    101.      */
    102.     private String name;
    103.     /**
    104.      * 生活费
    105.      */
    106.     private BigDecimal salary;
    107.     /**
    108.      * 生日
    109.      */
    110.     private Date birth;
    111.  
    112. }
    113.  
    114. ##################################分隔符########################################
    115.  
    116. package com.douzi.mongo.dao.secondary;
    117.  
    118. import org.springframework.data.mongodb.repository.MongoRepository;
    119.  
    120. /**
    121.  * @Author douzi
    122.  * @Title: SecondaryRepository
    123.  * @Description: 从数据源dao层
    124.  * @Date 2023/09/24 16:02
    125.  */
    126. public interface SecondaryRepository extends MongoRepository {
    127.     /**
    128.      * 通过名字查找学生
    129.      *
    130.      * @param name 名字
    131.      * @return 学生信息
    132.      */
    133.     SecondaryStudent findByName(String name);
    134.  
    135.     /**
    136.      * 通过名字删除学生
    137.      *
    138.      * @param name 名字
    139.      * @return 学生信息
    140.      */
    141.     SecondaryStudent removeStudentByName(String name);
    142. }

    Service层：

    1. package com.douzi.mongo.service;
    2.  
    3. import com.douzi.mongo.dao.primary.PrimaryRepository;
    4. import com.douzi.mongo.dao.primary.PrimaryStudent;
    5. import com.douzi.mongo.dao.secondary.SecondaryRepository;
    6. import com.douzi.mongo.dao.secondary.SecondaryStudent;
    7. import lombok.extern.slf4j.Slf4j;
    8. import org.springframework.beans.factory.annotation.Autowired;
    9. import org.springframework.stereotype.Service;
    10.  
    11. import java.util.List;
    12.  
    13. /**
    14.  * 
    15.  * @Author douzi
    16.  * @Title: StudentService
    17.  * @Description: 
    18.  * @Date 2023/09/24 14:32
    19.  */
    20. @Service
    21. @Slf4j
    22. public class StudentService {
    23.  
    24.     @Autowired
    25.     private PrimaryRepository primaryRepository;
    26.     @Autowired
    27.     private SecondaryRepository secondaryRepository;
    28.  
    29.     /**
    30.      * 保存学生
    31.      *
    32.      * @param primaryStudent
    33.      * @param secondaryStudent
    34.      */
    35.     public void save(PrimaryStudent primaryStudent, SecondaryStudent secondaryStudent) {
    36.         PrimaryStudent student1 = primaryRepository.insert(primaryStudent);
    37.         log.info(student1.toString());
    38.         SecondaryStudent student2 = secondaryRepository.insert(secondaryStudent);
    39.         log.info(student2.toString());
    40.     }
    41.  
    42.     /**
    43.      * 删除学生
    44.      *
    45.      * @param name
    46.      * @return
    47.      */
    48.     public void delete(String name) {
    49.         primaryRepository.deleteById(1);
    50.         secondaryRepository.deleteById(1);
    51.     }
    52.  
    53.     /**
    54.      * 修改学生
    55.      *
    56.      * @param primaryStudent
    57.      * @param secondaryStudent
    58.      */
    59.     public void update(PrimaryStudent primaryStudent, SecondaryStudent secondaryStudent) {
    60.         PrimaryStudent student1 = primaryRepository.save(primaryStudent);
    61.         log.info(student1.toString());
    62.         SecondaryStudent student2 = secondaryRepository.save(secondaryStudent);
    63.         log.info(student2.toString());
    64.     }
    65.  
    66.     /**
    67.      * 查找学生
    68.      *
    69.      * @param name 学生姓名
    70.      * @return
    71.      */
    72.     public void find(String name) {
    73.         PrimaryStudent student1 = primaryRepository.findByName(name);
    74.         log.info(student1.toString());
    75.         SecondaryStudent student2 = secondaryRepository.findByName(name);
    76.         log.info(student2.toString());
    77.     }
    78.  
    79.     /**
    80.      * 查找学生集合
    81.      *
    82.      * @return 学生集合
    83.      */
    84.     public void findAll() {
    85.         List primaryRepositoryAll = primaryRepository.findAll();
    86.         log.info(primaryRepositoryAll.toString());
    87.         List secondaryRepositoryAll = secondaryRepository.findAll();
    88.         log.info(secondaryRepositoryAll.toString());
    89.     }
    90. }

    Controller层：

    1. package com.douzi.mongo.controller;
    2.  
    3. import com.douzi.mongo.dao.primary.PrimaryStudent;
    4. import com.douzi.mongo.dao.secondary.SecondaryStudent;
    5. import com.douzi.mongo.service.StudentService;
    6. import org.springframework.beans.BeanUtils;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.web.bind.annotation.RequestMapping;
    9. import org.springframework.web.bind.annotation.RestController;
    10.  
    11. import java.math.BigDecimal;
    12. import java.util.Date;
    13.  
    14. /**
    15.  * @Author douzi
    16.  * @Title: StudentController
    17.  * @Description: 
    18.  * @Date 2023/09/24 14:53
    19.  */
    20. @RestController
    21. @RequestMapping("/student")
    22. public class StudentController {
    23.  
    24.     @Autowired
    25.     private StudentService studentService;
    26.  
    27.     /**
    28.      * 保存学生
    29.      *
    30.      * @return 保存的学生
    31.      */
    32.     @RequestMapping("/save")
    33.     public void save() {
    34.         PrimaryStudent primaryStudent = new PrimaryStudent();
    35.         SecondaryStudent secondaryStudent = new SecondaryStudent();
    36.         primaryStudent.setId(1);
    37.         primaryStudent.setName("mongo");
    38.         primaryStudent.setSalary(BigDecimal.valueOf(1000));
    39.         primaryStudent.setBirth(new Date());
    40.         BeanUtils.copyProperties(primaryStudent, secondaryStudent);
    41.         studentService.save(primaryStudent, secondaryStudent);
    42.     }
    43.  
    44.     /**
    45.      * 修改学生
    46.      *
    47.      * @return 修改结果
    48.      */
    49.     @RequestMapping("/update")
    50.     public void update() {
    51.         PrimaryStudent primaryStudent = new PrimaryStudent();
    52.         SecondaryStudent secondaryStudent = new SecondaryStudent();
    53.         primaryStudent.setId(1);
    54.         primaryStudent.setName("mongo");
    55.         primaryStudent.setSalary(BigDecimal.valueOf(2000));
    56.         primaryStudent.setBirth(new Date());
    57.         BeanUtils.copyProperties(primaryStudent, secondaryStudent);
    58.         studentService.update(primaryStudent, secondaryStudent);
    59.     }
    60.  
    61.     /**
    62.      * 根据姓名删除学生
    63.      *
    64.      * @param name 姓名
    65.      * @return 删除结果
    66.      */
    67.     @RequestMapping("/delete")
    68.     public void delete(String name) {
    69.         studentService.delete(name);
    70.     }
    71.  
    72.     /**
    73.      * 通过名字查找学生
    74.      *
    75.      * @param name 学生名
    76.      * @return 学生信息
    77.      */
    78.     @RequestMapping("/find")
    79.     public void find(String name) {
    80.         studentService.find(name);
    81.     }
    82.  
    83.     /**
    84.      * 查找所有学生
    85.      *
    86.      * @return 学生集合
    87.      */
    88.     @RequestMapping("/all")
    89.     public void findAll() {
    90.         studentService.findAll();
    91.     }
    92.  
    93. }

    测试：

    http://localhost:8080/student/save

    结果：

  • 相关阅读:
    使用golang+antlr4构建一个自己的语言解析器（一）
    什么是单片机？聊聊它的历史
    mysql
    基于轩禹秒杀ctfshow-RSA
    在面试提问环节应该问那些内容
    “蔚来杯“2022牛客暑期多校训练营6 C题: Forest
    测试用例评审的旁观记录
    Ubuntu 22.04 下 CURL（C++） 实现分块上传/下载文件源码
    （一）JDK、转义字符、数据类型
    使去中心化媒体网络相关联的NFT元数据标准
  • 原文地址：https://blog.csdn.net/qq_16116549/article/details/133344312