关于springboot:Spring-Boot连接多个数据库

6次阅读

共计 4164 个字符，预计需要花费 11 分钟才能阅读完成。

微服务架构流行的明天，应用服务与数据库的对应关系通常是一个微服务对应一个数据库。

在一个电商零碎中，用户信息存储在用户数据库中，订单信息存储在订单数据库中，如果一次申请须要获取订单相干信息，则须要将订单信息和下单的用户信息一起查问进去。

在订单服务中获取用户数据不会间接调用用户数据库，而是通过调用用户治理服务的接口。

这种架构在大型零碎中劣势很显著，在业务上能够解耦，防止一个服务对用多个数据库，导致业务凌乱，系统维护艰难。也能够进步数据库的安全性。

然而在些 B 端的管理系统，架构通常没有这么简单（单体架构），只有一个服务。
这种利用也有连贯多个数据库的需要，例如同步数据库。

这里应用 Spring Boot 和 Mybatis。

因为 Spring boot 的易用性，默认状况下，咱们只须要在 application 配置文件中，

配置好数据源的信息
Mybtis 的 Mapper 扫描门路，
以及在 Configuration 类中配置 MapperScan 配置对应 Mapper 类的包门路

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db1?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8
    username: root
    password:  12345
mybatis: 
  mapper-locations: /mapper/**.xml

@SpringBootApplication
@MapperScan("icu.daydream.demo.mybatisdemo.mapper")
public class MybatisDemoApplication {public static void main(String[] args) {SpringApplication.run(MybatisDemoApplication.class, args);
    }

}

实现以上三个配置，不须要再创立 DataSource 对象，以及 SqlSessionFactory 对象，即可使利用主动连贯上数据库。体现了 Spring Boot 约定大于配置 的个性。

当初咱们的需要是同时连贯两个数据库，Spring Boot 的默认配置曾经满足不了需要，因而就须要手动的去配置数据源信息。

先创立连贯数据库 1 的须要的对象。

@Configuration
@MapperScan(basePackages = DataSourceConfig1.PACKAGE,sqlSessionFactoryRef = "sqlSessionFactory1")
public class DataSourceConfig1 {
    // 数据库 1 扫描的 Mapper 类门路
    final static String PACKAGE = "test.mapper.db1";

    @Bean(name = "dataSource1")
    // 将 yaml 文件中的 datasource1 下的属性 注入到 DataSource 对象中
    @ConfigurationProperties(prefix = "datasource1")
    public DataSource businessDbDataSource() {return new DruidDataSource();
    }

    @Bean(name = "sqlSessionFactory1")
    public SqlSessionFactory sqlSessionFactory1(@Qualifier("dataSource1") DataSource dataSource ) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource); 
        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/db1/*.xml"));
        return factoryBean.getObject();}
    
}

默认配置下这两个 Bean 对象是主动创立的，当初显式创立后，Spring Boot 的默认配置对象就不会再创立了，application.yaml 中 mybatis 下的一些配置也跟着生效了。须要显式创立 Myabtis 的 Configuration 配置对象。这个前面再讲。

目前曾经配置好了数据库 1 的连贯，同样地，再创立一个连贯数据库 2 的对象。

@Configuration
@MapperScan(basePackages = DataSourceConfig2.PACKAGE,sqlSessionFactoryRef = "sqlSessionFactory2")
public class DataSourceConfig2 {
    // 数据库 1 扫描的 Mapper 类门路
    final static String PACKAGE = "test.mapper.db2";

    @Bean(name = "dataSource2")
    // 将 yaml 文件中的 datasource1 下的属性 注入到 DataSource 对象中
    @ConfigurationProperties(prefix = "datasource2")
    public DataSource businessDbDataSource() {return new DruidDataSource();
    }

    @Bean(name = "sqlSessionFactory2")
    public SqlSessionFactory sqlSessionFactory1(@Qualifier("dataSource2") DataSource dataSource ) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/db2/*.xml"));
        return factoryBean.getObject();} 
}

包构造如下：

以上多数据源就配置实现了，db1 下的 mapper 查问会连贯数据库 1，db2 下的 mapper 连贯数据库 2 .

@Bean：在 @Configuration 类中应用，作用在办法上，办法的返回值为创立 Bean 对象，并注入到 Spring 容器中。属性 name 为 Bean 对象的名称，不加则办法名为 Bean 对象名称。
@MapperScan：用于扫描 Mapper 对象的包门路
@Qualifier：作用在办法参数上，依据 Bean 对象名称注入 Bean 对象

在配置连个数据源后，application 中 mybatis 下的相干配置生效了。例如将 SQL 查问的字段名从下划线转为小驼峰，通常在 application 中这么配置：

mybatis:
  configuration:
    map-underscore-to-camel-case: true

在创立多个数据源后，该配置生效了，因为 Mybatis 中的 Configuration 没有被创立，在多个数据源的状况下，Mybatis 也不晓得要将该配置配置在哪个数据源下。

因而须要手动创立 Configuration Bean 对象，并注入到 SqlSessionFactoryBean 对象中。

@Bean("customSessionConfiguration")
@ConfigurationProperties(prefix = "mybatis.configuration")
public org.apache.ibatis.session.Configuration configuration(){return new org.apache.ibatis.session.Configuration();
}

@Bean(name = "sqlSessionFactory1")
public SqlSessionFactory sqlSessionFactory1(@Qualifier("dataSource1") DataSource dataSource , @Qualifier("customSessionConfiguration") org.apache.ibatis.session.Configuration configuration) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
    factoryBean.setDataSource(dataSource);
    factoryBean.setConfiguration(configuration);
    factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
            .getResources("classpath:mapper/db1/*.xml"));
    return factoryBean.getObject();}

如果感觉文章对你有帮忙，就请作者喝杯 Java 吧！我是白日梦。

正文完