Spring3 整合MyBatis3 配置多資料來源 動態選擇SqlSessionFactory
阿新 • • 發佈：2019-02-11
1. Spring整合MyBatis切換SqlSessionFactory有兩種方法，第一、 繼承SqlSessionDaoSupport，重寫獲取SqlSessionFactory的方法。第二、繼承SqlSessionTemplate 重寫getSqlSessionFactory、getConfiguration和SqlSessionInterceptor這個攔截器。其中最為關鍵還是繼承SqlSessionTemplate 並重寫裡面的方法。
我們一般使用第二種方法，第二種方法有2 種配置：
單個sqlSessionFactory情況：需要在程式中（action 裡面動態指定使用那個資料庫連線池）
spring-mybatis.xml配置如下：
<!-- ========================================配置資料來源========================================= --> <!-- 配置資料來源，使用的是alibaba的Druid(德魯伊)資料來源 --> <bean name="pepos" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <property name="url" value="${pepos.url}" /> <property name="username" value="${pepos.username}" /> <property name="password" value="${pepos.password}" /> <!-- 密碼解密--> <property name="filters" value="config" /> <property name="connectionProperties" value="config.decrypt=true;config.decrypt.key=${pepos.publickey}" /> <!-- 初始化連線大小 --> <property name="initialSize" value="0" /> <!-- 連線池最大使用連線數量 --> <property name="maxActive" value="20" /> <!-- 連線池最大空閒 <property name="maxIdle" value="20" /> --> <!-- 連線池最小空閒 --> <property name="minIdle" value="0" /> <!-- 獲取連線最大等待時間 --> <property name="maxWait" value="60000" /> <!-- 開啟PSCache，並且指定每個連線上PSCache的大小 --> <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="20" /> <property name="validationQuery" value="SELECT 1" /> <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" /> </bean> <!-- 配置資料來源，使用的是alibaba的Druid(德魯伊)資料來源 --> <bean name="payment" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <property name="url" value="${payment.url}" /> <property name="username" value="${payment.username}" /> <property name="password" value="${payment.password}" /> <!-- 密碼解密 --> <property name="filters" value="config" /> <property name="connectionProperties" value="config.decrypt=true;config.decrypt.key=${payment.publickey}" /> <!-- 初始化連線大小 --> <property name="initialSize" value="0" /> <!-- 連線池最大使用連線數量 --> <property name="maxActive" value="20" /> <!-- 連線池最大空閒 <property name="maxIdle" value="20" /> --> <!-- 連線池最小空閒 --> <property name="minIdle" value="0" /> <!-- 獲取連線最大等待時間 --> <property name="maxWait" value="60000" /> <!-- 開啟PSCache，並且指定每個連線上PSCache的大小 --> <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="20" /> <property name="validationQuery" value="SELECT 1" /> <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" /> </bean> <!-- 需要基礎spring的 AbstractRoutingDataSource 來實現動態設定資料庫連線池 --> <bean id="dynamicDataSource" class="com.threeweidu.mallmanage.utils.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <entry value-ref="pepos" key="pepos"></entry> <entry value-ref="payment" key="payment"></entry>
</map> </property> <property name="defaultTargetDataSource" ref="pepos"> </property> </bean> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dynamicDataSource"></property> </bean> <!-- MyBatis配置 --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dynamicDataSource" /> <!-- 自動掃描entity目錄, 省掉Configuration.xml裡的手工配置 --> <property name="typeAliasesPackage" value="com.threeweidu.mallmanage.entity" /> <!-- 顯式指定Mapper檔案位置 --> <property name="mapperLocations" value="classpath:/com/threeweidu/mallmanage/dao/mybatis/mapper/*Mapper.xml" /> </bean> <!-- 配置掃描器 --> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <!-- 掃描me.gacl.dao這個包以及它的子包下的所有對映介面類 --> <property name="basePackage" value="com.threeweidu.mallmanage.dao.mybatis" /> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" /> </bean> <!-- 配置Spring的事務管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dynamicDataSource" /> </bean> <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" /> <!-- 攔截器方式配置事務 --> <tx:advice id="transactionAdvice" transaction-manager="transactionManager"> <tx:attributes> <tx:method name="get*" propagation="REQUIRED" read-only="true"/> <tx:method name="find*" propagation="REQUIRED" read-only="true"/> <tx:method name="load*" propagation="REQUIRED" read-only="true"/> <tx:method name="init*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="save*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="add*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="register*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="update*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="delete*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="remove*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/> <tx:method name="*" propagation="SUPPORTS" /> </tx:attributes> </tx:advice> <aop:config> <aop:pointcut id="transactionPointcut" expression="execution(* com.threeweidu.mallmanage.service..*Impl.*(..))"/> <aop:advisor pointcut-ref="transactionPointcut" advice-ref="transactionAdvice"/> </aop:config> </beans>
多個sqlsessionFactroy 模式
spring-mybatis.xml 配置檔案
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.1.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
">
<import resource="spring-mybatis-shop.xml" />
<import resource="spring-mybatis-payment.xml" />
<!--
<import resource="spring-mybatis-pepos.xml" />
<import resource="spring-mybatis-peposlog.xml" />
<import resource="spring-mybatis-peposchat.xml" />
<import resource="spring-mybatis-vaservice.xml" />
-->
</beans>spring-mybatis-payment.xml 配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.1.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
">
<!-- 資料庫連線池 -->
<bean id="dataSource_payment" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
<property name="url" value="${payment.url}" />
<property name="username" value="${payment.username}" />
<property name="password" value="${payment.password}" />
<!-- 密碼解密 -->
<property name="filters" value="config" />
<property name="connectionProperties" value="config.decrypt=true;config.decrypt.key=${payment.publickey}" />
<!-- 初始化連線大小 -->
<property name="initialSize" value="3" />
<!-- 連線池最大使用連線數量 -->
<property name="maxActive" value="200" />
<!-- 連線池最大空閒 <property name="maxIdle" value="20" /> -->
<!-- 連線池最小空閒 -->
<property name="minIdle" value="0" />
<!-- 獲取連線最大等待時間 -->
<property name="maxWait" value="60000" />
<!-- 開啟PSCache，並且指定每個連線上PSCache的大小 -->
<property name="poolPreparedStatements" value="true" />
<property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
<property name="validationQuery" value="SELECT 1" />
<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" />
</bean>
<!-- MyBatis配置 -->
<bean id="sqlSessionFactory_payment" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource_payment" />
<!-- 自動掃描entity目錄, 省掉Configuration.xml裡的手工配置 -->
<property name="typeAliasesPackage" value="com.threeweidu.supplier.entity" />
<!-- 顯式指定Mapper檔案位置 -->
<property name="mapperLocations" value="classpath:/com/threeweidu/supplier/dao/mybatis/payment/mapper/*Mapper.xml" />
</bean>
<!-- 配置掃描器 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<!-- 掃描me.gacl.dao這個包以及它的子包下的所有對映介面類 -->
<property name="basePackage" value="com.threeweidu.supplier.dao.mybatis.payment" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory_payment" />
</bean>
<!-- 配置Spring的事務管理器 -->
<bean id="transactionManager_payment" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource_payment" />
</bean>
<tx:annotation-driven transaction-manager="transactionManager_payment" proxy-target-class="true" />
<!-- 攔截器方式配置事務 -->
<tx:advice id="transactionAdvice_payment" transaction-manager="transactionManager_payment">
<tx:attributes>
<tx:method name="get*" propagation="REQUIRED" read-only="true"/>
<tx:method name="find*" propagation="REQUIRED" read-only="true"/>
<tx:method name="load*" propagation="REQUIRED" read-only="true"/>
<tx:method name="init*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="save*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="add*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="register*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="update*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="delete*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="remove*" rollback-for="java.lang.Exception" propagation="REQUIRED" read-only="false"/>
<tx:method name="*" propagation="SUPPORTS" />
</tx:attributes>
</tx:advice>
<aop:config>
<aop:advisor advice-ref="transactionAdvice_payment" pointcut="execution(* com.threeweidu.supplier.service..*Impl.*(..))" />
</aop:config>
</beans>