繼續(xù)上篇文章如何使用mybatis3+spring3并且配置多數(shù)據(jù)源呢?

先上代碼在講解吧?
替換上一篇中spring中datasource的配置?
Java代碼??

<!--?數(shù)據(jù)源配置?-->??

<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&amp;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&amp;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();??

????}??

}??

原來(lái)的單元測(cè)試新添加一行信息，修改為?
Java代碼??

@Test??

public?void?addTest()?throws?Exception?{??

????UserLogin?userLogin?=?new?UserLogin();??

????userLogin.setPassword("102");??

????userLogin.setUsername("102");??

????DataSourceContextHolder.setDbType("ds2");??

??

????service.add(userLogin);??

}??

最主要的變化是DynamicDataSource 類，這個(gè)類繼承了AbstractRoutingDataSource，我們?cè)倮^續(xù)考察，發(fā)現(xiàn)這個(gè)類實(shí)現(xiàn)了datasource這個(gè)接口。?

再仔細(xì)研究，發(fā)現(xiàn)我配置了多個(gè)數(shù)據(jù)源給DynamicDataSource，默認(rèn)的數(shù)據(jù)源是ds1。?
我們研究下AbstractRoutingDataSource類的代碼，主要是兩個(gè)實(shí)現(xiàn)datasource的方法?
Java代碼??

public?Connection?getConnection()?throws?SQLException?{??

????return?determineTargetDataSource().getConnection();??

}??

??

public?Connection?getConnection(String?username,?String?password)?throws?SQLException?{??

????return?determineTargetDataSource().getConnection(username,?password);??

}??

根據(jù)這段代碼發(fā)現(xiàn)主要玄機(jī)都在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;??

????}??

根據(jù)這段代碼發(fā)現(xiàn)，首先在使用數(shù)據(jù)源之前，首先判斷使用數(shù)據(jù)源的key，也就是我們配置給?
Java代碼??

private?Map<Object,?Object>?targetDataSources;??

這個(gè)map中的key值，找到key值之后再找到對(duì)應(yīng)的datasource然后并使用這個(gè)數(shù)據(jù)源。?


從上面我們發(fā)現(xiàn)，實(shí)際上DynamicDataSource只是在內(nèi)部封裝了數(shù)據(jù)源，然后調(diào)用它，只不過(guò)在內(nèi)部他加了一些控制而已。（此處不知道是否可以理解為代理模式）?

再深一步想想，此處使用的orm層是mybatis，如果換成hibernate呢，或者jdbctemplate呢。?
實(shí)際上這個(gè)方法都適用。

總結(jié)

以上是生活随笔為你收集整理的mybatis 学习之多数据源整合的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。