多数据源的配置

左手的ㄟ右手 2022-02-14 00:28 291阅读 0赞

多数据源的配置  
项目中一些模糊查询需要链接另外一个数据库 这是可以配置多个数据源进行操作。  
数据库连接文件jdbc.properties 主要是数据库的地址、驱动、账户、密码

jdbc.url = jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf8  
jdbc.driver = com.mysql.jdbc.Driver  
jdbc.username= root  
jdbc.password= 123

\#\#第二个数据链接  
jdbc.url2 = jdbc:mysql://localhost :3306/test?useUnicode=true&characterEncoding=utf8  
jdbc.driver2 = com.mysql.jdbc.Driver  
jdbc.username2 = root  
jdbc.password2 = 123

获取当前使用的数据源  
public class DynamicDataSource extends AbstractRoutingDataSource\{  
Protected Object determineCurrentLookupKey()\{  
return DBContextHolder.getDbType();  
\}  
\}  
切换数据源的工具类  
public class DBContextHolder\{  
private static final ThreadLocal contextHolder = new ThreadLocal();  
public static void setDbType(String dbType)\{  
contextHolder.set(dbType);  
\}  
public static String getDbType()\{  
return ((String)contextHolder.get());  
\}  
public static void clearDbType()\{  
contextHolder.remove();  
\}  
\}  
在spring配置文件中进行配置

<context:property-placeholder location="classpath:jdbc.properties" />
    <bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    	<property name="jdbcUrl" value="${jdbc.url}"></property>
    	<property name="driverClass" value="${jdbc.driver}"></property>
    	<property name="user" value="${jdbc.username}"></property>
    	<property name="password" value="${jdbc.password}"></property>
    </bean>
    <bean id="dataSource2" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    	<property name="jdbcUrl" value="${jdbc.url2}"></property>
    	<property name="driverClass" value="${jdbc.driver2}"></property>
    	<property name="user" value="${jdbc.username2}"></property>
    	<property name="password" value="${jdbc.password2}"></property>
    </bean>
    
    <bean class="com.ocean.utils.DynamicDataSource" id="dynamicDataSource">  
        <property name="targetDataSources">  
            <map key-type="java.lang.String">  
                <entry value-ref="dataSource1" key="dataSource1"></entry>  
                <entry value-ref="dataSource2" key="dataSource2"></entry>  
            </map>  
        </property>  
        <property name="defaultTargetDataSource" ref="dataSource1"></property>  
    </bean> 
    
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dynamicDataSource"></property>
    <property name="configLocation" value="classpath:sqlMapConfig.xml"></property>
    </bean>
    
     
     
    
    
    <bean class="tk.mybatis.spring.mapper.MapperScannerConfigurer">
    	<property name="basePackage" value="com.ocean.mapper"/>
    	<property name="properties">
    		<value>
    			enumAsSimpleType=true
    		</value>
    	</property>
    </bean>
    
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dynamicDataSource"></property>
    </bean>
    
    <tx:annotation-driven transaction-manager="transactionManager" />

需要使用通用的mapper,需要导入两个jar包 mapper-4.0.0-beta3jar和 persistence-api-1.0.2.jar. 使用通用mapper,可以完成基本的CRUD操作，需要其他操作，可以在.xml中进行配置即可  
如下UserMapper.xml文件

<?xml version="1.0" encoding="UTF-8" ?> SELECT \* from user where id = \#\{id\} 多数据源使用方式 默认使用的数据源是dataSource1，使用不需要配置。如果需要使用dataSource2则需要声明，使用完成之后需要关闭。 public User findById(Integer id)\{ User user = userMapper.selectByPrimaryKey(id); Return user; \}

public User findId2(Integer id)\{  
DBContextHolder.setDbType(“dataSource2”);  
User user = userMapper.findOne(id);  
DBContextHolder.clearDbType();  
return user;  
\}

需要打印SQL方法如下，在mybatis的配置文件sqlMapConfig.xml中加入一句话即可