ssm项目配置多个数据源(看到最后，最后是重点)

在项目中到一些问题，一些查询模块需要链接另一个数据库，这时，就可以配置两个数据源进行操作。

1.创建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://192.168.1.57:3306/test?useUnicode=true&characterEncoding=utf8
jdbc.driver2 = com.mysql.jdbc.Driver
jdbc.username2 = root
jdbc.password2 = 123

2.获取当前使用的数据源

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
/**
 * <p>desc:配置多个数据源 </p>
 * <p>类名：DynamicDataSource </p>
 * <p>创建时间：2018-7-10 上午9:38:42 </p>
 * <p>@author：mmy</p>
 */
public class DynamicDataSource extends AbstractRoutingDataSource {

	protected Object determineCurrentLookupKey() {
		return DBContextHolder.getDbType();
	}

}

3.切换数据源的工具类：

/**
 * <p>desc: 数据源的切换</p>
 * <p>类名：DBContextHolder </p>
 * <p>创建时间：2018-7-10 上午9:39:24 </p>
 * <p>@author：mmy</p>
 */
public class DBContextHolder {
	
 	private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
    public static void setDbType(String dbType) {
        contextHolder.set(dbType);
    }
    
    public static String getDbType() {
        return ((String) contextHolder.get());
    }
    
    public static void clearDbType() {
        contextHolder.remove();
    }
    
}

4.在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> 


	<!-- 创建sqlSessionFactory -->
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
	<property name="dataSource" ref="dynamicDataSource"></property>
	<property name="configLocation" value="classpath:sqlMapConfig.xml"></property>
	</bean>
	<!-- 配置mybatis接口代理开发
		* 接口类名和映射文件必须同名
		*　接口类和映射文件必须在同一个目录　下
		* 映射文件namespace名字必须是接口的全类路径名
		*　接口的方法名必须和映射Statement的id一致
	 -->
	<!--  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	 <property name="basePackage" value="com.ocean.mapper"></property>
	 <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
	 </bean> -->
	 
	 <!-- 整合通用Mapper所需要做的配置修改： -->
	<!-- 原始全类名：org.mybatis.spring.mapper.MapperScannerConfigurer -->
	<!-- 通用Mapper使用：tk.mybatis.spring.mapper.MapperScannerConfigurer -->
	<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，可以帮助我们完成基本的CRUD操作，若需其他的操作，可以再.xml中进行配置即可

例子如下:

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.ocean.mapper.UserMapper" >
  <resultMap id="BaseResultMap" type="com.ocean.po.User" >
    <id column="id" property="id" jdbcType="INTEGER" />
    <result column="username" property="username" jdbcType="VARCHAR" />
    <result column="password" property="password" jdbcType="VARCHAR" />
    <result column="nickname" property="nickname" jdbcType="VARCHAR" />
    <result column="create_time" property="createTime" jdbcType="TIMESTAMP" />
    <result column="update_time" property="updateTime" jdbcType="TIMESTAMP" />
    <result column="qy_flag" property="qyFlag" jdbcType="VARCHAR" />
  </resultMap>
  
  <select id="findOne" parameterType="java.lang.Integer" resultMap="BaseResultMap">
  	SELECT * from user where id = #{id}
  </select>
  
</mapper>

4.测试使用

注：默认使用的数据源是dataSource1，使用不需要配置。如果需要使用dataSource2，则需要声明，使用完成之后需要关闭。

       public User findById(Integer id) {
	    User user = userMapper.selectByPrimaryKey(id);
	    return user;
	}
        /**
	 * 测试第二个数据源用法
	 */
	public User findId2(Integer id) {
	    //User user = userMapper.selectByPrimaryKey(id);
	    //调用数据库2
            DBContextHolder.setDbType("dataSource2");
	    User user = userMapper.findOne(id);
	    DBContextHolder.clearDbType();   //关闭
	    return user;
	}

 

结果如下

 

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

<settings>
        <!-- 打印查询语句 -->
        <setting name="logImpl" value="STDOUT_LOGGING" />
</settings>

重点：后续又发现了一个问题，发现：事务没有配置成功，问题是：在application.xml和Springmvc.xml中配置的扫描注解问题。

总结下： Spring在使用ContextLoadListener加载applicationContext.xml或其他名称的xml文件时，能进行数据源和相关事务注解的检查，启动事务特性。若在Springmvc.xml文件中加载是，仅作为普通bean定义加载。所以一个良好的习惯就是，分层配置相关的bean。applicationContext.xml中配置数据库相关的bean（dao、service等）, 在spingmvc中配置mvc相关的bean（controller等）。

加上事务之后，发现，无法切换数据源，这是一个头疼的问题。各种百度，最终找到了问题所在。

问题：事务开启一般是在service中开启，事务开启后会导致数据源切换失败，数据源切换需要在事务开启前执行。

解决方法：在controller层调用service之前，进行切换数据源，调用完成之后，在controller层关闭数据源。

 

本文地址：https://blog.csdn.net/admin_mvip/article/details/80985535