(另外一种方法）springboot使用MybatisPlus 如何同时连接2个MYSQL数据库

admin

(另外一种方法）springboot使用MybatisPlus 如何同时连接2个MYSQL数据库
在Spring Boot中同时连接两个MySQL数据库，你需要配置两个数据源并分别为它们创建相应的SqlSessionFactory和MapperScanner。以下是一个基本的配置示例：

在application.properties或application.yml中配置两个数据源的基本属性：

1. # 第一个数据库配置
   
2. spring.datasource.primary.jdbc-url=jdbc:mysql://localhost:3306/db1?useSSL=false
   
3. spring.datasource.primary.username=user1
   
4. spring.datasource.primary.password=pass1
   
5. 
   
6. # 第二个数据库配置
   
7. spring.datasource.secondary.jdbc-url=jdbc:mysql://localhost:3306/db2?useSSL=false
   
8. spring.datasource.secondary.username=user2
   
9. spring.datasource.secondary.password=pass2

复制代码

配置数据源和SqlSessionFactory：

1. @Configuration
   
2. public class DataSourceConfig {
   
3. 
   
4.     @Bean
   
5.     @Primary
   
6.     @ConfigurationProperties(prefix = "spring.datasource.primary")
   
7.     public DataSource primaryDataSource() {
   
8.         return DataSourceBuilder.create().build();
   
9.     }
   
10. 
    
11.     @Bean
    
12.     @ConfigurationProperties(prefix = "spring.datasource.secondary")
    
13.     public DataSource secondaryDataSource() {
    
14.         return DataSourceBuilder.create().build();
    
15.     }
    
16. 
    
17.     @Bean
    
18.     public SqlSessionFactory primarySqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource) throws Exception {
    
19.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    
20.         bean.setDataSource(dataSource);
    
21.         return bean.getObject();
    
22.     }
    
23. 
    
24.     @Bean
    
25.     public SqlSessionFactory secondarySqlSessionFactory(@Qualifier("secondaryDataSource") DataSource dataSource) throws Exception {
    
26.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    
27.         bean.setDataSource(dataSource);
    
28.         return bean.getObject();
    
29.     }
    
30. }

复制代码

配置MyBatis Plus的MapperScanner：

1. @Configuration
   
2. public class MybatisPlusConfig {
   
3. 
   
4.     @Bean
   
5.     public MybatisPlusInterceptor mybatisPlusInterceptor() {
   
6.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
   
7.         // 这里可以添加自定义的拦截器等
   
8.         return interceptor;
   
9.     }
   
10. 
    
11.     @Bean
    
12.     @Primary
    
13.     public SqlSessionTemplate primarySqlSessionTemplate(@Qualifier("primarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    
14.         return new SqlSessionTemplate(sqlSessionFactory);
    
15.     }
    
16. 
    
17.     @Bean
    
18.     public SqlSessionTemplate secondarySqlSessionTemplate(@Qualifier("secondarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    
19.         return new SqlSessionTemplate(sqlSessionFactory);
    
20.     }
    
21. }

复制代码

配置Mapper扫描，确保它们绑定到正确的SqlSessionTemplate：

1. @MapperScan(basePackages = "com.example.primary.mapper", sqlSessionTemplateRef = "primarySqlSessionTemplate")
   
2. @MapperScan(basePackages = "com.example.secondary.mapper", sqlSessionTemplateRef = "secondarySqlSessionTemplate")

复制代码

确保你的Mapper接口放在对应的包下，以便@MapperScan能够找到它们并为它们创建代理。

以上代码提供了一个基本框架，你需要根据自己的项目结构和需求进行相应的调整。例如，你可能需要为每个数据源配置事务管理器，并确保它们正确地与对应的SqlSessionTemplate关联。