本文是向大家介绍Fluent Mybatis ，其实不是介绍，如果只是简单介绍，官方文档足够了。而是实战深入，比较适合已经有一定了解FluentMybatis的同学。

它能够实现多数据源接入，不使用默认傻瓜式配置，避免泛泛而谈，似是而非，转眼就忘～

而是能够带来深入理解FluentMybatis的使用价值。

有兴趣的同学，不妨考虑适配Sharding-jdbc，Zdal-jdbc，组合使用，刚好可以锻炼提升一下～

前言： 什么是Fluent Mybatis

简单入门: 地址

和其他plus 框架比较

1. 配置案例

1.1 pom依赖jar包

1.8

UTF-8

UTF-8

2.3.7.RELEASE

2.6

1.1.17

1.8.7

8.0.17

com.github.atool

fluent-mybatis

${fluent-mybatis.version}

com.github.atool

fluent-mybatis-processor

provided

${fluent-mybatis.version}

com.alibaba

druid-spring-boot-starter

${druid.version}

org.mybatis.spring.boot

mybatis-spring-boot-starter

2.1.4

1.2 数据源 注解配置

package com.csu.andrew.fluentmybatisdemo.common.config;

import cn.org.atool.fluent.mybatis.spring.MapperFactory;

import com.alibaba.druid.pool.DruidDataSource;

import org.mybatis.spring.SqlSessionFactoryBean;

import org.mybatis.spring.annotation.MapperScan;

import org.springframework.beans.factory.annotation.Autowired;

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.core.io.support.ResourcePatternResolver;

/**

* @author zhangcq

* @version 1.0.0

* @title

* @date 2021/8/12 10:34

*/

@Configuration

@MapperScan(basePackages = "com.csu.andrew.fluentmybatisdemo.commondao.mapper", sqlSessionFactoryRef = "mgportraitbasecoreSqlSessionFactory")

@MapperScan(basePackages = "com.csu.andrew.fluentmybatisdemo.anotherdao.mapper", sqlSessionFactoryRef = "anotherSqlSessionFactory")

public class DataSourceCfg {

@Bean(initMethod = "init")

@Primary

@ConfigurationProperties(prefix = "custom.datasource1.druid")

public DruidDataSource getPrimaryDataSource() {

return new DruidDataSource();

}

@Bean("mgportraitbasecoreSqlSessionFactory")

@Primary

@Autowired

public SqlSessionFactoryBean sqlSessionFactoryBean(DruidDataSource druidDataSource) throws Exception {

SqlSessionFactoryBean bean = new SqlSessionFactoryBean();

bean.setDataSource(druidDataSource);

ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();

// 路径正则表达式方式加载

bean.setMapperLocations(resolver.getResources("classpath*:mapper/*.xml"));

// 一个个文件加载

// bean.setMapperLocations(

// new ClassPathResource("mapper/MyXmlMapper.xml"),

// new ClassPathResource("mapper/BatchUpdate.xml")

// );

org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();

configuration.setLazyLoadingEnabled(true);

configuration.setMapUnderscoreToCamelCase(true);

bean.setConfiguration(configuration);

return bean;

}

@Bean(initMethod = "init", value = "anotherDataSource")

@ConfigurationProperties(prefix = "custom.datasource2.druid")

public DruidDataSource getAnotherDataSource() {

return new DruidDataSource();

}

@Bean("anotherSqlSessionFactory")

@Autowired

public SqlSessionFactoryBean sqlSessionFactoryAnotherBean(@Qualifier("anotherDataSource") DruidDataSource druidDataSource) throws Exception {

SqlSessionFactoryBean bean = new SqlSessionFactoryBean();

bean.setDataSource(druidDataSource);

ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();

// 路径正则表达式方式加载

bean.setMapperLocations(resolver.getResources("classpath*:anothermapper/*.xml"));

// 一个个文件加载

// bean.setMapperLocations(

// new ClassPathResource("mapper/MyXmlMapper.xml"),

// new ClassPathResource("mapper/BatchUpdate.xml")

// );

org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();

configuration.setLazyLoadingEnabled(true);

configuration.setMapUnderscoreToCamelCase(true);

bean.setConfiguration(configuration);

return bean;

}

@Bean

public MapperFactory mapperFactory() {

return new MapperFactory();

}

}

1.3 application.properties 配置

# 应用名称

spring.application.name=fluent-mybatisdemo

# 应用服务 WEB 访问端口

server.port=8080

custom.db.ipport=admin.xuanqitang.cn:3306

custom.db.name=testdb

custom.db.user=**

custom.db.pass=***

custom.datasource1.druid.url=jdbc:mysql://${custom.db.ipport}/${custom.db.name}?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai

custom.datasource1.druid.username=${custom.db.user}

custom.datasource1.druid.password=${custom.db.pass}

custom.datasource1.druid.driver-class-name=com.mysql.cj.jdbc.Driver

custom.datasource2.druid.url=jdbc:mysql://${custom.db.ipport}/ry-vue?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai

custom.datasource2.druid.username=***

custom.datasource2.druid.password=***

custom.datasource2.druid.driver-class-name=com.mysql.cj.jdbc.Driver

2. 测试验证代码

@RestController

public class UserProvincePrecheckJobController {

@Autowired

SysDictDataDao sysDictDataDao;

@Autowired

UserProvincePrecheckJobDao userProvincePrecheckJobDao;

@GetMapping(value = "/test1")

@ResponseBody

public List getUserProvincePrecheckJobDo() {

return userProvincePrecheckJobDao.list();

}

@GetMapping(value = "/test2")

@ResponseBody

public List getSysDictDataDo() {

return sysDictDataDao.list();

}

}

2.1 验证数据源 testdb中的UserProvincePrecheckJobDo

2.2 验证数据源 ry-vue 中的 SysDictDataDo

3、参考

Let’s Fluent：更顺滑的MyBatis - 阿里云云栖号 - 博客园