【转】spring 数据库读写分离
什么是数据库的读写分离
数据库的读写分离简单的说是把对数据库读和写的操作分开对应不同的数据库服务器，这样能有效地减轻数据库压力，也能减轻io压力。主(master)数据库提供写操作，从(slave)数据库提供读操作，其实在很多系统中，主要是读的操作。当主(master)数据库进行写操作时，数据要同步到从(slave)的数据库，这样才能有效保证数据库完整性。主(master)数据库同步到从(slave)数据库，从数据库一般由多台数据库组成这样才能达到减轻压力的目的。这里还要注意处理好负载均衡。
使用spring的动态路由实现数据库读写分离
Spring2.0.1以后的版本已经支持配置多数据源，并且可以在运行的时候动态加载不同的数据源。通过继承AbstractRoutingDataSource就可以实现多数据源的动态转换。目前做的项目就是需要访问2个数据源，每个数据源的表结构都是相同的，所以要求数据源的变动对于编码人员来说是透明，也就是说同样SQL语句在不同的环境下操作的数据库是不一样的。具体的流程如下：
1.建立一个获得和设置上下文的类
package com.lvye.base.dao.impl.jdbc;
/**
*连接哪个数据源的环境变量
*/
public class JdbcContextHolder {
private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
public static void setJdbcType(String jdbcType) {
contextHolder.set(jdbcType);
}
public static void setSlave(){
setJdbcType("slave");
}
public static void setMaster(){
clearJdbcType();
}
public static String getJdbcType(){
return (String) contextHolder.get();
}
public static void clearJdbcType() {
contextHolder.remove();
}
} 2.建立动态数据源类，这个类必须继承AbstractRoutingDataSource
package com.lvye.base.dao.impl.jdbc;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class DynamicDataSource extends AbstractRoutingDataSource{
/*(non-Javadoc)
*@see org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource#determineCurrentLookupKey()
*@author wenc
*/
@Override
protected Object determineCurrentLookupKey() {
return JdbcContextHolder.getJdbcType();
}
} 这个类实现了determineCurrentLookupKey方法，该方法返回一个Object，一般是返回字符串。该方法中直接使用了JdbcContextHolder.getJdbcType();方法获得上下文环境并直接返回。
3.编写spring的配置文件配置数据源
public void testSave() throws Exception{
jdbcContextHolder.setSlave();//设置从数据源
Test test = new Test();
test.setTest("www.wenhq.com.cn");
mydao.save(test);//使用dao保存实体
jdbcContextHolder.setMaster();//设置主数据源
mydao.save(test);//使用dao保存实体到另一个库中
} 5.实现读写分离，上面的测试通过了，现在就简单了我的程序是使用jdbc实现的保存数据，只是使用了c3p0的数据库连接池而已。把所有访问数据库的方法包装一下，统一调用。把执行更新的sql发送到主数据库了
public void execute(String sql) {
JdbcContextHolder.setMaster();
log.debug("execute-sql:" + sql);
jdbcTemplate.execute(sql);
} 把查询的发送到从数据库，需要注意的是像LAST_INSERT_ID这类的查询需要特殊处理，必须发送到主数据库，建议增加专门的方法，用于获取自增长的主键。
public List findObject(String queryString, Class clazz) {
JdbcContextHolder.setSlave();
log.debug("findObject-sql:" + queryString);
List list = jdbcTemplate.queryForList(queryString);
try {
list = StringBase.convertList(list, clazz);// 将List转化为List<clazz>
} catch (Exception e) {
log.error("List convert List<Object> error:" + e);
}
AbstractRoutingDataSourcereturn list;
}