MyBatis多數(shù)據(jù)源的兩種配置方式
前言
同一個(gè)項(xiàng)目有時(shí)會(huì)涉及到多個(gè)數(shù)據(jù)庫(kù)，也就是多數(shù)據(jù)源。多數(shù)據(jù)源又可以分為兩種情況：
1）兩個(gè)或多個(gè)數(shù)據(jù)庫(kù)沒(méi)有相關(guān)性，各自獨(dú)立，其實(shí)這種可以作為兩個(gè)項(xiàng)目來(lái)開(kāi)發(fā)。比如在游戲開(kāi)發(fā)中一個(gè)數(shù)據(jù)庫(kù)是平臺(tái)數(shù)據(jù)庫(kù)，其它還有平臺(tái)下的游戲?qū)?yīng)的數(shù)據(jù)庫(kù)；
2）兩個(gè)或多個(gè)數(shù)據(jù)庫(kù)是master-slave的關(guān)系，比如有mysql搭建一個(gè) master-master，其后又帶有多個(gè)slave；或者采用MHA搭建的master-slave復(fù)制；
MyBatis多數(shù)據(jù)源的配置主要有兩種方式:
- 通過(guò)@MapperScan注解，對(duì)不同包下的Mapper使用不同的sqlSessionFactory
- 通過(guò)@MapperScan注解加自定義注解，對(duì)使用不同注解的Mapper使用不同的sqlSessionFactory
第二種配置相對(duì)靈活，示例如下:
package bj;
import ch.qos.logback.classic.Level;
import ch.qos.logback.classic.Logger;
import com.zaxxer.hikari.HikariDataSource;
import io.shardingsphere.shardingjdbc.spring.boot.SpringBootConfiguration;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.core.JdbcTemplate;
import javax.annotation.Resource;
import javax.sql.DataSource;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import java.util.List;
import java.util.Map;
/**
* Created by BaiJiFeiLong@gmail.com at 2018/12/6 下午9:29
* <p>
* MyBatis多數(shù)據(jù)源演示
*/
@SpringBootApplication(exclude = {SpringBootConfiguration.class})
@Configuration
@MapperScan(annotationClass = Mapper.class, basePackageClasses = MyBatisApp.class,
sqlSessionFactoryRef = "sqlSessionFactory")
public class MyBatisApp implements ApplicationListener<ApplicationReadyEvent> {
/**
* SecondaryMapper配置
* \@MapperScan 注解一次只能添加一個(gè)，所以需要單獨(dú)再加一個(gè)配置類(lèi)
* 自定義@MapperScan會(huì)替換MyBatis自動(dòng)添加的默認(rèn)@MapperScan。所以主@MapperScan也必須顯式添加
*/
@Configuration
@MapperScan(annotationClass = SecondaryMapper.class, basePackageClasses = MyBatisApp.class,
sqlSessionFactoryRef = "sqlSessionFactorySecond")
static class SecondaryMapperConfiguration {
}
public static void main(String[] args) {
new SpringApplication(MyBatisApp.class) {{
setWebApplicationType(WebApplicationType.NONE);
}}.run(args);
}
@Resource
private DataSource dataSource;
@Resource
private DataSource dataSourceSecond;
@Resource
private JdbcTemplate jdbcTemplate;
@Resource
private UserMapper userMapper;
@Resource
private SecondaryUserMapper secondaryUserMapper;
private void initLogger() {
((Logger) LoggerFactory.getLogger(MyBatisApp.class)).setLevel(Level.DEBUG);
((Logger) LoggerFactory.getLogger(JdbcTemplate.class)).setLevel(Level.DEBUG);
}
private void initDatabase() {
String oldDatabase = jdbcTemplate.queryForObject("SELECT DATABASE()", String.class);
jdbcTemplate.execute("DROP SCHEMA IF EXISTS one");
jdbcTemplate.execute("CREATE SCHEMA one");
jdbcTemplate.execute("USE one");
jdbcTemplate.execute("CREATE TABLE user(id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(32) CHARSET 'utf8')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的兒子')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的孫子')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的曾孫子')");
jdbcTemplate.execute("DROP SCHEMA IF EXISTS two");
jdbcTemplate.execute("CREATE SCHEMA two");
jdbcTemplate.execute("USE two");
jdbcTemplate.execute("CREATE TABLE user(id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(32) CHARSET 'utf8')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的爹')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的爺')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的太爺')");
jdbcTemplate.execute("INSERT INTO user(name) VALUES ('人民的老太爺')");
jdbcTemplate.execute("USE " + oldDatabase);
}
@Override
public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) {
initLogger();
initDatabase();
System.out.println("Users:");
userMapper.selectAll().forEach(System.out::println);
System.out.println("Secondary users:");
secondaryUserMapper.selectAll().forEach(System.out::println);
}
/**
* 主數(shù)據(jù)源
* <p>
* 如果不添加@Primary注解, MyBatis可以工作，但是JdbcTemplate無(wú)法注入
*
* @return .
*/
@Primary
@Bean
public DataSource dataSource() {
return new HikariDataSource() {{
setJdbcUrl("jdbc:mysql://localhost/one?useUnicode=true&characterEncoding=utf8");
setUsername("root");
setPassword("root");
}};
}
/**
* 副數(shù)據(jù)源
*
* @return .
*/
@Bean
public DataSource dataSourceSecond() {
return new HikariDataSource() {{
setJdbcUrl("jdbc:mysql://localhost/two?useUnicode=true&characterEncoding=utf8");
setUsername("root");
setPassword("root");
}};
}
/**
* 主SqlSessionFactory。使用主數(shù)據(jù)源。自定義SqlSessionFactory后，MyBatis就不自動(dòng)添加SqlSessionFactory了，所以必須有
*
* @return .
* @throws Exception .
*/
@Bean
public SqlSessionFactory sqlSessionFactory() throws Exception {
return new SqlSessionFactoryBean() {{
setDataSource(dataSource);
}}.getObject();
}
/**
* 副SqlSessionFactory。使用副數(shù)據(jù)源
*
* @return .
* @throws Exception .
*/
@Bean
public SqlSessionFactory sqlSessionFactorySecond() throws Exception {
return new SqlSessionFactoryBean() {{
setDataSource(dataSourceSecond);
}}.getObject();
}
@Mapper
interface UserMapper {
@Select("SELECT * FROM user")
List<Map<String, Object>> selectAll();
}
@SecondaryMapper
interface SecondaryUserMapper {
@Select("SELECT * FROM user")
List<Map<String, Object>> selectAll();
}
/**
* 自定義Mapper注解，用于標(biāo)識(shí)使用的數(shù)據(jù)源
*/
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@interface SecondaryMapper {
}
}
控制臺(tái)輸出:
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.1.0.RELEASE)2018-12-07 11:49:02.596 INFO 5154 --- [ main] bj.MyBatisApp : Starting MyBatisApp on MacBook-Air-2.local with PID 5154 (/Users/yuchao/temp/java/hellomaven/target/classes started by yuchao in /Users/yuchao/temp/java/hellomaven)
2018-12-07 11:49:02.633 INFO 5154 --- [ main] bj.MyBatisApp : No active profile set, falling back to default profiles: default
2018-12-07 11:49:05.341 INFO 5154 --- [ main] com.zaxxer.hikari.HikariDataSource : HikariPool-1 - Starting...
2018-12-07 11:49:05.499 INFO 5154 --- [ main] com.zaxxer.hikari.HikariDataSource : HikariPool-1 - Start completed.
2018-12-07 11:49:05.547 INFO 5154 --- [ main] org.quartz.impl.StdSchedulerFactory : Using default implementation for ThreadExecutor
2018-12-07 11:49:05.569 INFO 5154 --- [ main] org.quartz.core.SchedulerSignalerImpl : Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
2018-12-07 11:49:05.569 INFO 5154 --- [ main] org.quartz.core.QuartzScheduler : Quartz Scheduler v.2.3.0 created.
2018-12-07 11:49:05.570 INFO 5154 --- [ main] org.quartz.simpl.RAMJobStore : RAMJobStore initialized.
2018-12-07 11:49:05.571 INFO 5154 --- [ main] org.quartz.core.QuartzScheduler : Scheduler meta-data: Quartz Scheduler (v2.3.0) 'quartzScheduler' with instanceId 'NON_CLUSTERED'
Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
NOT STARTED.
Currently in standby mode.
Number of jobs executed: 0
Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.2018-12-07 11:49:05.571 INFO 5154 --- [ main] org.quartz.impl.StdSchedulerFactory : Quartz scheduler 'quartzScheduler' initialized from an externally provided properties instance.
2018-12-07 11:49:05.571 INFO 5154 --- [ main] org.quartz.impl.StdSchedulerFactory : Quartz scheduler version: 2.3.0
2018-12-07 11:49:05.571 INFO 5154 --- [ main] org.quartz.core.QuartzScheduler : JobFactory set to: org.springframework.scheduling.quartz.SpringBeanJobFactory@769a58e5
2018-12-07 11:49:05.780 WARN 5154 --- [ main] reactor.netty.tcp.TcpResources : [http] resources will use the default LoopResources: DefaultLoopResources {prefix=reactor-http, daemon=true, selectCount=4, workerCount=4}
2018-12-07 11:49:05.780 WARN 5154 --- [ main] reactor.netty.tcp.TcpResources : [http] resources will use the default ConnectionProvider: PooledConnectionProvider {name=http, poolFactory=reactor.netty.resources.ConnectionProvider$$Lambda$284/1788545647@10667848}
2018-12-07 11:49:06.061 INFO 5154 --- [ main] o.s.s.quartz.SchedulerFactoryBean : Starting Quartz Scheduler now
2018-12-07 11:49:06.062 INFO 5154 --- [ main] org.quartz.core.QuartzScheduler : Scheduler quartzScheduler_$_NON_CLUSTERED started.
2018-12-07 11:49:06.079 INFO 5154 --- [ main] bj.MyBatisApp : Started MyBatisApp in 4.645 seconds (JVM running for 6.354)
2018-12-07 11:49:06.084 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL query [SELECT DATABASE()]
2018-12-07 11:49:06.105 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [DROP SCHEMA IF EXISTS one]
2018-12-07 11:49:06.115 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [CREATE SCHEMA one]
2018-12-07 11:49:06.117 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [USE one]
2018-12-07 11:49:06.119 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [CREATE TABLE user(id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(32) CHARSET 'utf8')]
2018-12-07 11:49:06.153 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的兒子')]
2018-12-07 11:49:06.157 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的孫子')]
2018-12-07 11:49:06.161 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的曾孫子')]
2018-12-07 11:49:06.164 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [DROP SCHEMA IF EXISTS two]
2018-12-07 11:49:06.174 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [CREATE SCHEMA two]
2018-12-07 11:49:06.176 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [USE two]
2018-12-07 11:49:06.178 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [CREATE TABLE user(id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(32) CHARSET 'utf8')]
2018-12-07 11:49:06.226 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的爹')]
2018-12-07 11:49:06.231 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的爺')]
2018-12-07 11:49:06.235 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的太爺')]
2018-12-07 11:49:06.243 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [INSERT INTO user(name) VALUES ('人民的老太爺')]
2018-12-07 11:49:06.246 DEBUG 5154 --- [ main] o.s.jdbc.core.JdbcTemplate : Executing SQL statement [USE one]
Users:
2018-12-07 11:49:06.271 DEBUG 5154 --- [ main] bj.MyBatisApp$UserMapper.selectAll : ==> Preparing: SELECT * FROM user
2018-12-07 11:49:06.297 DEBUG 5154 --- [ main] bj.MyBatisApp$UserMapper.selectAll : ==> Parameters:
2018-12-07 11:49:06.314 DEBUG 5154 --- [ main] bj.MyBatisApp$UserMapper.selectAll : <== Total: 3
{name=人民的兒子, id=1}
{name=人民的孫子, id=2}
{name=人民的曾孫子, id=3}
Secondary users:
2018-12-07 11:49:06.318 INFO 5154 --- [ main] com.zaxxer.hikari.HikariDataSource : HikariPool-2 - Starting...
2018-12-07 11:49:06.324 INFO 5154 --- [ main] com.zaxxer.hikari.HikariDataSource : HikariPool-2 - Start completed.
2018-12-07 11:49:06.325 DEBUG 5154 --- [ main] b.M.selectAll : ==> Preparing: SELECT * FROM user
2018-12-07 11:49:06.325 DEBUG 5154 --- [ main] b.M.selectAll : ==> Parameters:
2018-12-07 11:49:06.328 DEBUG 5154 --- [ main] b.M.selectAll : <== Total: 4
{name=人民的爹, id=1}
{name=人民的爺, id=2}
{name=人民的太爺, id=3}
{name=人民的老太爺, id=4}
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
- Mybatis中使用updateBatch進(jìn)行批量更新
- mybatis執(zhí)行批量更新batch update 的方法（oracle,mysql兩種）
- BootStrap+Mybatis框架下實(shí)現(xiàn)表單提交數(shù)據(jù)重復(fù)驗(yàn)證
- MyBatis-Spring配置的講解
- 深入了解MyBatis二級(jí)緩存
- Spring Boot整合Mybatis并完成CRUD操作的實(shí)現(xiàn)示例
- Mybatis Interceptor 攔截器的實(shí)現(xiàn)
- mybatis Interceptor對(duì)UpdateTime自動(dòng)處理的實(shí)現(xiàn)方法
- MybatisPlus 多租戶架構(gòu)(Multi-tenancy)實(shí)現(xiàn)詳解
- MyBatis通過(guò)BATCH批量提交的方法
相關(guān)文章
本文詳細(xì)介紹了JProfiler的下載、安裝和使用過(guò)程,首先需要在官網(wǎng)下載對(duì)應(yīng)操作系統(tǒng)的安裝包并進(jìn)行安裝,然后填寫(xiě)個(gè)人信息進(jìn)行注冊(cè)并獲取許可證密鑰,感興趣的朋友一起看看吧2024-10-10
java中timer的schedule和scheduleAtFixedRate方法區(qū)別詳解
這篇文章主要為大家詳細(xì)介紹了java中timer的schedule和scheduleAtFixedRate方法區(qū)別，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-12-12
mybatis入門(mén)_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要為大家詳細(xì)介紹了mybatis入門(mén)的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-09-09
Java實(shí)現(xiàn)簡(jiǎn)易拼圖游戲的方法詳解
這篇文章主要介紹了如何利用Java語(yǔ)言實(shí)現(xiàn)簡(jiǎn)易拼圖游戲，幫助大家更好的理解和使用Java開(kāi)發(fā)游戲，感興趣的朋友可以跟隨小編一起學(xué)習(xí)一下2022-05-05
基于tomcat8 編寫(xiě)字符編碼Filter過(guò)濾器無(wú)效問(wèn)題的解決方法
下面小編就為大家分享一篇基于tomcat8 編寫(xiě)字符編碼Filter過(guò)濾器無(wú)效問(wèn)題的解決方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-01-01
java集合類(lèi)遍歷的同時(shí)如何進(jìn)行刪除操作
這篇文章主要介紹了java集合類(lèi)遍歷的同時(shí)如何進(jìn)行刪除操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-09-09
這篇文章主要為大家介紹了Spring注解@Import原理解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-02-02
springboot實(shí)現(xiàn)學(xué)生管理系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了springboot實(shí)現(xiàn)學(xué)生管理系統(tǒng)，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-07-07
IDEA設(shè)置JVM運(yùn)行參數(shù)的方法步驟
這篇文章主要介紹了IDEA設(shè)置JVM運(yùn)行參數(shù)的方法步驟，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
這篇文章主要介紹了java 注解的基礎(chǔ)詳細(xì)介紹的相關(guān)資料,希望通過(guò)本文大家能掌握注解的使用方法，需要的朋友可以參考下2017-09-09