前言
同一個項目有時會涉及到多個數(shù)據(jù)庫，也就是多數(shù)據(jù)源。多數(shù)據(jù)源又可以分為兩種情況：
1）兩個或多個數(shù)據(jù)庫沒有相關(guān)性，各自獨立，其實這種可以作為兩個項目來開發(fā)。比如在游戲開發(fā)中一個數(shù)據(jù)庫是平臺數(shù)據(jù)庫，其它還有平臺下的游戲?qū)?yīng)的數(shù)據(jù)庫；
2）兩個或多個數(shù)據(jù)庫是master-slave的關(guān)系，比如有mysql搭建一個 master-master，其后又帶有多個slave；或者采用mha搭建的master-slave復(fù)制；
mybatis多數(shù)據(jù)源的配置主要有兩種方式:
- 通過@mapperscan注解，對不同包下的mapper使用不同的sqlsessionfactory
- 通過@mapperscan注解加自定義注解，對使用不同注解的mapper使用不同的sqlsessionfactory
第二種配置相對靈活，示例如下:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
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 [email protected] 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 注解一次只能添加一個，所以需要單獨再加一個配置類 * 自定義@mapperscan會替換mybatis自動添加的默認(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無法注入 * * @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就不自動添加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ù)據(jù)源 */ @target(elementtype.type) @retention(retentionpolicy.runtime) @interface secondarymapper { }} |
控制臺輸出:
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: 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é)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對服務(wù)器之家的支持。
原文鏈接：https://baijifeilong.github.io/2018/12/07/mybatis-multiple-datasource/
