之前寫過(guò)一篇jpa的多數(shù)據(jù)源配置，隨著各種項(xiàng)目的不斷開(kāi)發(fā)，發(fā)現(xiàn)有時(shí)Mybatis操作數(shù)據(jù)更加方便，所以把Mybatis多數(shù)據(jù)源配置的方法也隨手記錄下，希望對(duì)你有幫助

1、先在application.yml 中配置多個(gè)數(shù)據(jù)庫(kù)

server:
  port: 13001
  address: 127.0.0.1
spring:
  application:
    name: log_common
  datasource:
    user_center:
      url: jdbc:mysql://localhost:3306/user_center?useUnicode=true&characterEncoding=utf8&useSSL=false
      username: root
      password: 12345678
      driver-class-name: com.mysql.jdbc.Driver
    log_common:
      url: jdbc:mysql://localhost:3306/log_common?useUnicode=true&characterEncoding=utf8&useSSL=false
      username: root
      password: 12345678
      driver-class-name: com.mysql.jdbc.Driver
# mybatis
mybatis:
  configuration:
    call-setters-on-nulls: true
    map-underscore-to-camel-case: true
mapper:
  mappers:
  - tk.mybatis.mapper.common.Mapper
  notEmpty: true
# 分頁(yè)插件配置
pagehelper:
  helperDialect: mysql
  reasonable: true
  supportMethodsArguments: true
  params: count=countSql

2、數(shù)據(jù)源連接配置

第一個(gè)數(shù)據(jù)源配置
LCDataSourceConfig.java

package com.haizhi.log_common.config;

import com.zaxxer.hikari.HikariDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.core.io.support.ResourcePatternResolver;
import tk.mybatis.spring.annotation.MapperScan;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = {"com.haizhi.log_common.mapper.lc"}, sqlSessionTemplateRef = "logCommonSqlSessionTemplate")
public class LCDataSourceConfig {
    @Value("${spring.datasource.log_common.url}")
    private String url;
    @Value("${spring.datasource.log_common.username}")
    private String username;
    @Value("${spring.datasource.log_common.password}")
    private String password;
    @Value("${spring.datasource.log_common.driver-class-name}")
    private String driverClassName;


    @Bean(name = "logCommonSource")
    public DataSource userDataSource() {
        // 此處用的是HikariDataSource，也可替換為druid
        HikariDataSource hikariDataSource = new HikariDataSource();
        hikariDataSource.setJdbcUrl(url);
        hikariDataSource.setUsername(username);
        hikariDataSource.setPassword(password);
        hikariDataSource.setDriverClassName(driverClassName);
        return hikariDataSource;
    }
    @Bean
    public SqlSessionFactory logCommonSqlSessionFactory(@Qualifier("logCommonSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //添加X(jué)ML目錄
        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        try {
            bean.setMapperLocations(resolver.getResources("classpath*:mapper/lc/*.xml"));
            return bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
    @Bean
    public SqlSessionTemplate logCommonSqlSessionTemplate(@Qualifier("logCommonSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory); // 使用上面配置的Factory
        return template;
    }
}

上述注意兩個(gè)地方
com.haizhi.log_common.mapper.lc : 第一個(gè)數(shù)據(jù)源的mapper路徑classpath:mapper/lc/.xml : 第一個(gè)數(shù)據(jù)源的xml路徑

第二個(gè)數(shù)據(jù)源配置
UCDataSourceConfig.java

package com.haizhi.log_common.config;

import com.zaxxer.hikari.HikariDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.core.io.support.ResourcePatternResolver;
import tk.mybatis.spring.annotation.MapperScan;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = {"com.haizhi.log_common.mapper.uc"}, sqlSessionTemplateRef = "userCenterSqlSessionTemplate")
public class UCDataSourceConfig {
    @Value("${spring.datasource.user_center.url}")
    private String url;
    @Value("${spring.datasource.user_center.username}")
    private String username;
    @Value("${spring.datasource.user_center.password}")
    private String password;
    @Value("${spring.datasource.user_center.driver-class-name}")
    private String driverClassName;


    @Bean(name = "userCenterSource")
    @Primary //必須加此注解，不然報(bào)錯(cuò)，下一個(gè)類則不需要添加
    public DataSource userDataSource() {
        HikariDataSource hikariDataSource = new HikariDataSource();
        hikariDataSource.setJdbcUrl(url);
        hikariDataSource.setUsername(username);
        hikariDataSource.setPassword(password);
        hikariDataSource.setDriverClassName(driverClassName);
        return hikariDataSource;
    }
    @Bean
    public SqlSessionFactory userCenterSqlSessionFactory(@Qualifier("userCenterSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //添加X(jué)ML目錄
        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        try {
            bean.setMapperLocations(resolver.getResources("classpath*:mapper/uc/*.xml"));
            return bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
    @Bean
    public SqlSessionTemplate userCenterSqlSessionTemplate(@Qualifier("userCenterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory); // 使用上面配置的Factory
        return template;
    }
}

上述注意兩個(gè)地方
com.haizhi.log_common.mapper.uc : 第一個(gè)數(shù)據(jù)源的mapper路徑classpath:mapper/uc/.xml : 第一個(gè)數(shù)據(jù)源的xml路徑

以上多數(shù)據(jù)源的配置已經(jīng)配好了，手動(dòng)創(chuàng)建mapper或者用mapper生成器生成文件，只需要把對(duì)應(yīng)的mapper和xml文件放到對(duì)應(yīng)的目錄下就可以完成配置，方便簡(jiǎn)單，希望對(duì)你有所幫助，最后附上項(xiàng)目目錄結(jié)構(gòu)

1.png