# multiple-data-sources **Repository Path**: jack_of_disco/multiple-data-sources ## Basic Information - **Project Name**: multiple-data-sources - **Description**: springboot多数据源配置，连接，事务管理，使用注解快速解决；MySQL，SQLServer - **Primary Language**: Java - **License**: Apache-2.0 - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 2 - **Forks**: 0 - **Created**: 2024-12-19 - **Last Updated**: 2025-08-23 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # multiple-data-sources #### 介绍 springboot多数据源配置，连接，事务管理，使用注解快速解决；MySQL，SQLServer CSDN 博客文章：https://blog.csdn.net/qq_45062700/article/details/144610108 #### 不使用数据池 还有更多的数据库可以 ##### 需要注意的几个点 1. springboot配置数据库连接的url时，要写成jdbc-url ```java 比如报错为： java.lang.IllegalArgumentException: jdbcUrl is required with driverClassName. 那么很大概率就是url没写成jdbc-url ``` 2. Mapper类最好是分开放到两个包下面，不要有父子包的关系； ```java 比如报错为： org.apache.ibatis.binding.BindingException: Invalid bound statement (not found): com.zyl.multiple.data.sources.mapper.xx.XxxMapper.getXxUser 大概率就是Mapper类放置的包没弄好，可以根据下面的内容，仔细理解 ``` ```java ├── com.zyl.multiple.data.sources.mapper │ └── ms │ └── UserTableMapper.java │ └── mysql │ └── UserMapper.java ``` ```java @MapperScan( basePackages = "com.zyl.multiple.data.sources.mapper.mysql", sqlSessionFactoryRef = "sqlSessionFactory" ) public class MySqlConfig { ...... } ``` ```java @Configuration @MapperScan( basePackages = "com.zyl.multiple.data.sources.mapper.ms", sqlSessionFactoryRef = "sqlserverSqlSessionFactory" ) public class SQLServerConfig { ...... } ``` 可以发现两个配置类的@MapperScan的basePackages值是没有包含关系的； 如果其中一个是com.zyl.multiple.data.sources.mapper，一个是com.zyl.multiple.data.sources.mapper.xx 那么就很有可能后者的数据源就无法获取到了，会被前者全部代理了。 --- #### 使用数据池 (Druid) 1. 导入druid依赖 ```xml com.alibaba druid-spring-boot-starter 1.1.10 ``` 2. 修改[application.yml](src%2Fmain%2Fresources%2Fapplication.yml) ```yaml spring: application: name: multiple-data-sources datasource: mysql: # driver-class-name: com.mysql.jdbc.Driver #可以去除，如果是特殊版本，可以自己导入 # spring中使用jdbc连接数据库时，url要写成jdbc-url # 使用druid数据源时，要写成url url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useAffectedRows=true&allowMultiQueries=true username: root password: 123456 type: com.alibaba.druid.pool.DruidDataSource # 连接池类型 initial-size: 5 # 初始连接数 min-idle: 5 # 闲置连接数 max-active: 50 # 最大连接数 sqlserver: # driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver #可以去除，如果是特殊版本，可以自己导入 url: jdbc:sqlserver://localhost:1433;databaseName=Test2;encrypt=false;trustServerCertificate=false; username: sa password: 123456 type: com.alibaba.druid.pool.DruidDataSource # 连接池类型 initial-size: 5 # 初始连接数 min-idle: 5 # 闲置连接数 max-active: 50 # 最大连接数 ``` 3. 修改数据源加载配置java文件 [DataSourceConfig.java](src%2Fmain%2Fjava%2Fcom%2Fzyl%2Fmultiple%2Fdata%2Fsources%2Fconfig%2FDataSourceConfig.java) ```java package com.zyl.multiple.data.sources.config; import com.alibaba.druid.pool.DruidDataSource; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import javax.sql.DataSource; @Configuration public class DataSourceConfig { @Primary @Bean @ConfigurationProperties(prefix = "spring.datasource.mysql") public DataSource dataSource() { return new DruidDataSource(); } @Bean(name = "dataSourceMs") @ConfigurationProperties(prefix = "spring.datasource.sqlserver") public DataSource dataSourceMs() { return new DruidDataSource(); } } ``` 就只需要这三步就完成了，是不是很简单；快去试试吧 #### 多数据源事务管理 在这里讨论一个方法中同时操作两个数据源，方法报错后两个数据源的数据是否会回滚 [MySqlConfig.java](src%2Fmain%2Fjava%2Fcom%2Fzyl%2Fmultiple%2Fdata%2Fsources%2Fconfig%2FMySqlConfig.java) ```java @Bean(name = "mysqlTransactionManager") @Primary //(重要)配置mysql为主要(默认)事务管理器 public DataSourceTransactionManager mysqlTransactionManager(DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } ``` 2. 全部回滚，使用手动控制事务提交。 ```java @Transactional(rollbackFor = Exception.class) @Override public String testMyAndMS5() { // 下面的语句报错，但是当前的事务管理器是默认的（MySQL事务管理器） // 发送报错的位置在addTableUser方法内部，而addTableUser方法增加了MS事务管理器，所以MS可以回滚 // 然后错误往上抛，testMyAndMS5()方法也触发异常，MySQL插入也回滚。 // 此时两个数据库的插入在出现异常时，都可以回滚 // 总结：不同的数据库操作，不要放在同一个方法内，否则无法回滚；建议同一个的数据库操作写一个方法，然后指定对应事务管理器 User user = new User(); user.setId(new Date().getTime()); user.setName("小红6"); user.setAge(226); UserTable userTable = new UserTable(); userTable.setName("小铁6"); userTable.setAge(316); userMapper.addUser(user); //报错 this.addTableUser(userTable); return "OK"; } public Integer addTableUser(UserTable userTable) { // 手动控制事务 DefaultTransactionDefinition def = new DefaultTransactionDefinition(); def.setName("myTransaction"); def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); TransactionStatus status = sqlserverTransactionManager.getTransaction(def); Integer i1; try { i1 = userTableMapper.addMsUser(userTable); int i = 1 / 0; sqlserverTransactionManager.commit(status); } catch (Exception e) { sqlserverTransactionManager.rollback(status); // 再次把错误抛给外面 throw e; } return i1; } ``` 2. 只有 @Transactional 中的事务管理器的数据回滚 ```java @Transactional(rollbackFor = Exception.class) @Override public String testMyAndMS2() { // 下面的语句报错，但是当前的事务管理器是默认的（MySQL事务管理器） // 发送报错时，MS的插入还没有执行，所有可以回滚成功 User user = new User(); user.setId(new Date().getTime()); user.setName("小红2"); user.setAge(222); UserTable userTable = new UserTable(); userTable.setName("小铁2"); userTable.setAge(312); userMapper.addUser(user); //报错 int i = 1 / 0; userTableMapper.addMsUser(userTable); return "OK"; } @Transactional(rollbackFor = Exception.class) @Override public String testMyAndMS3() { // 下面的语句报错，但是当前的事务管理器是默认的（MySQL事务管理器） // 发送报错时，MS的插入已经执行，MS无法回滚 User user = new User(); user.setId(new Date().getTime()); user.setName("小红3"); user.setAge(223); UserTable userTable = new UserTable(); userTable.setName("小铁3"); userTable.setAge(313); userTableMapper.addMsUser(userTable); //报错 int i = 1 / 0; userMapper.addUser(user); return "OK"; } @Transactional(rollbackFor = Exception.class) @Override public String testMyAndMS4() { // 下面的语句报错，但是当前的事务管理器是默认的（MySQL事务管理器） // 发送报错时，MS的插入已经执行，所有只有MySQL回滚成功,MS无法回滚 User user = new User(); user.setId(new Date().getTime()); user.setName("小红4"); user.setAge(224); UserTable userTable = new UserTable(); userTable.setName("小铁4"); userTable.setAge(314); userMapper.addUser(user); userTableMapper.addMsUser(userTable); //报错 int i = 1 / 0; return "OK"; } ``` 对于多事务管理，还有一个 Seata 分布式事务管理框架，里面包含了 AT模式、TCC模式、Saga模式、XA模式。