mybatis如何配置使用多個數據源（environment）

mybatis如何配置使用多個數據源？
一、資料庫連線properties配置檔案，兩個資料來源的地址： Java程式碼

hd.jdbc.driverClassName=com.mysql.jdbc.Driver
hd.jdbc.url=jdbc:mysql://127.0.0.1::3306/hd?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true
hd.jdbc.username=root
hd.jdbc.password=root
ho.jdbc.driverClassName=com.mysql.jdbc.Driver
ho.jdbc.url=jdbc:mysql://127.0.0.1:3306/ho?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true
ho.jdbc.username=root
ho.jdbc.password=root

二、mybatis配置檔案，配置兩個environment：
Xml程式碼

<?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>
<properties resource="mybatis/jdbc.properties"/>
<environments default="HO">
<environment id="HD">
<transactionManager type="JDBC" />
<dataSource type="POOLED"

>
<property name="driver" value="${hd.jdbc.driverClassName}" />
<property name="url" value="${hd.jdbc.url}" />
<property name="username" value="${hd.jdbc.username}" />
<property name="password" value="${hd.jdbc.password}" />
</dataSource>
</environment>
<environment id="HO">
<transactionManager type="JDBC" />
<dataSource type="POOLED">
<property name="driver" value="${ho.jdbc.driverClassName}" />
<property name="url" value="${ho.jdbc.url}" />
<property name="username" value="${ho.jdbc.username}" />
<property name="password" value="${ho.jdbc.password}" />
</dataSource>
</environment>
</environments>
</configuration>

三、獲取SqlSessionFactory，獲取Mapper代理，便於在執行完Mapper方法後關閉SqlSession。
SqlSessionFactory的獲取：
Java程式碼

/**
* 根據mybatis.xml中配置的不同的environment建立對應的SqlSessionFactory
* @author boyce
* @version 2014-3-27
*/
public final class DataSourceSqlSessionFactory {
private static final String CONFIGURATION_PATH = "mybatis/mybatis.xml";
private static final Map<DataSourceEnvironment, SqlSessionFactory> SQLSESSIONFACTORYS
= new HashMap<DataSourceEnvironment, SqlSessionFactory>();
/**
* 根據指定的DataSourceEnvironment獲取對應的SqlSessionFactory
* @param environment 資料來源environment
* @return SqlSessionFactory
*/
public static SqlSessionFactory getSqlSessionFactory(DataSourceEnvironment environment) {
SqlSessionFactory sqlSessionFactory = SQLSESSIONFACTORYS.get(environment);
if (ObjectUtils.isNotNull(sqlSessionFactory))
return sqlSessionFactory;
else {
InputStream inputStream = null;
try {
inputStream = Resources.getResourceAsStream(CONFIGURATION_PATH);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream, environment.name());
logger.info("Get {} SqlSessionFactory successfully.", environment.name());
} catch (IOException e) {
logger.warn("Get {} SqlSessionFactory error.", environment.name());
logger.error(e.getMessage(), e);
}
finally {
IOUtils.closeQuietly(inputStream);
}
SQLSESSIONFACTORYS.put(environment, sqlSessionFactory);
return sqlSessionFactory;
}
}
/**
* 配置到Configuration.xml檔案中的資料來源的environment的列舉描述
* @author boyce
* @version 2014-3-27
*/
public static enum DataSourceEnvironment {
HD,
HO;
}
}

定義一個統一的Mapper標識介面，每一個具體的Mapper介面繼承該介面：
Java程式碼

/**
* Mapper Interface
* @author boyce
* @version 2014-3-28
*/
public interface Mapper {
}

定義一個Mapper代理工廠：
Java程式碼

/**
* Mapper Factory
* @author boyce
* @version 2014-3-28
*/
public final class MapperFactory {
private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(MapperFactory.class);
/**
* Create a mapper of environment by Mapper class
* @param clazz Mapper class
* @param environment A datasource environment
* @return a Mapper instance
*/
@SuppressWarnings("unchecked")
public static <T> T createMapper(Class<? extends Mapper> clazz, DataSourceEnvironment environment) {
SqlSessionFactory sqlSessionFactory = getSqlSessionFactory(environment);
SqlSession sqlSession = sqlSessionFactory.openSession();
Mapper mapper = sqlSession.getMapper(clazz);
return (T)MapperProxy.bind(mapper, sqlSession);
}
/**
* Mapper Proxy
* executing mapper method and close sqlsession
* @author boyce
* @version 2014-4-9
*/
private static class MapperProxy implements InvocationHandler {
private Mapper mapper;
private SqlSession sqlSession;
private MapperProxy(Mapper mapper, SqlSession sqlSession) {
this.mapper = mapper;
this.sqlSession = sqlSession;
}
@SuppressWarnings("unchecked")
private static Mapper bind(Mapper mapper, SqlSession sqlSession) {
return (Mapper) Proxy.newProxyInstance(mapper.getClass().getClassLoader(),
mapper.getClass().getInterfaces(), new MapperProxy(mapper, sqlSession));
}
/**
* execute mapper method and finally close sqlSession
*/
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
Object object = null;
try {
object = method.invoke(mapper, args);
} catch(Exception e) {
e.printStackTrace();
logger.error(e.getMessage(), e);
} finally {
sqlSession.close();
}
return object;
}
}
//Get a SqlSessionFactory of environment
private static SqlSessionFactory getSqlSessionFactory(DataSourceEnvironment environment) {
return DataSourceSqlSessionFactory.getSqlSessionFactory(environment);
}

大功告成，客戶端使用：
Java程式碼

UserMapper mapper = MapperFactory.createMapper(UserMapper.class, DataSourceEnvironment.HD);
User user = mapper.getUserById(162L);
System.out.println(user);

OK，到此基本上所有的工作就完成了，以上的方式就可以支援多個數據源了。
但是程式碼還不夠優雅，以上程式碼我們發現DataSourceEnvironment這個列舉變數在客戶端，MapperFactory以及DataSourceEnvironment
中傳來傳去，我們應該儘量減少一個類對外界類的耦合，也就是不符合Java程式設計原則中的迪米特法則。
好了，那我們來改良一下。
將MapperFactory設計成列舉策略模式：
Java程式碼

/**
* Mapper Creator
* @author boyce
* @version 2014-3-28
*/
public enum MapperFactory {
HD {
相關推薦

mybatis如何配置使用多個數據源（environment）？

mybatis如何配置使用多個數據源？一、資料庫連線properties配置檔案，兩個資料來源的地址： hd.jdbc.driverClassName=com.mysql.jdbc.Driver hd.jdbc.url=jdbc:mysql:/

mybatis如何配置使用多個數據源（environment）

mybatis如何配置使用多個數據源？一、資料庫連線properties配置檔案，兩個資料來源的地址： Java程式碼   hd.jdbc.driverClassName=com.mysql.jdbc.Driver   hd.jdbc.url=jdbc:mysql

Spring Profile和Mybatis進行多個數據源（H2和Mysql）的切換

sql pda 開箱 https tails val 收集 sqlserver jpetstore 總結：最近在做WebMagic的後臺，遇到一個問題：後臺用到了數據庫，本來理想情況下是用Mysql，但是為了做到開箱即用，也整合了一個嵌入式數據庫H2。這裏面就有個問題了，

Mybatis配置多個數據源

1.編寫2個以上資料來源 <bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">        <property n

使用Spring Profile和Mybatis進行多個數據源（H2和Mysql）的切換

轉載自：http://my.oschina.net/flashsword/blog/209872 最近在做WebMagic的後臺，遇到一個問題：後臺用到了資料庫，本來理想情況下是用Mysql，但是為了做到開箱即用，也整合了一個嵌入式資料庫H2。這裡面就有個問題了，如何用

mybatis+druid+springboot 註解方式配置多個數據源

pat nts println service ssp bsp manager 打開 iba 1\數據庫配置 #test數據源 spring.datasource.test.url=jdbc:mysql://*:3306/db?useUnicode=true&ch

hibernate配置多個數據源及事物（以兩個資料來源為例）

在ssh專案中，需要連線兩個不同ip下的資料庫，所以必須要給hibernate配置兩個或多個數據源因為我只有一臺電腦，所以我配置的是sqlserver+mysql兩個資料來源首先hibernate配置是直接從myeclipse中新增的   右鍵----myeclipse

EJB 配置多個數據源

name XML cti kong 添加 local ima 不能 transacti 1.修改jboss-6.simple\server\default\deploy\transaction-jboss-beans.xml 配置文件 <bean name="Co

多個數據源（multiple data sources）

art multipl spring detail 多個教程 boot net sdn 參考資料： SpringBoot非官方教程 | 第五篇：springboot整合 beatlsql多個數據源（multiple data sources）

Spring cloud整合Reids 配置多個數據源

首先是連線池的選擇一般有兩種 lettuce ,jedis Jedis 執行緒不安全，方法同步 Lettuce 基於Netty.nio, 方法非同步執行緒安全 letture通過引入spring-boot-starter-redis就可以使用 <

Spring配置多個數據源，並實現資料來源的動態切換

1.首先在config.properties檔案中配置兩個資料庫連線的基本資料。這個省略了 2.在spring配置檔案中配置這兩個資料來源：資料來源1  <bean id="prope

tomcat配置多個數據源

應用場景：                公司tomcat伺服器中執行著多個工程，工程連結的mysql資料庫不同，所以每個工程的Spring總配置檔案中都配置了資料來源。需求：   將資料來源統一拿到tomcat中配置。              本來指派給本人，由於開發

Pandas包對多個數據表（DataFrame）的常用整合功能。

目錄 merge join concat append combin_first merge 合併 pandas.merge可根據一個或多個鍵將不同DataFrame中的行合併起來

Message訊息佇列中多個數據傳遞（Bundle）

MyHandler handler = new MyHandler(handlerThread.getLooper()); Message msg = handler.obtainMessage(); /** * 將Mes

Tidyverse| XX_join ：多個數據表（檔案）之間的各種連線

本文首發於公眾號：“生信補給站” Tidyverse| XX_join ：多個數據表（檔案）之間的各種連線前面分享了單個檔案中的select列，filter行，列拆分等，實際中經常是多個數據表，綜合使用才能回答你所感興趣的問題。本次簡單的介紹多個表（檔案）連線的方法。一載入資料，R包 librar

單個工程中Spring+Mybatis連線多個數據庫的配置（個人分享版本）

上一篇部落格說到同一個問題，經過和朋友的研究已經參考網上的資料，現在給出一份更簡潔的配置。情景：現在單個工程中需要連線兩個庫，這兩個庫在同一個mysql中，兩個庫都需要進行讀寫。解決：第一步：將spring和mybatis整合，這個過程就不具體演示了，在這個過程中建立

AngularJS $q 和 $q.all 單個數據源和多個數據源合並（promise的說明）

獲取 lar debug let index 被拒可用第一個 brush 這篇文章講的不錯， angular $q 和 promise!! -------------------------------------------------------------- 通

Spring Boot實現多個數據源教程收集（待實踐）

get shu 多個 href eos net -c smi tar 先收集，後續實踐。 http://blog.csdn.net/catoop/article/details/50575038 http://blog.csdn.net/neosmith/article

mybatis如何配置使用多個數據源（environment）

相關推薦