springboot 简单配置mongodb多数据源

准备工作：

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

所需jar包：

# springboot基于的版本
<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.2.1.RELEASE</version><relativePath/>
</parent># maven 关键jar包
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-configuration-processor</artifactId><optional>true</optional>
</dependency>

配置文件：

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

多数据源配置类 MultipleMongoConfig：

package com.douzi.mongo.config;import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.util.StringUtils;import com.mongodb.MongoClientURI;/*** @Author douzi* @Title: MultipleMongoConfig* @Description: 读取对应的配置信息并且构造对应的MongoTemplate* @Date 2023-09-27*/
@Configuration
public class MultipleMongoConfig {@Value("${douzi.mongo.primary.uri}")private String primaryUri;@Value("${douzi.mongo.secondary.uri}")private String secondaryUri;/*** 配置主数据源template* @return 主数据源template*/@Primary@Bean(name = PrimaryMongoConfig.MONGO_TEMPLATE)public MongoTemplate primaryMongoTemplate() {return new MongoTemplate(primaryFactory());}/*** 配置从数据源template* @return 从数据源template*/@Bean@Qualifier(SecondaryMongoConfig.MONGO_TEMPLATE)public MongoTemplate secondaryMongoTemplate() {return new MongoTemplate(secondaryFactory());}/*** 配置主数据源db工厂* @param mongo 属性配置信息* @return 主数据源db工厂*/@Bean@Primarypublic MongoDbFactory primaryFactory() {if (StringUtils.isEmpty(primaryUri)) {throw new RuntimeException("必须配置mongo primary Uri");}return new SimpleMongoDbFactory(new MongoClientURI(primaryUri));}/*** 配置从数据源db工厂* @param mongo 属性配置信息* @return 从数据源db工厂*/@Beanpublic MongoDbFactory secondaryFactory() {return new SimpleMongoDbFactory(new MongoClientURI(secondaryUri));}
}

 主数据源配置 PrimaryMongoConfig：

package com.douzi.mongo.config;import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;/*** @Author douzi* @Title: PrimaryMongoConfig* @Description: 主数据源配置* @date 2023-09-27 */
@Configuration
@EnableMongoRepositories(basePackages = "${douzi.mongo.primary.repository-package}", mongoTemplateRef = PrimaryMongoConfig.MONGO_TEMPLATE)
public class PrimaryMongoConfig {protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
}

副数据源配置 SecondaryMongoConfig：

package com.douzi.mongo.config;import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;/*** @Author douzi* @Title: SecondaryMongoConfig* @Description: 从数据源配置* @Date 2023-09-27*/
@Configuration
@EnableMongoRepositories(basePackages = "${douzi.mongo.secondary.repository-package}", mongoTemplateRef = SecondaryMongoConfig.MONGO_TEMPLATE)
public class SecondaryMongoConfig {protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
}

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

dao层：

package com.douzi.mongo.dao.primary;import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;/*** @Author douzi* @Title: PrimaryStudent* @Description: 主数据源学生对象* @Date 2023/09/24 13:33*/
@Data
@Document(collection = "first_students")
public class PrimaryStudent implements Serializable {/*** id*/@Idprivate Integer id;/*** 姓名*/private String name;/*** 生活费*/private BigDecimal salary;/*** 生日*/private Date birth;}##################################分隔符########################################package com.douzi.mongo.dao.primary;import org.springframework.data.mongodb.repository.MongoRepository;/*** @Author douzi* @Title: PrimaryRepository* @Description: 主数据源dao层* @Date 2023/09/24 16:01*/
public interface PrimaryRepository extends MongoRepository<PrimaryStudent, Integer> {/*** 通过名字查找学生** @param name 名字* @return 学生信息*/PrimaryStudent findByName(String name);/*** 通过名字删除学生** @param name 名字* @return 学生信息*/PrimaryStudent removeStudentByName(String name);
}##################################分隔符########################################package com.douzi.mongo.dao.secondary;import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;/*** * @Author douzi* @Title: PrimaryStudent* @Description: 副数据源学生对象* @Date 2023/09/24 13:33*/
@Data
@Document(collection = "secondary_students")
public class SecondaryStudent implements Serializable {/*** id*/@Idprivate Integer id;/*** 姓名*/private String name;/*** 生活费*/private BigDecimal salary;/*** 生日*/private Date birth;}##################################分隔符########################################package com.douzi.mongo.dao.secondary;import org.springframework.data.mongodb.repository.MongoRepository;/*** @Author douzi* @Title: SecondaryRepository* @Description: 从数据源dao层* @Date 2023/09/24 16:02*/
public interface SecondaryRepository extends MongoRepository<SecondaryStudent, Integer> {/*** 通过名字查找学生** @param name 名字* @return 学生信息*/SecondaryStudent findByName(String name);/*** 通过名字删除学生** @param name 名字* @return 学生信息*/SecondaryStudent removeStudentByName(String name);
}

Service层：

package com.douzi.mongo.service;import com.douzi.mongo.dao.primary.PrimaryRepository;
import com.douzi.mongo.dao.primary.PrimaryStudent;
import com.douzi.mongo.dao.secondary.SecondaryRepository;
import com.douzi.mongo.dao.secondary.SecondaryStudent;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;/*** * @Author douzi* @Title: StudentService* @Description: * @Date 2023/09/24 14:32*/
@Service
@Slf4j
public class StudentService {@Autowiredprivate PrimaryRepository primaryRepository;@Autowiredprivate SecondaryRepository secondaryRepository;/*** 保存学生** @param primaryStudent* @param secondaryStudent*/public void save(PrimaryStudent primaryStudent, SecondaryStudent secondaryStudent) {PrimaryStudent student1 = primaryRepository.insert(primaryStudent);log.info(student1.toString());SecondaryStudent student2 = secondaryRepository.insert(secondaryStudent);log.info(student2.toString());}/*** 删除学生** @param name* @return*/public void delete(String name) {primaryRepository.deleteById(1);secondaryRepository.deleteById(1);}/*** 修改学生** @param primaryStudent* @param secondaryStudent*/public void update(PrimaryStudent primaryStudent, SecondaryStudent secondaryStudent) {PrimaryStudent student1 = primaryRepository.save(primaryStudent);log.info(student1.toString());SecondaryStudent student2 = secondaryRepository.save(secondaryStudent);log.info(student2.toString());}/*** 查找学生** @param name 学生姓名* @return*/public void find(String name) {PrimaryStudent student1 = primaryRepository.findByName(name);log.info(student1.toString());SecondaryStudent student2 = secondaryRepository.findByName(name);log.info(student2.toString());}/*** 查找学生集合** @return 学生集合*/public void findAll() {List<PrimaryStudent> primaryRepositoryAll = primaryRepository.findAll();log.info(primaryRepositoryAll.toString());List<SecondaryStudent> secondaryRepositoryAll = secondaryRepository.findAll();log.info(secondaryRepositoryAll.toString());}
}

Controller层：

package com.douzi.mongo.controller;import com.douzi.mongo.dao.primary.PrimaryStudent;
import com.douzi.mongo.dao.secondary.SecondaryStudent;
import com.douzi.mongo.service.StudentService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.math.BigDecimal;
import java.util.Date;/*** @Author douzi* @Title: StudentController* @Description: * @Date 2023/09/24 14:53*/
@RestController
@RequestMapping("/student")
public class StudentController {@Autowiredprivate StudentService studentService;/*** 保存学生** @return 保存的学生*/@RequestMapping("/save")public void save() {PrimaryStudent primaryStudent = new PrimaryStudent();SecondaryStudent secondaryStudent = new SecondaryStudent();primaryStudent.setId(1);primaryStudent.setName("mongo");primaryStudent.setSalary(BigDecimal.valueOf(1000));primaryStudent.setBirth(new Date());BeanUtils.copyProperties(primaryStudent, secondaryStudent);studentService.save(primaryStudent, secondaryStudent);}/*** 修改学生** @return 修改结果*/@RequestMapping("/update")public void update() {PrimaryStudent primaryStudent = new PrimaryStudent();SecondaryStudent secondaryStudent = new SecondaryStudent();primaryStudent.setId(1);primaryStudent.setName("mongo");primaryStudent.setSalary(BigDecimal.valueOf(2000));primaryStudent.setBirth(new Date());BeanUtils.copyProperties(primaryStudent, secondaryStudent);studentService.update(primaryStudent, secondaryStudent);}/*** 根据姓名删除学生** @param name 姓名* @return 删除结果*/@RequestMapping("/delete")public void delete(String name) {studentService.delete(name);}/*** 通过名字查找学生** @param name 学生名* @return 学生信息*/@RequestMapping("/find")public void find(String name) {studentService.find(name);}/*** 查找所有学生** @return 学生集合*/@RequestMapping("/all")public void findAll() {studentService.findAll();}}

测试：

http://localhost:8080/student/save

结果：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/94120.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Facebook Delos 中的虚拟共识协议

Facebook Delos 中的虚拟共识协议

背景 Facebook 的软件系统栈一般包括两层&#xff1a;上层是数据平面&#xff0c; 下层是控制平面。 facebook software stack 数据平面包括大量的服务&#xff0c;他们需要存储和处理海量数据。控制平面用来支撑数据平面&#xff0c;起到一些控制作用&#xff1a;调度、配置…
阅读更多...
【React】组件实例三大属性state、props、refs

【React】组件实例三大属性state、props、refs

state React 把组件看成是一个状态机&#xff08;State Machines&#xff09;。通过与用户的交互&#xff0c;实现不同状态&#xff0c;然后渲染 UI&#xff0c;让用户界面和数据保持一致。 React 里&#xff0c;只需更新组件的 state&#xff0c;然后根据新的 state 重新渲染用…
阅读更多...
Linux实用操作（固定IP、进程控制、监控、文件解压缩）

Linux实用操作（固定IP、进程控制、监控、文件解压缩）

目录 一、快捷键 1、ctrl c强制停止 2、ctrl d退出或登出 3、历史命令搜索history 4、光标移动快捷键 5、清屏 二、软件安装 1、CentOS的yum命令 2、Ubantu的apt命令 三、systemctl命令 四、软连接 五、日期、时区 1、date命令 2、修改Linux时区为东八区 3、nt…
阅读更多...
车牌文本检测与识别：License Plate Recognition Based On Multi-Angle View Model

车牌文本检测与识别：License Plate Recognition Based On Multi-Angle View Model

论文作者&#xff1a;Dat Tran-Anh,Khanh Linh Tran,Hoai-Nam Vu 作者单位&#xff1a;Thuyloi University;Posts and Telecommunications Institute of Technology 论文链接&#xff1a;http://arxiv.org/abs/2309.12972v1 内容简介&#xff1a; 1&#xff09;方向&#x…
阅读更多...
2023蓝帽杯半决赛电子取证+CTF部分题解

2023蓝帽杯半决赛电子取证+CTF部分题解

文章目录 电子取证123456789101112131415 CTFWeb | MyLinuxBotWeb | AirticleShareCrypto | ezrsaPwn | AdminPwn | uafmisc|排排坐吃吃果果 电子取证 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 CTF Web | MyLinuxBot Web | AirticleShare import requests import times reques…
阅读更多...
IDEA中的神仙插件——Smart Input （自动切换输入法）

IDEA中的神仙插件——Smart Input （自动切换输入法）

推荐专栏&#xff1a;开发环境配置攻略 致力于记录学习过程中各种软件的安装及环境配置操作&#xff0c;并提供详细的步骤说明和丰富的配图。涵盖了 Java、Python、IntelliJ IDEA、Tomcat、MySQL 等常见开发工具和服务器组件的配置&#xff0c;为初学者提供一个实用、全面的配置…
阅读更多...
WOL唤醒配置（以太网、PHY、MAC）

WOL唤醒配置（以太网、PHY、MAC）

目录 wol 以太网 MAC PHY RMII 通信配置 总结 wol Wake-on-LAN简称WOL&#xff0c;WOL&#xff08;网络唤醒&#xff09; 是一种标准网络协议&#xff0c;它的功效在于让已经进入休眠状态或关机状态的计算机&#xff0c;透过局域网&#xff08;多半为以太网&#xff…
阅读更多...
lv8 嵌入式开发-网络编程开发 01什么是互联网

lv8 嵌入式开发-网络编程开发 01什么是互联网

目录 1 计算机网络的定义与分类 1.1 按照网络的作用范围进行分类 1.2 按照网络的使用者进行分类 2 网络的网络 2.1 名词解释 2.2 边缘与核心 3 互联网基础结构发展的三个阶段 3.1 第一阶段&#xff1a;1969 – 1990 3.2 第二阶段&#xff1a;1985 – 1993 3.3 第三阶…
阅读更多...
linux MySQL高阶语句

linux MySQL高阶语句

linux MySQL高阶语句 1、MySQL高级语言1.1order by排序1.2group by分组1.3limit前几行1.4as别名1.5通配符1.6子查询1.7in1.8not in1.9exists 2、视图2.1视图概念2.2功能2.3应用场景2.4视图和表的区别和联系2.5创建视图 3、null值3.1null值3.2null值与空值的区别3.3验证null和空…
阅读更多...
Autowired和Resource的关系

Autowired和Resource的关系

相同点对于下面的代码来说&#xff0c;如果是Spring容器的话&#xff0c;两个注解的功能基本是等价的&#xff0c;他们都可以将bean注入到对应的field中 不同点但是请注意&#xff0c;这里说的是基本相同&#xff0c;说明还是有一些不同点的&#xff1a; byName和byType匹配顺…
阅读更多...
IDEA的Maven换源

IDEA的Maven换源

前言 IDEA是个好东西&#xff0c;但是使用maven项目时可能会让人很难受&#xff0c;要么是非常慢&#xff0c;要么直接下载不了。所以我们需要给IDEA自带maven换源&#xff0c;保证我们的下载速度。 具体操作 打开IDEA安装路径&#xff0c;然后打开下面的文件夹 plugins\m…
阅读更多...
第10章 MySQL（一）

第10章 MySQL（一）

10.1 谈谈MySQL的架构 难度：★★ 重点：★ 白话解析 要想彻底的理解MySQL，它的架构一定要先弄清楚，当Java程序员通过JDBC或者Mybatis去执行一条SQL的时候，到底经历了什么。下边先看一幅图： 户端：Java程序员通过JDBC或者Mybatis去拿MySQL的驱动程序，实际上就是拿客户端。…
阅读更多...
GNN PyG~torch_geometric 学习理解

GNN PyG~torch_geometric 学习理解

目录 1. PyG Introduction 2. PyG Installation 2.1 PyG 安装常见错误及原因 2.2 PyG 具体安装步骤 3. torch_geometric packages torch_geometric.data.Data Dataset 与 DataLoader Dropout、BatchNorm 3. torch_geometric: 理解edge_index 3.1 理解 mini-batch edg…
阅读更多...
【2023年11月第四版教材】第17章《干系人管理》（合集篇）

【2023年11月第四版教材】第17章《干系人管理》（合集篇）

第17章《干系人管理》&#xff08;合集篇&#xff09; 1 章节内容2 管理基础3 管理过程3.1 管理的过程★★★ &#xff08;22上44&#xff09;3.2 管理ITTO汇总★★★ 4 过程1-识别干系人4.1 数据收集★★★4.3数据分析4.4 权力利益方格4.5 数据表现&#xff1a;干系人映射分析…
阅读更多...
记录UNIAPP打包苹果iOS·APP

记录UNIAPP打包苹果iOS·APP

用到生成的四个文件：1-1.CSR证书文件、2-2.CER证书文件、3-3.PP文件【证书Profiles文件】、4-4.P12文件【证书私钥】 1. 生成CSR证书文件： 2. 操作苹果后台：Sign In - Applehttps://developer.apple.com/account/resources/certificates/list
阅读更多...
使用CrawlSpider爬取全站数据。

使用CrawlSpider爬取全站数据。

CrawpSpider和Spider的区别 CrawlSpider使用基于规则的方式来定义如何跟踪链接和提取数据。它支持定义规则来自动跟踪链接&#xff0c;并可以根据链接的特征来确定如何爬取和提取数据。CrawlSpider可以对多个页面进行同样的操作&#xff0c;所以可以爬取全站的数据。CrawlSpid…
阅读更多...
PHP图片文件管理功能系统源码

PHP图片文件管理功能系统源码

文件图库管理单PHP源码直接解压就能用&#xff0c;单文件&#xff0c;indexm.php文件可以重新命名&#xff0c;上传到需要访问的目录中&#xff0c; 可以查看目录以及各个文件&#xff0c;图片等和下载及修改管理服务。 源码下载&#xff1a;https://download.csdn.net/downloa…
阅读更多...
零基础Linux_11(进程)进程程序替换+实现简单的shell

零基础Linux_11(进程)进程程序替换+实现简单的shell

目录 1. 进程程序替换 1.1 程序替换原理 1.2 execl 接口 1.3 execv execlp execvp 1.4 exec 调各种程序 1.5 execle 接口 2. 实现简单的shell 2.1 打印提示和获取输入 2.2 拆开输入的命令和选项 2.3 创建进程和程序替换执行命令 2.4 内建命令实现路径切换 2.5 my…
阅读更多...
win10 ip设置

win10 ip设置

百度安全验证
阅读更多...
第82步 时间序列建模实战：LightGBM回归建模

第82步 时间序列建模实战：LightGBM回归建模

基于WIN10的64位系统演示 一、写在前面 这一期&#xff0c;我们介绍LightGBM回归。 同样&#xff0c;这里使用这个数据&#xff1a; 《PLoS One》2015年一篇题目为《Comparison of Two Hybrid Models for Forecasting the Incidence of Hemorrhagic Fever with Renal Syndr…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023