SpringCloud集成MybatisPlus，实现MySQL多数据源配置

news2024/11/25 14:59:43

在这里插入图片描述

引入依赖

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.4.0</version>
</dependency>

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.15</version>
</dependency>

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

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

配置多数据源

在application.properties中配置多数据源：

spring.datasource.master.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.master.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTC
spring.datasource.master.username=root
spring.datasource.master.password=root

spring.datasource.slave.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.slave.url=jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTC
spring.datasource.slave.username=root
spring.datasource.slave.password=root

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.pool.init-size=10
spring.datasource.pool.max-size=20
spring.datasource.pool.min-size=5
spring.datasource.pool.max-wait=30000
spring.datasource.filters=stat,wall,log4j
spring.datasource.log-enabled=true
spring.datasource.log-prefix=druid.log
spring.datasource.stat-view-servlet.enabled=true
spring.datasource.stat-view-servlet.url-pattern=/druid/*
spring.datasource.web-stat-filter.enabled=true
spring.datasource.web-stat-filter.exclusions=*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*
spring.datasource.max-total=20
spring.datasource.max-idle=10
spring.datasource.min-idle=5
spring.datasource.time-between-eviction-runs-millis=60000
spring.datasource.min-evictable-idle-time-millis=300000
spring.datasource.validation-query=SELECT 1 FROM dual
spring.datasource.test-on-borrow=true
spring.datasource.test-on-return=true
spring.datasource.test-while-idle=true
spring.datasource.remove-abandoned=true
spring.datasource.remove-abandoned-timeout=60000
spring.datasource.log-abandoned=true

配置解释

这是一个Spring Boot应用程序中用于配置数据库连接的属性文件。以下是每个配置项目的解释：

  1. spring.datasource.master.driver-class-name: 指定主数据库的JDBC驱动程序类名，这里是MySQL数据库的驱动类。
  2. spring.datasource.master.url: 主数据库的JDBC URL，指定了数据库的位置和连接参数，包括字符编码、时区等。
  3. spring.datasource.master.username: 主数据库的用户名。
  4. spring.datasource.master.password: 主数据库的密码。
  5. spring.datasource.slave.driver-class-name: 指定从数据库（副本）的JDBC驱动程序类名，同样是MySQL数据库的驱动类。
  6. spring.datasource.slave.url: 从数据库的JDBC URL，与主数据库不同的地方可能包括不同的数据库名称或连接参数。
  7. spring.datasource.slave.username: 从数据库的用户名。
  8. spring.datasource.slave.password: 从数据库的密码。
  9. spring.datasource.type: 数据源类型，这里使用了阿里巴巴的Druid数据源。
  10. spring.datasource.pool.init-size: 数据源的初始连接池大小，表示在启动时会创建的数据库连接数。
  11. spring.datasource.pool.max-size: 数据源的最大连接池大小，表示连接池中允许存在的最大连接数。
  12. spring.datasource.pool.min-size: 数据源的最小连接池大小，表示连接池中允许存在的最小连接数。
  13. spring.datasource.pool.max-wait: 获取连接时的最大等待时间（毫秒），如果连接池中的连接都被占用，且达到最大连接数，新请求会等待一段时间。
  14. spring.datasource.filters: 数据源的过滤器，可以用于监控、安全等目的。这里包括了统计（stat）、SQL防火墙（wall）和日志（log4j）。
  15. spring.datasource.log-enabled: 是否启用Druid的连接池日志。
  16. spring.datasource.log-prefix: 连接池日志的前缀。
  17. spring.datasource.stat-view-servlet.enabled: 是否启用Druid的统计数据查看servlet。
  18. spring.datasource.stat-view-servlet.url-pattern: 统计数据查看servlet的URL路径。
  19. spring.datasource.web-stat-filter.enabled: 是否启用Druid的Web统计过滤器。
  20. spring.datasource.web-stat-filter.exclusions: 需要排除统计的资源路径，如JavaScript、图片等。
  21. spring.datasource.max-total: 最大活动连接数，与spring.datasource.pool.max-size相同。
  22. spring.datasource.max-idle: 最大空闲连接数。
  23. spring.datasource.min-idle: 最小空闲连接数。
  24. spring.datasource.time-between-eviction-runs-millis: 连接池定期检查空闲连接的时间间隔。
  25. spring.datasource.min-evictable-idle-time-millis: 连接池中连接的最小空闲时间，超过此时间的连接将被回收。
  26. spring.datasource.validation-query: 用于验证连接是否有效的SQL查询。
  27. spring.datasource.test-on-borrow: 是否在借用连接时测试连接的有效性。
  28. spring.datasource.test-on-return: 是否在归还连接时测试连接的有效性。
  29. spring.datasource.test-while-idle: 是否在连接空闲时测试连接的有效性。
  30. spring.datasource.remove-abandoned: 是否移除长时间未使用的连接。
  31. spring.datasource.remove-abandoned-timeout: 设置长时间未使用连接的超时时间。
  32. spring.datasource.log-abandoned: 是否记录移除连接的日志。
    这些配置项用于定义应用程序与数据库之间的连接池、数据库连接属性和连接池监控等相关设置。不同的配置项可以根据应用程序的需求进行调整。

配置MybatisPlus

在application.properties中配置MybatisPlus：

mybatis-plus.mapper-locations=classpath:mapper/*.xml
mybatis-plus.global-config.id-type=auto
mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0
mybatis-plus.global-config.base-namespace=test
mybatis-plus.global-config.mapper-namespace=test.mapper

配置MybatisPlus解释

这是一个MyBatis Plus（通常简称为MyBatis+或MP）的配置文件，用于配置MyBatis Plus在Spring Boot应用程序中的行为。以下是每个配置项目的解释：

  1. mybatis-plus.mapper-locations=classpath:mapper/*.xml: 这个配置项指定了MyBatis Plus的Mapper XML文件的位置。在这个例子中，它告诉MyBatis Plus在类路径下的"mapper"目录中查找所有以".xml"结尾的文件，以作为Mapper定义文件。
  2. mybatis-plus.global-config.id-type=auto: 这个配置项指定了主键ID的生成策略。在这里，设置为"auto"表示使用数据库自动生成的主键值，这通常是由数据库管理的自增长或唯一标识符。
  3. mybatis-plus.global-config.db-config.logic-delete-value=1: 这个配置项指定了逻辑删除的值。在MyBatis Plus中，逻辑删除是一种通过标记记录来表示删除状态的方式，这里设置为"1"表示已删除。
  4. mybatis-plus.global-config.db-config.logic-not-delete-value=0: 这个配置项指定了逻辑未删除的值。在MyBatis Plus中，这是指记录未被删除的状态，这里设置为"0"表示未删除。
  5. mybatis-plus.global-config.base-namespace=test: 这个配置项指定了基础的Mapper命名空间。这个命名空间将会被用于生成Mapper接口的全限定名，通常与包名相关联。
  6. mybatis-plus.global-config.mapper-namespace=test.mapper: 这个配置项指定了Mapper接口的命名空间。在MyBatis Plus中，Mapper接口与XML文件相关联，这个配置项将会在生成的Mapper接口中设置XML文件的命名空间。
    这些配置项用于自定义MyBatis Plus的行为，包括主键生成策略、逻辑删除的值、Mapper接口命名空间等。它们允许根据应用程序的需求来配置和控制MyBatis Plus的行为。

配置Mapper

创建一个Mapper接口，例如UserMapper：

@Mapper
public interface UserMapper extends BaseMapper<User> {
}

使用多数据源

在需要使用多数据源的地方，使用@MapperScan注解指定Mapper所在包路径：

@SpringBootApplication
@EnableDiscoveryClient
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @MapperScan("com.example.demo.mapper")
    public class MyApp {
        // ...
    }
}

CRUD示例

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public User save(User user) {
        return userMapper.save(user);
    }

    @Override
    public User update(User user) {
        return userMapper.updateById(user);
    }

    @Override
    public User findById(Long id) {
        return userMapper.selectById(id);
    }

    @Override
    public void delete(Long id) {
        userMapper.deleteById(id);
    }
}

@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserService userService;

    @PostMapping
    public User save(@RequestBody User user) {
        return userService.save(user);
    }

    @PutMapping("/{id}")
    public User update(@PathVariable Long id, @RequestBody User user) {
        user.setId(id);
        return userService.update(user);
    }

    @GetMapping("/{id}")
    public User findById(@PathVariable Long id) {
        return userService.findById(id);
    }

    @DeleteMapping("/{id}")
    public void delete(@PathVariable Long id) {
        userService.delete(id);
    }
}

使用不同数据源

要使用不同的数据源查询，可以在Mapper接口中使用@MapperScan注解指定需要使用的数据源，例如：

@MapperScan("com.example.demo.mapper.master")
public interface UserMapperMaster extends BaseMapper<User> {
}

@MapperScan("com.example.demo.mapper.slave")
public interface UserMapperSlave extends BaseMapper<User> {
}

然后在需要使用不同数据源的地方，使用@Autowired注解注入对应的Mapper接口，例如：

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapperMaster userMapperMaster;

    @Autowired
    private UserMapperSlave userMapperSlave;

    @Override
    public User save(User user) {
        return userMapperMaster.save(user);
    }

    @Override
    public User update(User user) {
        return userMapperMaster.updateById(user);
    }

    @Override
    public User findById(Long id) {
        return userMapperMaster.selectById(id);
    }

    @Override
    public void delete(Long id) {
        userMapperMaster.deleteById(id);
    }
}

要在某个方法上使用不同的数据源，可以在该方法上使用@MapperScan注解指定需要使用的数据源，例如：

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapperMaster userMapperMaster;

    @Autowired
    private UserMapperSlave userMapperSlave;

    @Override
    public User save(User user) {
        return userMapperMaster.save(user);
    }

    @Override
    public User update(User user) {
        return userMapperMaster.updateById(user);
    }

    @Override
    public User findById(Long id) {
        return userMapperMaster.selectById(id);
    }

    @Override
    public void delete(Long id) {
        userMapperMaster.deleteById(id);
    }

    @MapperScan("com.example.demo.mapper.slave")
    @Override
    public User findByIdSlave(Long id) {
        return userMapperSlave.selectById(id);
    }
}

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

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

相关文章

Apache DataFusion查询引擎简介

Apache DataFusion查询引擎简介

01 简介 DataFusion是一个查询引擎&#xff0c;其本身不具备存储数据的能力。正因为不依赖底层存储的格式&#xff0c;使其成为了一个灵活可扩展的查询引擎。它原生支持了查询CSV&#xff0c;Parquet&#xff0c;Avro&#xff0c;Json等存储格式&#xff0c;也支持了本地&#…
阅读更多...
TCP通信实现

TCP通信实现

前言 TCP&#xff08;Transmission Control Protocol&#xff0c;传输控制协议&#xff09;是一种面向连接的、可靠的、基于流的通信协议。它是互联网协议栈&#xff08;TCP/IP&#xff09;中的核心协议之一&#xff0c;主要用于保证在计算机网络中可靠地传输数据。 TCP通信的基…
阅读更多...
面向物联网基础的智能农业环境的节能边缘-雾-云计算架构

面向物联网基础的智能农业环境的节能边缘-雾-云计算架构

这篇论文的标题是《Energy-Efficient Edge-Fog-Cloud Architecture for IoT-Based Smart Agriculture Environment》&#xff0c;作者是Hatem A. Alharbi和Mohammad Aldossary&#xff0c;发表在IEEE Access期刊上。论文的主要内容可以概括为以下几个部分&#xff1a; 摘要&am…
阅读更多...
【JVM 工具命令】JAVA程序线上问题诊断，JVM工具命令的使用，jstat， jstack，jmap命令的使用

【JVM 工具命令】JAVA程序线上问题诊断，JVM工具命令的使用，jstat， jstack，jmap命令的使用

【JVM 工具命令】JAVA程序线上问题诊断&#xff0c;JVM工具命令的使用&#xff0c;jstat&#xff0c; jstack&#xff0c;jmap命令的使用 1. JVM监控工具&#xff1a; Jstat命令 通过这个命令查询java程序&#xff0c;gc的情况 jstat -gcutil {pid} 5000 12 5000 表示5000…
阅读更多...
JavaWeb【day12】--（SpringBootWeb登录认证）

JavaWeb【day12】--（SpringBootWeb登录认证）

案例-登录认证 在前面的课程中&#xff0c;我们已经实现了部门管理、员工管理的基本功能&#xff0c;但是大家会发现&#xff0c;我们并没有登录&#xff0c;就直接访问到了Tlias智能学习辅助系统的后台。 这是不安全的&#xff0c;所以我们今天的主题就是登录认证。 最终我们…
阅读更多...
Mysql高级篇（中）—— 索引优化

Mysql高级篇（中）—— 索引优化

Mysql高级篇&#xff08;中&#xff09;—— 索引优化 一、索引分析案例案例 1&#xff1a;单表查询案例 2&#xff1a;两表连接查询案例 3&#xff1a;三表连接查询 二、避免索引失效常见索引失效场景简述场景 1场景 2场景 3场景 4场景 5场景 6 三、索引优化文字版示例版 一、…
阅读更多...
每日OJ_牛客_数组中出现次数超过一半的数字

每日OJ_牛客_数组中出现次数超过一半的数字

目录 牛客_数组中出现次数超过一半的数字 解析代码1 解析代码2 牛客_数组中出现次数超过一半的数字 数组中出现次数超过一半的数字__牛客网 给一个长度为 n 的数组&#xff0c;数组中有一个数字出现的次数超过数组长度的一半&#xff0c;请找出这个数字。例如输入一个长度为…
阅读更多...
瑞芯微RK3566鸿蒙开发板OpenHarmony标准系统应用兼容性测试指导

瑞芯微RK3566鸿蒙开发板OpenHarmony标准系统应用兼容性测试指导

本文OpenHarmony标准系统应用兼容性测试指导&#xff0c;适用鸿蒙系统软件开发测试的新手入门学习课程。设备为触觉智能的瑞芯微RK3566开发板&#xff0c;型号Purple Pi OH。是Laval官方社区主荐的一款鸿蒙开发主板。支持Openharmony、安卓Android、Linux的Debian、Ubuntu系统。…
阅读更多...
实战项目01-icon图标修改

实战项目01-icon图标修改

修改项目图标 引入图片资源&#xff0c;放入指定目录&#xff0c;覆盖掉之前图片即可 目录&#xff1a;entry > src > main > resources > base > media 图片&#xff1a;startIcon.png foreground.png background.png 修改项目标题 需要修改 EntryAbilit…
阅读更多...
Deploying Spring Boot Apps Tips

Deploying Spring Boot Apps Tips

Java PaaS providers chatter command Efficient deployments See also spring-boot-reference.pdf https://docs.spring.io/spring-framework/reference/integration/checkpoint-restore.html
阅读更多...
基于JAVA+SpringBoot+Vue的网上商城系统的设计与实现

基于JAVA+SpringBoot+Vue的网上商城系统的设计与实现

基于JAVASpringBootVue的网上商城系统的设计与实现 前言 ✌全网粉丝20W,csdn特邀作者、博客专家、CSDN[新星计划]导师、java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末附源码下载链接&#x1…
阅读更多...
为数据仓库构建Zero-ETL无缝集成数据分析方案（下篇）

为数据仓库构建Zero-ETL无缝集成数据分析方案（下篇）

对于从事数据分析的小伙伴们来说&#xff0c;最头疼的莫过于数据处理的阶段。在我们将数据源的原始数据导入数据仓储进行分析之前&#xff0c;我们通常需要进行ETL流程对数据格式进行统一转换&#xff0c;这个流程需要分配专业数据工程师基于业务情况完成&#xff0c;整个过程十…
阅读更多...
Java解决Jira单点登录、登出思路介绍

Java解决Jira单点登录、登出思路介绍

说明&#xff1a; 当前环境的Jira是容器部署的&#xff0c;所以方案中的整个流程是在docker环境下进行分析。且方案为解决思路或者说解决方式的一种&#xff0c;仅供参考&#xff0c;不喜勿喷。当然依然存在个别问题&#xff0c;没能完全优化完&#xff0c;想了解的可以直接看最…
阅读更多...
【小中大 / 1】

【小中大 / 1】

题目 、 代码 #include <bits/stdc.h> using namespace std; const double eps 1e-8; const int N 1e510; int a[N]; int main() {int n;cin >> n;for(int i 1; i < n; i){cin >> a[i];}sort(a1, an1);int maxx a[n], minn a[1];double midd;if((1…
阅读更多...
Mac OS14外接显示器字体过小和放大字体模糊问题的简单解决

Mac OS14外接显示器字体过小和放大字体模糊问题的简单解决

文章目录 问题简述解决方法 问题简述 使用Mac mini外接2K 显示器时&#xff0c;默认分辨率是25601440&#xff0c;字体较小&#xff0c;如果切换成19201080&#xff0c;字体又变大模糊。 解决方法 使用HiDP I&#xff08;一种显示技术&#xff0c;使用多个物理像素显示1个像…
阅读更多...
一款好用的电子样本册转换器

一款好用的电子样本册转换器

在数字化时代&#xff0c;电子样本册已成为各行各业必备的工具。一款好用的电子样本册转换器&#xff0c;可以让你在繁杂的资料管理中轻松解脱。今天&#xff0c;就为大家推荐一款实用的电子样本册转换神器&#xff0c;让你的工作效率翻倍&#xff01; 工具推荐&#xff1a;FLB…
阅读更多...
做好职业规划，绘制璀璨蓝图！

做好职业规划，绘制璀璨蓝图！

我们来聊一聊如何做好职业规划&#xff0c;建立自己奋斗的目标和计划。 1、使用 SWOT 模型分析自己的现状 SWOT 分析通过对自己的优势、劣势、机会和威胁加以综合评估&#xff0c;做一个合理的自我分析&#xff0c;帮助我们更清楚地分析自己的现状&#xff0c;发现自身的优势和…
阅读更多...
GenAI 客户支持 — 第 3 部分：为人类设计聊天机器人的聊天界面

GenAI 客户支持 — 第 3 部分：为人类设计聊天机器人的聊天界面

作者&#xff1a;Ian Moersen 本博客系列揭示了我们的现场工程团队如何使用 Elastic stack 和生成式 AI 开发出一款可爱而高效的客户支持聊天机器人。如果你错过了本系列的其他文章&#xff0c;请务必查看第一部分、第二部分和第四部分。 通过 Web 应用聊天的想法已经存在了很长…
阅读更多...
[AHK]ListBox的增删改移等操作示范

[AHK]ListBox的增删改移等操作示范

ahk v1 中对ListBox的操作&#xff1a;增、删、改、上移、下移等操作。 #singleinstance forcetitle ListBox 例子gui,add,listbox,xm ym w100 r20 vLB choose1 gLBevent,电话|聊天|拍拖|表白|订婚|礼金|礼盒 gui,add,edit ,xm yp250 w200 vEDT -background gui,add,butto…
阅读更多...
c++数据结构算法题讲解

c++数据结构算法题讲解

那么从本期文章开始&#xff0c;会尽量带大家一起刷题 第一题 题目 关键词 思路 源代码 class MinStack { public: void push(int val) { _st.push(val); if(_minst.empty() || val < _minst.top()) { _minst.push(val); } } void pop() { if(_st.top() _minst.top()) {…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023