Spring + Mybatis配置多数据库

清疚 2022-07-25 15:41 197阅读 0赞

目前有两种思路：

1.动态切换数据源，需要自定义一个数据源类继承自AbstractRoutingDataSource抽象类，这种方式有弊端，如果是并发系统中，当你把数据源改了，系统中所有的操作数据源都改了，即使你立马再改回去，还是有风险；

2.建立两套数据源，在spring加载Mapper时关联不同的数据源。

以下仅介绍第二种方式：

（1）新建两套数据源：

数据源一：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
     xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans 
    	                    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd     
    	                    http://www.springframework.org/schema/aop     
    	                    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd     
    	                    http://www.springframework.org/schema/tx      
    	                    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    	                    http://www.springframework.org/schema/context
        					http://www.springframework.org/schema/context/spring-context-3.0.xsd">
      
        
    	
        <bean id="dataSource" class="com.jolbox.bonecp.BoneCPDataSource"  
             destroy-method="close">  
               
             <property name="driverClass" value="${jdbc_driverClassName}" />  
               
             <property name="jdbcUrl" value="${jdbc_url}" /> 
               
             <property name="username" value="${jdbc_username}" />  
               
             <property name="password" value="${jdbc_password}" />  
           
           
             
            
    		
    		<property name="partitionCount" value="${db.partitionCount}" />
    		
    		
    		<property name="maxConnectionsPerPartition" value="${db.maxConnectionsPerPartition}" />
    		
    		
    		<property name="minConnectionsPerPartition" value="${db.minConnectionsPerPartition}" />
    		
    		
    		<property name="acquireIncrement" value="${db.acquireIncrement}" />
    		
    		
    		<property name="poolAvailabilityThreshold" value="${db.poolAvailabilityThreshold}" />
    		
    		
    		<property name="connectionTimeoutInMs" value="${db.connectionTimeoutInMs}" />
    		
    		
    		
    		
    		<property name="maxConnectionAgeInSeconds" value="${db.maxConnectionAgeInSeconds}" />
    		
    		
    		<property name="connectionTestStatement" value="${db.connectionTestStatement}" />
    		
    		
    		
    		<property name="idleMaxAgeInMinutes" value="${db.idleMaxAgeInMinutes}" />
    		
    		
    		
    		
    		<property name="idleConnectionTestPeriodInMinutes" value="${db.idleConnectionTestPeriodInMinutes}" />
    		
    		
    		
    		<property name="acquireRetryAttempts" value="${db.acquireRetryAttempts}" />
    		
    		
    		<property name="acquireRetryDelayInMs" value="${db.acquireRetryDelayInMs}" />
    		
    		
    		<property name="lazyInit" value="${db.lazyInit}" />
    		
    		
    		<property name="disableJMX" value="${db.disableJMX}" />
    		
    		
    		<property name="poolName" value="${db.poolName}" />
    		
    		
    		
    		<property name="statementsCacheSize" value="${db.statementsCacheSize}" />
    		
    		
    		<property name="logStatementsEnabled" value="${db.logStatementsEnabled}" />
    		
    		
    		<property name="queryExecuteTimeLimitInMs" value="${db.queryExecuteTimeLimit}" />
         </bean>
    	
    	
    	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    		<property name="dataSource" ref="dataSource" />
    	</bean>      
    		
    	
    	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    		<property name="dataSource" ref="dataSource" />
    		
    		
    		<property name="mapperLocations">
    			<list>                
    				<value>classpath:mapper/*Mapper.xml</value>
    			</list>
    		</property>
    	</bean>        
    
    	<tx:annotation-driven  transaction-manager="transactionManager" />  
    
    </beans>

数据源二：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
     xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans 
    	                    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd     
    	                    http://www.springframework.org/schema/aop     
    	                    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd     
    	                    http://www.springframework.org/schema/tx      
    	                    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    	                    http://www.springframework.org/schema/context
        					http://www.springframework.org/schema/context/spring-context-3.0.xsd">
      
        
    	
        <bean id="dataSource2" class="com.jolbox.bonecp.BoneCPDataSource"  
             destroy-method="close">  
               
             <property name="driverClass" value="${jdbc_driverClassName}" />  
               
             <property name="jdbcUrl" value="${jdbc_url2}" /> 
               
             <property name="username" value="${jdbc_username2}" />  
               
             <property name="password" value="${jdbc_password2}" />  
           
           
             
            
    		
    		<property name="partitionCount" value="${db.partitionCount}" />
    		
    		
    		<property name="maxConnectionsPerPartition" value="${db.maxConnectionsPerPartition}" />
    		
    		
    		<property name="minConnectionsPerPartition" value="${db.minConnectionsPerPartition}" />
    		
    		
    		<property name="acquireIncrement" value="${db.acquireIncrement}" />
    		
    		
    		<property name="poolAvailabilityThreshold" value="${db.poolAvailabilityThreshold}" />
    		
    		
    		<property name="connectionTimeoutInMs" value="${db.connectionTimeoutInMs}" />
    		
    		
    		
    		
    		<property name="maxConnectionAgeInSeconds" value="${db.maxConnectionAgeInSeconds}" />
    		
    		
    		<property name="connectionTestStatement" value="${db.connectionTestStatement}" />
    		
    		
    		
    		<property name="idleMaxAgeInMinutes" value="${db.idleMaxAgeInMinutes}" />
    		
    		
    		
    		
    		<property name="idleConnectionTestPeriodInMinutes" value="${db.idleConnectionTestPeriodInMinutes}" />
    		
    		
    		
    		<property name="acquireRetryAttempts" value="${db.acquireRetryAttempts}" />
    		
    		
    		<property name="acquireRetryDelayInMs" value="${db.acquireRetryDelayInMs}" />
    		
    		
    		<property name="lazyInit" value="${db.lazyInit}" />
    		
    		
    		<property name="disableJMX" value="${db.disableJMX}" />
    		
    		
    		<property name="poolName" value="${db.poolName}" />
    		
    		
    		
    		<property name="statementsCacheSize" value="${db.statementsCacheSize}" />
    		
    		
    		<property name="logStatementsEnabled" value="${db.logStatementsEnabled}" />
    		
    		
    		<property name="queryExecuteTimeLimitInMs" value="${db.queryExecuteTimeLimit}" />
         </bean>
    			
    	
    	<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
    		<property name="dataSource" ref="dataSource2" />     
    		
    		
    		<property name="mapperLocations">
    			<list>                
    				<value>classpath:mapper2/*Mapper.xml</value>
    			</list>
    		</property>
    	</bean>        
    
    </beans>

注意：（1）sqlSessionFactory2关联的Mapper.xml的映射地址；（2）数据源2中去除了事务管理的配置，否则使用事务时会找到两个事务管理器，有兴趣的可以研究下怎么控制事务。

（2）在spring中扫描Mapper.java文件：

注意：关联不同的包和sqlSessionFactory，这里使用sqlSessionFactoryBeanName，而不是sqlSessionFactory；

如果只是关联一个Mapper，则可以使用如下方式

注意：mapper和mapper2中不能有相同的类名，因为扫描的时候会根据类名来新建bean托管给spring。

其它的Dao层等不用修改，在需要调用新数据库的地方，调用对应的mapper就可以了。

欢迎关注我的公众号“彤哥读源码”，查看更多“源码&架构&算法”系列文章, 与彤哥一起畅游源码的海洋。

![qrcode_ss.jpg][]

[qrcode_ss.jpg]: /images/20220724/039923e6a3f9424da6789eb37ce972df.png