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

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 />
在这里,使用了通用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 >
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层关闭数据源。
---------------------

相关文章:

  • 2021-07-17
  • 2022-12-23
  • 2021-11-29
  • 2021-08-08
  • 2022-12-23
  • 2022-02-15
  • 2021-06-14
  • 2021-07-19
猜你喜欢
  • 2021-07-19
  • 2021-08-07
  • 2022-12-23
  • 2022-12-23
  • 2021-07-22
  • 2021-10-18
相关资源
相似解决方案