Spring Boot 支持多数据源配置,可以通过配置多个数据源来访问不同的数据库。

步骤:

1.在 application.properties 中配置数据源信息,例如:

spring.datasource.url=jdbc:mysql://localhost:3306/db1
spring.datasource.username=root
spring.datasource.password=123456

spring.datasource2.url=jdbc:mysql://localhost:3306/db2
spring.datasource2.username=root
spring.datasource2.password=123456

2.创建两个数据源的配置类,例如:

@Configuration
@MapperScan(basePackages = "com.example.demo.mapper1", sqlSessionTemplateRef = "db1SqlSessionTemplate")
public class Db1DataSourceConfig {

    @Bean(name = "db1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource db1DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "db1SqlSessionFactory")
    public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        return bean.getObject();
    }

    @Bean(name = "db1SqlSessionTemplate")
    public SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

@Configuration
@MapperScan(basePackages = "com.example.demo.mapper2", sqlSessionTemplateRef = "db2SqlSessionTemplate")
public class Db2DataSourceConfig {

    @Bean(name = "db2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource2")
    public DataSource db2DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "db2SqlSessionFactory")
    public SqlSessionFactory db2SqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        return bean.getObject();
    }

    @Bean(name = "db2SqlSessionTemplate")
    public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

3.在需要访问数据源的地方使用 @Qualifier 注解指定数据源,例如:

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    @Qualifier("db1SqlSessionTemplate")
    private SqlSessionTemplate db1SqlSessionTemplate;

    @Autowired
    @Qualifier("db2SqlSessionTemplate")
    private SqlSessionTemplate db2SqlSessionTemplate;

    @Override
    public List<User> getUserListFromDb1() {
        return db1SqlSessionTemplate.selectList("com.example.demo.mapper1.UserMapper.getUserList");
    }

    @Override
    public List<User> getUserListFromDb2() {
        return db2SqlSessionTemplate.selectList("com.example.demo.mapper2.UserMapper.getUserList");
    }
}

以上就是 Spring Boot 多数据源配置的步骤。

Springboot 多数据源配置

原文地址: https://www.cveoy.top/t/topic/xVW 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录