hibernate動態切換數據源

原由：

公司的當前產品，主要是兩個項目集成的，一個是java項目，還有一個是php項目，兩個項目用的是不一樣的數據源，但都是mysql數據庫，由於java這邊的開發工做已經基本完成了，而php那邊任務還不少，人手也比較緊，產品上線日期緊促，因此領導但願java這邊可以幫助php那邊寫接口，因此須要切換數據源

思路：

動態切換數據源確切的來講是在同一類型數據庫的狀況下的。意思就是說 , 在系統中的使用的數據庫分佈在多臺數據庫服務器或者在同臺服務器上的多個數據庫. 在運行時期間根據某種標識符來動態的選擇當前操做的數據庫.

     1.數據源是相同類型的數據庫: 一個SessionFactory+動態數據源+一個事務管理器

     2.數據源是不一樣類型的數據庫: 根據類型 配置多套SessionFactory

困難解決：

一、配置dataSource的時候將id寫成那麼，而動態數據源的設置引用的是id

二、動態數據源的切換不能用枚舉來標識，得用常量

三、在mysql數據庫中不一樣種類的table也照樣起做用

四、spring的事務處理可能會影響動態數據源的切換(還沒有發現該問題)

測試環境：

一、hibernate

二、spring

三、mysql

最終實現：

一、首先得配置多個數據源

<!-- 配置數據源 使用的是Druid數據源 --> <bean id="dataSource1" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <property name="url" value="${jdbc.url1}" /> <property name="username" value="${jdbc.username1}" /> <property name="password" value="${jdbc.password1}" /> <!-- 初始化鏈接大小 --> <property name="initialSize" value="0" /> <!-- 鏈接池最大使用鏈接數量 --> <property name="maxActive" value="20" /> <!-- 鏈接池最小空閒 --> <property name="minIdle" value="0" /> <!-- 獲取鏈接最大等待時間 --> <property name="maxWait" value="60000" /> <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="33" /> <!-- 用來檢測有效sql --> <property name="validationQuery" value="${validationQuery}" /> <property name="testOnBorrow" value="false" /> <property name="testOnReturn" value="false" /> <property name="testWhileIdle" value="true" /> <!-- 配置間隔多久才進行一次檢測，檢測須要關閉的空閒鏈接，單位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="60000" /> <!-- 配置一個鏈接在池中最小生存的時間，單位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="25200000" /> <!-- 打開removeAbandoned功能 --> <property name="removeAbandoned" value="true" /> <!-- 1800秒，也就是30分鐘 --> <property name="removeAbandonedTimeout" value="1800" /> <!-- 關閉abanded鏈接時輸出錯誤日誌 --> <property name="logAbandoned" value="true" /> <!-- 監控數據庫 --> <property name="filters" value="mergeStat" /> </bean> <!-- 配置數據源 使用的是Druid數據源 --> <bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <property name="url" value="${jdbc.url2}" /> <property name="username" value="${jdbc.username2}" /> <property name="password" value="${jdbc.password2}" /> <!-- 初始化鏈接大小 --> <property name="initialSize" value="0" /> <!-- 鏈接池最大使用鏈接數量 --> <property name="maxActive" value="20" /> <!-- 鏈接池最小空閒 --> <property name="minIdle" value="0" /> <!-- 獲取鏈接最大等待時間 --> <property name="maxWait" value="60000" /> <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="33" /> <!-- 用來檢測有效sql --> <property name="validationQuery" value="${validationQuery}" /> <property name="testOnBorrow" value="false" /> <property name="testOnReturn" value="false" /> <property name="testWhileIdle" value="true" /> <!-- 配置間隔多久才進行一次檢測，檢測須要關閉的空閒鏈接，單位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="60000" /> <!-- 配置一個鏈接在池中最小生存的時間，單位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="25200000" /> <!-- 打開removeAbandoned功能 --> <property name="removeAbandoned" value="true" /> <!-- 1800秒，也就是30分鐘 --> <property name="removeAbandonedTimeout" value="1800" /> <!-- 關閉abanded鏈接時輸出錯誤日誌 --> <property name="logAbandoned" value="true" /> <!-- 監控數據庫 --> <property name="filters" value="mergeStat" /> </bean>

而後配置多數據源映射關係

<!-- 編寫spring 配置文件的配置多數源映射關係 --> <bean id="dataSource" class="com.asen.util.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <entry key="CCVZB" value-ref="dataSource1"></entry> <entry key="CCSC" value-ref="dataSource2"></entry> </map> </property> <property name="defaultTargetDataSource" ref="dataSource1"></property> </bean>

而後是hibernate的SessionFactory

<!-- 配置hibernate的SessionFactory --> <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> <!-- 注入數據源 相關信息看源碼 --> <property name="dataSource" ref="dataSource" /> <!-- hibernate配置信息 --> <property name="hibernateProperties"> <props> <prop key="hibernate.dialect">${hibernate.dialect}</prop> <prop key="hibernate.show_sql">${hibernate.show_sql}</prop> <prop key="hibernate.format_sql">${hibernate.format_sql}</prop> <prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop> </props> </property> <!-- 掃描hibernate註解配置的entity --> <property name="packagesToScan" value="com.asen.app.*" /> </bean>

這樣配置文件就寫好了，可是還須要三個類

package com.asen.util; import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; public class DynamicDataSource extends AbstractRoutingDataSource { @Override protected Object determineCurrentLookupKey() { return DynamicDataSourceHolder.getDataSourceType(); } }

package com.asen.util; public class DynamicDataSourceGlobal { public static final String CCVZB="CCVZB"; public static final String CCSC="CCSC"; }

package com.asen.util; public class DynamicDataSourceHolder { // 線程本地環境 private static final ThreadLocal contextHolder = new ThreadLocal(); // 設置數據源類型 public static void setDataSourceType(String dataSourceType) { contextHolder.set(dataSourceType); } // 獲取數據源類型 public static String getDataSourceType() { return (String) contextHolder.get(); } // 清除數據源類型 public static void clearDataSourceType() { contextHolder.remove(); } }

具體切換

package com.asen.app.dao.impl; import java.util.List; import javax.annotation.Resource; import org.hibernate.Criteria; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import org.springframework.stereotype.Repository; import com.asen.app.dao.IHomeFunctionDao; import com.asen.util.DynamicDataSourceGlobal; import com.asen.util.DynamicDataSourceHolder; @Repository("homeFunctionDao") public class HomeFunctionDaoImpl extends HibernateDaoSupport implements IHomeFunctionDao { @Resource public void setSessionFacotry(SessionFactory sessionFacotry) { super.setSessionFactory(sessionFacotry); } @Override public List getHomeFunctionList() throws Exception { DynamicDataSourceHolder.setDataSourceType(DynamicDataSourceGlobal.CCVZB); SessionFactory sessionFactory = getHibernateTemplate().getSessionFactory(); Session session = sessionFactory.openSession(); Query query = session.createQuery("from HomeFunction"); return query.list(); } }