ssm项目配置多个数据源

Posted 2022-04-11 ly570

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

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层关闭数据源。
---------------------