欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

在MyBatis中配置多數(shù)據(jù)源的方法有哪些

這篇文章給大家介紹在MyBatis中配置多數(shù)據(jù)源的方法有哪些，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

我們提供的服務(wù)有：成都網(wǎng)站建設(shè)、成都網(wǎng)站制作、微信公眾號(hào)開(kāi)發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、云夢(mèng)ssl等。為上千家企事業(yè)單位解決了網(wǎng)站和推廣的問(wèn)題。提供周到的售前咨詢和貼心的售后服務(wù)，是有科學(xué)管理、有技術(shù)的云夢(mèng)網(wǎng)站制作公司

同一個(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è)配置類
  * 自定義@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}

關(guān)于在MyBatis中配置多數(shù)據(jù)源的方法有哪些就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

當(dāng)前題目：在MyBatis中配置多數(shù)據(jù)源的方法有哪些
文章轉(zhuǎn)載：http://chinadenli.net/article38/iejdpp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站內(nèi)鏈、自適應(yīng)網(wǎng)站、靜態(tài)網(wǎng)站、網(wǎng)站設(shè)計(jì)、建站公司、網(wǎng)站改版

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

微信小程序開(kāi)發(fā)
成人免费观看视频免费| 国产精品一区二区香蕉视频| 欧美日不卡无在线一区| 国产肥妇一区二区熟女精品 | 久久福利视频视频一区二区| 亚洲最新的黄色录像在线| 欧洲亚洲精品自拍偷拍| 视频在线观看色一区二区| 果冻传媒精选麻豆白晶晶| 亚洲国产性生活高潮免费视频| 欧美有码黄片免费在线视频| 加勒比人妻精品一区二区| 国产精品免费无遮挡不卡视频| 日韩日韩欧美国产精品| 国产一区二区不卡在线播放| 一本色道久久综合狠狠躁| 九九热最新视频免费观看| 国语久精品在视频在线观看| 在线观看日韩欧美综合黄片| 亚洲一级在线免费观看| 日本加勒比在线播放一区| 国产又猛又黄又粗又爽无遮挡 | 精品亚洲香蕉久久综合网| 久久精品国产99国产免费| 免费观看在线午夜视频| 国产a天堂一区二区专区| 亚洲精品国产主播一区| 中文久久乱码一区二区| 久久国产精品亚州精品毛片 | 亚洲欧美国产中文色妇| 黄色在线免费高清观看| 男生和女生哪个更好色| 欧美乱视频一区二区三区| 又黄又色又爽又免费的视频| 久久精品国产亚洲av麻豆尤物| 在线观看那种视频你懂的| 成人免费视频免费观看| 国产精品欧美日韩中文字幕| 久久天堂夜夜一本婷婷| 国产真人无遮挡免费视频一区| 欧美做爰猛烈叫床大尺度|