mybatis 学习之多数据源整合

继续上篇文章如何使用mybatis3+spring3并且配置多数据源呢

先上代码在讲解吧
替换上一篇中spring中datasource的配置

Java代码

<bean id="ds1" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url"
value="jdbc:mysql://localhost:3306/payoffdatabase?useUnicode=true&characterEncoding=UTF-8" />
<property name="username" value="root" />
<property name="password" value="root" />
<property name="defaultAutoCommit" value="true"></property>
</bean>
<bean id="ds2" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url"
value="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8" />
<property name="username" value="root" />
<property name="password" value="root" />
<property name="defaultAutoCommit" value="true"></property>
</bean>
<bean id="dataSource" class="a.b.router.DynamicDataSource">
<property name="targetDataSources">
<map key-type="java.lang.String">
<entry value-ref="ds1" key="ds1"></entry>
<entry value-ref="ds2" key="ds2"></entry>
</map>
</property>
<property name="defaultTargetDataSource" ref="ds1"></property>
</bean>

新的类DynamicDataSource

Java代码

package a.b.router;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class DynamicDataSource extends AbstractRoutingDataSource {
@Override
protected Object determineCurrentLookupKey() {
return DataSourceContextHolder.getDbType();
}
}

新的类DataSourceContextHolder

Java代码

package a.b.router;
public class DataSourceContextHolder {
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();
}
}

原来的单元测试新添加一行信息，修改为

Java代码

@Test
public void addTest() throws Exception {
UserLogin userLogin = new UserLogin();
userLogin.setPassword("102");
userLogin.setUsername("102");
DataSourceContextHolder.setDbType("ds2");
service.add(userLogin);
}

最主要的变化是DynamicDataSource 类，这个类继承了AbstractRoutingDataSource，我们再继续考察，发现这个类实现了datasource这个接口。

再仔细研究，发现我配置了多个数据源给DynamicDataSource，默认的数据源是ds1。
我们研究下AbstractRoutingDataSource类的代码，主要是两个实现datasource的方法

Java代码

public Connection getConnection() throws SQLException {
return determineTargetDataSource().getConnection();
}
public Connection getConnection(String username, String password) throws SQLException {
return determineTargetDataSource().getConnection(username, password);
}

根据这段代码发现主要玄机都在determineTargetDataSource()方法上。

Java代码

protected DataSource determineTargetDataSource() {
Assert.notNull(this.resolvedDataSources, "DataSource router not initialized");
Object lookupKey = determineCurrentLookupKey();
DataSource dataSource = this.resolvedDataSources.get(lookupKey);
if (dataSource == null && (this.lenientFallback || lookupKey == null)) {
dataSource = this.resolvedDefaultDataSource;
}
if (dataSource == null) {
throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]");
}
return dataSource;
}

根据这段代码发现，首先在使用数据源之前，首先判断使用数据源的key，也就是我们配置给

Java代码

private Map<Object, Object> targetDataSources;

这个map中的key值，找到key值之后再找到对应的datasource然后并使用这个数据源。

从上面我们发现，实际上DynamicDataSource只是在内部封装了数据源，然后调用它，只不过在内部他加了一些控制而已。（此处不知道是否可以理解为代理模式）

再深一步想想，此处使用的orm层是mybatis，如果换成hibernate呢，或者jdbctemplate呢。
实际上这个方法都适用。

mybatis 学习之多数据源整合相关推荐

Spring Boot 入门系列（二十三）整合Mybatis，实现多数据源配置！
d之前介绍了Spring Boot 整合mybatis 使用注解方式配置的方式实现增删改查以及一些复杂自定义的sql 语句 .想必大家对spring boot 项目中,如何使用mybatis 有了一定 ...
Spring+SpringMVC+Mybatis 多数据源整合
原文地址:http://blog.csdn.net/q908555281/article/details/50316137 ----------------------------------- 此篇 ...
MyBatis学习随记
1 Mybatis入门 1.1 单独使用jdbc编程问题总结 1.1.1 jdbc程序 Public static void main(String[] args) { Conn ...
Mybatis学习一
1.Mytatis入门程序代码如下: package myBatis.cn.junit;import java.io.IOException; import java.io.InputStream ...
狂神说——Mybatis 学习
[狂神说Java]Mybatis最新完整教程IDEA版通俗易懂 Mybatis 笔记及源码 Mybatis 中文文档 Mybatis 案例源码狂神说--Mybatis 学习简介什么是Mybati ...
(五)MyBatis学习总结（超级详细哦，尤其适合初学者）
什么是MyBatis? MyBatis 是一款优秀的持久层框架,它支持自定义 SQL.存储过程以及高级映射. MyBatis 免除了几乎所有的 JDBC 代码以及设置参数和获取结果集的工作. MyBa ...
MyBatis学习：MyBatis的配置文件
1.本篇博文的背景和目的我本人正在学习MyBatis框架,在原先了解并且懵懵懂懂使用的基础上,开始系统正式的学习.阐述了MVC架构模式和三层架构,回顾了JDBC连接数据库,建立了使用MyBatis和 ...
事务中mybatis通过id查不到但是通过其他条件可以查到_40打卡 MyBatis 学习
第57次(mybatis) 学习主题:mybatis 学习目标: 1 掌握框架的概念 2 掌握mybatis环境搭建对应视频: http://www.itbaizhan.cn/course/id/8 ...
（五）springmvc+mybatis+dubbo+zookeeper分布式架构整合 - maven构建根项目
上一篇我们介绍<springmvc+mybatis+dubbo+zookeeper分布式架构整合 - maven模块规划>,从今天开始,我们将对代码的每一个构建做详细的记录,能够帮助大家 ...

mybatis 学习之多数据源整合

mybatis 学习之多数据源整合相关推荐

最新文章

热门文章