tk-mybatis整合springBoot使用兩個數(shù)據(jù)源的方法是什么

這篇文章主要介紹“tk-mybatis整合springBoot使用兩個數(shù)據(jù)源的方法是什么”，在日常操作中，相信很多人在tk-mybatis整合springBoot使用兩個數(shù)據(jù)源的方法是什么問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”tk-mybatis整合springBoot使用兩個數(shù)據(jù)源的方法是什么”的疑惑有所幫助！接下來，請跟著小編一起來學(xué)習(xí)吧！

根據(jù)項目功能需求，需要與第三方公共庫對接，需要對公共庫進(jìn)行相關(guān)操作，由于不想使用原生jdbc，所以采用mybaits進(jìn)行多數(shù)據(jù)配置。

單純的使用mybaits進(jìn)行多數(shù)據(jù)配置網(wǎng)上資料很多，但由于前期為了方便開發(fā)，采用了tk-mybaits。關(guān)于tk-mybaits多數(shù)據(jù)源配置沒有相關(guān)材料，官方也沒有提供相關(guān)功能說明，所以最終采用mybatis+tk-mybaits分別使用的策略進(jìn)行多數(shù)據(jù)源配置功能實現(xiàn)。具體代碼如下

一、配置連接信息

#開發(fā)運(yùn)行環(huán)境數(shù)據(jù)庫
spring.datasource.local.url=jdbc:mysql://0.0.0.0:3306/zhdd
spring.datasource.local.username=root
spring.datasource.local.password=
spring.datasource.local.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.local.druid.initial-size=1
spring.datasource.local.druid.min-idle=1
spring.datasource.local.druid.max-active=20
spring.datasource.local.druid.test-on-borrow=true
spring.datasource.local.druid.stat-view-servlet.allow=true
 
#第三方對接通用數(shù)據(jù)庫
spring.datasource.public.url=jdbc:mysql://0.0.0.0:3306/zhdd
spring.datasource.public.username=root
spring.datasource.public.password=
spring.datasource.public.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.public.druid.initial-size=1
spring.datasource.public.druid.min-idle=1
spring.datasource.public.druid.max-active=20
spring.datasource.public.druid.test-on-borrow=true
spring.datasource.public.druid.stat-view-servlet.allow=true

 二、配置DataSource數(shù)據(jù)源

 注意兩個數(shù)據(jù)源中有一個是為主數(shù)據(jù)源，需要增加一個@Primary注解，有且只能有一個需要。關(guān)于2個以上數(shù)據(jù)源沒有額外再進(jìn)行研究了，不過利用mybatis再額外配置多個數(shù)據(jù)源應(yīng)該可以實現(xiàn)

1.數(shù)據(jù)源1配置

package com.hiynn.core.mybatis;
 
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
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.jdbc.datasource.DataSourceTransactionManager;
 
import javax.sql.DataSource;
 
/**
 * 開發(fā)運(yùn)行環(huán)境數(shù)據(jù)庫
 */
@Configuration
public class LocalDataSourceConfig {
 
    @Bean(name = "localDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.local")
    @Primary
    public DataSource localDataSource() {
        return DruidDataSourceBuilder.create().build();
    }
 
    @Bean(name = "localTransactionManager")
    @Primary
    public DataSourceTransactionManager mysqlTransactionManager() {
        return new DataSourceTransactionManager(localDataSource());
    }
 
    @Bean(name = "localSqlSessionFactory")
    @Primary
    public SqlSessionFactory mysqlSqlSessionFactory(@Qualifier("localDataSource") DataSource dataSource)
            throws Exception {
        SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(dataSource);
        //如果不使用xml的方式配置mapper，則可以省去下面這行mapper location的配置。
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath*:mapper/*.xml"));
        return sessionFactory.getObject();
    }
}

2.數(shù)據(jù)源2配置

package com.hiynn.core.mybatis;
 
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 
import javax.sql.DataSource;
 
/**
 * 公共通用數(shù)據(jù)庫
 */
@Configuration
public class PublicDataSourceConfig {
 
    @Bean(name = "publicDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.public")
    public DataSource publicDataSource() {
        return DruidDataSourceBuilder.create().build();
    }
 
    @Bean(name = "publicTransactionManager")
    public DataSourceTransactionManager mysqlTransactionManager() {
        return new DataSourceTransactionManager(publicDataSource());
    }
 
    @Bean(name = "publicSqlSessionFactory")
    public SqlSessionFactory mysqlSqlSessionFactory(@Qualifier("publicDataSource") DataSource dataSource)
            throws Exception {
        SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(dataSource);
        //如果不使用xml的方式配置mapper，則可以省去下面這行mapper location的配置。
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath*:mapper2/*.xml"));
        return sessionFactory.getObject();
    }
}

三、Application配置

package com.hiynn.core;
 
//特別注意，下面的是 tk.MapperScan
 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
import tk.mybatis.spring.annotation.MapperScan;
 
/**
 * @author zz
 * @date 2018-7-2
 */
@ServletComponentScan
@SpringBootApplication
@EnableTransactionManagement
@EnableSwagger2
@MapperScan(basePackages = "com.hiynn.core.**.mapper",sqlSessionFactoryRef = "localSqlSessionFactory")
@org.mybatis.spring.annotation.MapperScan(basePackages = "com.hiynn.core.**.mapper2",sqlSessionFactoryRef = "publicSqlSessionFactory")
public class Application extends SpringBootServletInitializer{
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

四、Mapper代碼結(jié)構(gòu)

補(bǔ)充：

一、解決mybatis數(shù)據(jù)庫駝峰命名自動映射問題以及sql語句打印問題，通過讀取配置文件實現(xiàn)。兩個數(shù)據(jù)源都需要設(shè)置

@Bean(name = "localSqlSessionFactory")
    @Primary
    public SqlSessionFactory mysqlSqlSessionFactory(@Qualifier("localDataSource") DataSource dataSource)
            throws Exception {
        SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(dataSource);
        //添加mybatis配置文件讀取功能更
        sessionFactory.setConfigLocation(new PathMatchingResourcePatternResolver().getResource("mybatis-config.xml"));
        //如果不使用xml的方式配置mapper，則可以省去下面這行mapper location的配置。
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath*:mapper/*.xml"));
        return sessionFactory.getObject();
    }

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
        <setting name="mapUnderscoreToCamelCase" value="true" />
        <!-- 打印查詢語句 -->
        <setting name="logImpl" value="STDOUT_LOGGING" />
    </settings>
</configuration>

二、配置PageHelper分頁插件，在application.properties統(tǒng)一配置

數(shù)據(jù)庫方言 指定分頁插件使用哪種數(shù)據(jù)庫方言
pagehelper.helperDialect=mysql
#分頁參數(shù)合理化 pageNum<=0 時會查詢第一頁， pageNum>pages（超過總數(shù)時），會查詢最后一頁
pagehelper.reasonable=true
pagehelper.supportMethodsArguments=true
pagehelper.params=count=countSql

到此，關(guān)于“tk-mybatis整合springBoot使用兩個數(shù)據(jù)源的方法是什么”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識，請繼續(xù)關(guān)注億速云網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>