Spring3 整合MyBatis3 配置多数据源动态选择SqlSessionFactory

青旅半醒 2022-07-12 02:52 206阅读 0赞

1. Spring整合MyBatis切换SqlSessionFactory有两种方法，第一、 继承SqlSessionDaoSupport，重写获取SqlSessionFactory的方法。第二、继承SqlSessionTemplate 重写getSqlSessionFactory、getConfiguration和SqlSessionInterceptor这个拦截器。其中最为关键还是继承SqlSessionTemplate 并重写里面的方法。

我们一般使用第二种方法，第二种方法有2 种配置：

单个sqlSessionFactory情况：需要在程序中（action 里面动态指定使用那个数据库连接池）

spring-mybatis.xml配置如下：

<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="minIdle" value="0" />
    		
    		<property name="maxWait" value="60000" />
    
    		
    		<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" />
    		
    		<property name="removeAbandoned" value="true" />
    		
    		<property name="removeAbandonedTimeout" value="1800" />
    		
    		<property name="logAbandoned" value="true" />
    	</bean>
    	
    	
    	<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="minIdle" value="0" />
    		
    		<property name="maxWait" value="60000" />
    
    		
    		<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" />
    		
    		<property name="removeAbandoned" value="true" />
    		
    		<property name="removeAbandonedTimeout" value="1800" />
    		
    		<property name="logAbandoned" value="true" />
    	</bean>
    	
            	
       	<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>
    
    	
    	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    		<property name="dataSource" ref="dynamicDataSource" />
    		
    		<property name="typeAliasesPackage" value="com.threeweidu.mallmanage.entity" />
    		
    		<property name="mapperLocations" value="classpath:/com/threeweidu/mallmanage/dao/mybatis/mapper/*Mapper.xml" />
    	</bean>
    
    	
    	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    		
    		<property name="basePackage" value="com.threeweidu.mallmanage.dao.mybatis" />
    		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
    	</bean>
    
    	
    	<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 配置文件

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="minIdle" value="0" />
    		
    		<property name="maxWait" value="60000" />
    
    		
    		<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" />
    		
    		<property name="removeAbandoned" value="true" />
    		
    		<property name="removeAbandonedTimeout" value="1800" />
    		
    		<property name="logAbandoned" value="true" />
    	</bean>
    	
    	
    	<bean id="sqlSessionFactory_payment" class="org.mybatis.spring.SqlSessionFactoryBean">
    		<property name="dataSource" ref="dataSource_payment" />
    		
    		<property name="typeAliasesPackage" value="com.threeweidu.supplier.entity" />
    		
    		<property name="mapperLocations" value="classpath:/com/threeweidu/supplier/dao/mybatis/payment/mapper/*Mapper.xml" />
    	</bean>
    
    	
    	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    		
    		<property name="basePackage" value="com.threeweidu.supplier.dao.mybatis.payment" />
    		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory_payment" />
    	</bean>
    
    	
    	<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>

参考：[http://blog.csdn.net/xingxiupaioxue/article/details/51094091][http_blog.csdn.net_xingxiupaioxue_article_details_51094091]

[http_blog.csdn.net_xingxiupaioxue_article_details_51094091]: http://blog.csdn.net/xingxiupaioxue/article/details/51094091