springboot使用MybatisPlus 如何同时连接2个MYSQL数据库

admin

springboot使用MybatisPlus 如何同时连接2个MYSQL数据库
在 Spring Boot 中使用 MyBatis-Plus 同时连接两个 MySQL 数据库，可以通过配置多个  `DataSource`  和  `SqlSessionFactory`  来实现。以下是具体的步骤：
### 步骤 1: 添加依赖
确保在  `pom.xml`  中添加 MyBatis-Plus 和 MySQL 的依赖：

1. xml
   
2. <dependency>
   
3.     <groupId>mysql</groupId>
   
4.     <artifactId>mysql-connector-java</artifactId>
   
5.     <version>8.0.27</version> <!-- 使用最新版本 -->
   
6. </dependency>
   
7. <dependency>
   
8.     <groupId>com.baomidou</groupId>
   
9.     <artifactId>mybatis-plus-boot-starter</artifactId>
   
10.     <version>3.4.3</version> <!-- 使用最新版本 -->
    
11. </dependency>

复制代码

### 步骤 2: 配置  `application.properties`  或  `application.yml`
在配置文件中定义两个数据源的属性。例如，使用  `application.properties` ：

1. properties
   
2. # 数据源 1
   
3. spring.datasource.primary.url=jdbc:mysql://localhost:3306/db1
   
4. spring.datasource.primary.username=root
   
5. spring.datasource.primary.password=yourpassword
   
6. spring.datasource.primary.driver-class-name=com.mysql.cj.jdbc.Driver
   
7. # 数据源 2
   
8. spring.datasource.secondary.url=jdbc:mysql://localhost:3306/db2
   
9. spring.datasource.secondary.username=root
   
10. spring.datasource.secondary.password=yourpassword
    
11. spring.datasource.secondary.driver-class-name=com.mysql.cj.jdbc.Driver

复制代码

### 步骤 3: 创建数据源配置类
为每个数据源创建配置类。
#### 主数据源配置

1. import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
   
2. import com.zaxxer.hikari.HikariDataSource;
   
3. import org.mybatis.spring.SqlSessionFactoryBean;
   
4. import org.springframework.beans.factory.annotation.Qualifier;
   
5. import org.springframework.boot.autoconfigure.orm.jpa.HibernatePropertiesCustomizer;
   
6. import org.springframework.boot.context.properties.ConfigurationProperties;
   
7. import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
   
8. import org.springframework.context.annotation.Bean;
   
9. import org.springframework.context.annotation.Configuration;
   
10. import org.springframework.context.annotation.Primary;
    
11. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
12. import org.springframework.orm.jpa.JpaTransactionManager;
    
13. import org.springframework.orm.mybatis.SqlSessionFactoryBean;
    
14. import org.springframework.transaction.PlatformTransactionManager;
    
15. import javax.sql.DataSource;
    
16. @Configuration
    
17. public class PrimaryDataSourceConfig {
    
18.      @Bean(name = "primaryDataSource")
    
19.     @ConfigurationProperties("spring.datasource.primary")
    
20.     @Primary
    
21.     public DataSource primaryDataSource() {
    
22.         return new HikariDataSource();
    
23.     }
    
24.      @Bean(name = "primarySqlSessionFactory")
    
25.     @Primary
    
26.     public SqlSessionFactory primarySqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource) throws Exception {
    
27.         SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
    
28.         factoryBean.setDataSource(dataSource);
    
29.         return factoryBean.getObject();
    
30.     }
    
31.      @Bean(name = "primaryTransactionManager")
    
32.     @Primary
    
33.     public PlatformTransactionManager primaryTransactionManager(@Qualifier("primaryDataSource") DataSource dataSource) {
    
34.         return new DataSourceTransactionManager(dataSource);
    
35.     }
    
36. }

复制代码

#### 次数据源配置

1. import com.zaxxer.hikari.HikariDataSource;
   
2. import org.mybatis.spring.SqlSessionFactoryBean;
   
3. import org.springframework.beans.factory.annotation.Qualifier;
   
4. import org.springframework.boot.context.properties.ConfigurationProperties;
   
5. import org.springframework.context.annotation.Bean;
   
6. import org.springframework.context.annotation.Configuration;
   
7. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
   
8. import org.springframework.orm.mybatis.SqlSessionFactoryBean;
   
9. import org.springframework.transaction.PlatformTransactionManager;
   
10. import javax.sql.DataSource;
    
11. @Configuration
    
12. public class SecondaryDataSourceConfig {
    
13.      @Bean(name = "secondaryDataSource")
    
14.     @ConfigurationProperties("spring.datasource.secondary")
    
15.     public DataSource secondaryDataSource() {
    
16.         return new HikariDataSource();
    
17.     }
    
18.      @Bean(name = "secondarySqlSessionFactory")
    
19.     public SqlSessionFactory secondarySqlSessionFactory(@Qualifier("secondaryDataSource") DataSource dataSource) throws Exception {
    
20.         SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
    
21.         factoryBean.setDataSource(dataSource);
    
22.         return factoryBean.getObject();
    
23.     }
    
24.      @Bean(name = "secondaryTransactionManager")
    
25.     public PlatformTransactionManager secondaryTransactionManager(@Qualifier("secondaryDataSource") DataSource dataSource) {
    
26.         return new DataSourceTransactionManager(dataSource);
    
27.     }
    
28. }

复制代码

### 步骤 4: 创建实体和 Mapper
为每个数据库创建相应的实体类和 Mapper 接口，确保它们位于正确的包中。
### 步骤 5: 使用 Mapper
在服务中，可以根据需要注入主数据源和次数据源的 Mapper：

1. import org.springframework.beans.factory.annotation.Autowired;
   
2. import org.springframework.stereotype.Service;
   
3. @Service
   
4. public class MyService {
   
5.      @Autowired
   
6.     private PrimaryMapper primaryMapper;
   
7.      @Autowired
   
8.     private SecondaryMapper secondaryMapper;
   
9.      public void saveData() {
   
10.         // 使用 primaryMapper 和 secondaryMapper 进行数据操作
    
11.     }
    
12. }

复制代码

### 总结
通过以上步骤，你可以在 Spring Boot 应用中同时连接两个 MySQL 数据库，并使用 MyBatis-Plus 进行数据操作。