SpringCloud配置文件中新增两个数据源

野性酷女 2023-07-06 08:52 5阅读 0赞

application.yml

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> spring: &nbsp;&nbsp;datasource: &nbsp;&nbsp;&nbsp;&nbsp;###会员数据库 &nbsp;&nbsp;&nbsp;&nbsp;member: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;jdbc-url: jdbc:mysql://localhost:3306/user &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;username: root &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;password: root &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;driver-class-name: com.mysql.jdbc.Driver &nbsp;&nbsp;&nbsp;&nbsp;###订单数据库 &nbsp;&nbsp;&nbsp;&nbsp;order: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;jdbc-url: jdbc:mysql://localhost:3306/order &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;username: root &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;password: root &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;driver-class-name: com.mysql.jdbc.Driver &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

备注：如果是SpringBoot2配置多数据源 ，报如下错误：

“jdbcUrl is required with driverClassName.”或者Cause: java.lang.IllegalArgumentException: dataSource or dataSourceClassName or jdbcUrl is required.\] with root cause

解决方案：

spring.datasource.url 和spring.datasource.driverClassName，换成

spring.datasource.jdbc-url和spring.datasource.driver-class-name

**数据库数据源相关配置**

**会员数据源**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> @Configuration @MapperScan(basePackages = "com.member.mapper", sqlSessionFactoryRef = "memberSqlSessionFactory") public class MemberDataSourceConfig { &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 将会员db注册到容器中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "memberDataSource") &nbsp;&nbsp;&nbsp;&nbsp;@ConfigurationProperties(prefix = "spring.datasource.member") &nbsp;&nbsp;&nbsp;&nbsp;public DataSource memberDataSource() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return DataSourceBuilder.create().build(); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 将会员SqlSessionFactory注册到容器中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param dataSource &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @throws Exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "memberSqlSessionFactory") &nbsp;&nbsp;&nbsp;&nbsp;public SqlSessionFactory memberSqlSessionFactory(@Qualifier("memberDataSource") DataSource dataSource) throws Exception { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sqlSessionFactoryBean.setDataSource(memberDataSource()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return sqlSessionFactoryBean.getObject(); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 创建会员管理器 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param dataSource &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "memberTransactionManager") &nbsp;&nbsp;&nbsp;&nbsp;public DataSourceTransactionManager memberTransactionManager(@Qualifier("memberDataSource") DataSource dataSource) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return new DataSourceTransactionManager(dataSource); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 创建订单sqlSesion模版 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param sqlSessionFactory &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @throws Exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "memberSqlSessionTemplate") &nbsp;&nbsp;&nbsp;&nbsp;public SqlSessionTemplate menberSqlSessionTemplate( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Qualifier("memberSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return new SqlSessionTemplate(sqlSessionFactory); &nbsp;&nbsp;&nbsp;&nbsp;} } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

**订单数据源**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> @Configuration @MapperScan(basePackages = "com.order.mapper", sqlSessionFactoryRef = "orderSqlSessionFactory") public class OrderDataSourceConfig { &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 将订单db注册到容器中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "orderDataSource") &nbsp;&nbsp;&nbsp;&nbsp;@ConfigurationProperties(prefix = "spring.datasource.order") &nbsp;&nbsp;&nbsp;&nbsp;public DataSource orderDataSource() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return DataSourceBuilder.create().build(); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 将订单SqlSessionFactory注册到容器中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param dataSource &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @throws Exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "orderSqlSessionFactory") &nbsp;&nbsp;&nbsp;&nbsp;public SqlSessionFactory orderSqlSessionFactory(@Qualifier("orderDataSource") DataSource dataSource) throws Exception { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sqlSessionFactoryBean.setDataSource(orderDataSource()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return sqlSessionFactoryBean.getObject(); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 创建订单管理器 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param dataSource &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "orderTransactionManager") &nbsp;&nbsp;&nbsp;&nbsp;public DataSourceTransactionManager orderTransactionManager(@Qualifier("orderDataSource") DataSource dataSource) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return new DataSourceTransactionManager(dataSource); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 创建订单sqlSesion模版 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param sqlSessionFactory &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @return &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @throws Exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Bean(name = "orderSqlSessionTemplate") &nbsp;&nbsp;&nbsp;&nbsp;public SqlSessionTemplate menberSqlSessionTemplate( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Qualifier("orderSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return new SqlSessionTemplate(sqlSessionFactory); &nbsp;&nbsp;&nbsp;&nbsp;} } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

**4.4.2创建分包Mapper **

**会员mapper**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public interface MemberMapper { &nbsp;&nbsp;&nbsp;&nbsp;@Insert("insert into users values(null,#{name},#{age});") &nbsp;&nbsp;&nbsp;&nbsp;public int addUser(@Param("name") String name, @Param("age") Integer age); } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

**订单mapper**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public interface OrderMapper { &nbsp;&nbsp;&nbsp;&nbsp;@Insert("insert into order_number values(null,#{number});") &nbsp;&nbsp;&nbsp;&nbsp;int inserOrder(@Param("number") String number); } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

如果多数据源使用事务报错的话

cted single matching bean but found 2: memberTransactionManager,orderTransactionManager

@Transactional(transactionManager = "memberTransactionManager")

明确指定使用那个事务管理器即可

@EnableConfigurationProperties(\{OrderConfig.**class**, MemberConfig.**class**\})