tk-mybatis整合springBoot使用两个数据源的方法

 更新时间:2021年12月01日 10:52:15   作者:Dark_Zhou  
单纯的使用mybaits进行多数据配置网上资料很多,但是关于tk-mybaits多数据源配置没有相关材料,本文就详细的介绍一下如何使用,感兴趣的可以了解一下

根据项目功能需求,需要与第三方公共库对接,需要对公共库进行相关操作,由于不想使用原生jdbc,所以采用mybaits进行多数据配置。

单纯的使用mybaits进行多数据配置网上资料很多,但由于前期为了方便开发,采用了tk-mybaits。关于tk-mybaits多数据源配置没有相关材料,官方也没有提供相关功能说明,所以最终采用mybatis+tk-mybaits分别使用的策略进行多数据源配置功能实现。具体代码如下

一、配置连接信息

#开发运行环境数据库
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
 
#第三方对接通用数据库
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数据源

 注意两个数据源中有一个是为主数据源,需要增加一个@Primary注解,有且只能有一个需要。关于2个以上数据源没有额外再进行研究了,不过利用mybatis再额外配置多个数据源应该可以实现

1.数据源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;
 
/**
 * 开发运行环境数据库
 */
@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.数据源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;
 
/**
 * 公共通用数据库
 */
@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代码结构

补充:

一、解决mybatis数据库驼峰命名自动映射问题以及sql语句打印问题,通过读取配置文件实现。两个数据源都需要设置

    @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统一配置

数据库方言 指定分页插件使用哪种数据库方言
pagehelper.helperDialect=mysql
#分页参数合理化 pageNum<=0 时会查询第一页, pageNum>pages(超过总数时),会查询最后一页
pagehelper.reasonable=true
pagehelper.supportMethodsArguments=true
pagehelper.params=count=countSql

到此这篇关于tk-mybatis整合springBoot使用两个数据源的方法的文章就介绍到这了,更多相关tk-mybatis springBoot数据源内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Spring Boot中@ConditionalOnProperty的使用方法

    Spring Boot中@ConditionalOnProperty的使用方法

    这篇文章主要给大家介绍了关于Spring Boot中@ConditionalOnProperty的使用方法,文中通过示例代码介绍的非常详细,对大家的学习或者使用Spring Boot具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-12-12
  • Java如何通过反射获取对象的属性和值

    Java如何通过反射获取对象的属性和值

    这篇文章主要介绍了Java如何通过反射获取对象的属性和值问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-02-02
  • Java中的图形界面重绘方式

    Java中的图形界面重绘方式

    这篇文章主要介绍了Java中的图形界面重绘方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-03-03
  • Java按照添加顺序的集合几种方法详解

    Java按照添加顺序的集合几种方法详解

    这篇文章主要介绍了Java按照添加顺序的集合几种方法的相关资料,文中介绍了Java中五种常用的数据结构(ArrayList、LinkedList、LinkedHashSet、LinkedHashMap、Stream)及其特点,适合不同的应用场景,需要的朋友可以参考下
    2024-12-12
  • spring data jpa如何只查询实体部分字段

    spring data jpa如何只查询实体部分字段

    这篇文章主要介绍了spring data jpa如何只查询实体部分字段的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • javaweb实现在线支付功能

    javaweb实现在线支付功能

    这篇文章主要为大家详细介绍了javaweb实现在线支付功能的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-11-11
  • SpringCloud整合Activiti过程中的踩坑记录

    SpringCloud整合Activiti过程中的踩坑记录

    由于项目需要,最近开始在项目Spring boot中集成工作流引擎Activiti,由于第一次集成,一路上步步都是坑,所以这篇文章主要给大家介绍了关于SpringCloud整合Activiti过程中所遇到的踩坑记录,需要的朋友可以参考下
    2021-09-09
  • Java实现的质因数分解操作示例【基于递归算法】

    Java实现的质因数分解操作示例【基于递归算法】

    这篇文章主要介绍了Java实现的质因数分解操作,结合实例形式较为详细的分析了Java基于递归算法实现针对整数的质因数分解相关操作技巧,需要的朋友可以参考下
    2018-03-03
  • 什么情况下会出现java.io.IOException : Broken pipe这个错误以及解决办法

    什么情况下会出现java.io.IOException : Broken pipe这个错误以及解决办法

    这篇文章主要介绍了什么情况下会出现java.io.IOException : Broken pipe这个错误以及解决办法的相关资料,这个错误表示通信另一端已关闭连接,常发生在客户端关闭连接、网络超时或资源不足等情况,文中将解决办法介绍的非常详细,需要的朋友可以参考下
    2024-10-10
  • 如何利用java实现生成PDF文件

    如何利用java实现生成PDF文件

    前段时间因为相关业务需求需要后台生成pdf文件,下面这篇文章主要给大家介绍了关于如何利用java实现生成PDF文件的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2022-10-10

最新评论