Spring2连接多数据库，实现读写分离
Spring2.0.1以后的版本已经支持配置多数据源，并且可以在运行的时候动态加载不同的数据源。通过继承 AbstractRoutingDataSource就可以实现多数据源的动态转换。目前做的项目就是需要访问2个数据源，每个数据源的表结构都是相同的，所以要求数据源的变动对于编码人员来说是透明，也就是说同样SQL语句在不同的环境下操作的数据库是不一样的。具体的流程如下：
一、建立一个获得和设置上下文的类
  package com.lvye.base.dao.impl.jdbc;
/**连接哪个数据源的 环境变量
* @author wenc
*/
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) (); 
          } 
          public static void clearJdbcType() { 
            ve(); 
          } 
}
二、建立动态数据源类，这个类必须继承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() {
              JdbcType();
      }
}
这个类实现了determineCurrentLookupKey方法，该方法返回一个Object，一般是返回字符串。该方法中直接 使用了JdbcType();方法获得上下文环境并直接返回。
三、编写spring的配置文件配置数据源
<beans>
      <bean id="master"
              class="hange.v2.c3p0.ComboPooledDataSource"
              destroy-method="close">
              <property name="driverClass">
                    <value&sql.jdbc.Driver</value>
              </property>
              <property name="jdbcUrl">
                    <value>jdbc:mysql://192.168.18.143:3306/wenhq?useUnicode=true&characterEncoding=utf-8</value>
              </property>
              <property name="user">
                    <value>root</value>
              </property>
              <property name="password">
                    <value></value>
              </property>
      </bean>
      <bean id="slave"
              class="hange.v2.c3p0.ComboPooledDataSource"
              destroy-method="close">
              <property name="driverClass">
                    <value&sql.jdbc.Driver</value>
              </property>
              <property name="jdbcUrl">
                    <value>jdbc:mysql://192.168.18.144:3306/ wenhq?useUnicode=true&characterEncoding=utf-8</value>
              </property>
              <property name="user">
                    <value>root</value>
              </property>
              <property name="password">
                    <value></value>
              </property>
      </bean>
  <bean id="mySqlDataSource" class="com.lvye.base.dao.impl.jdbc.DynamicDataSource">
          <property name="targetDataSources">
            <map>
                <entry key="slave" value-ref="slave"/>
            </map>
          </property>
          <property name="defaultTargetDataSource" ref="master"/>
  </bean>
      <bean id="jdbcTemplate"
              class="org.JdbcTemplate">
              <property name="dataSource" ref="mySqlDataSource" />
      </bean>
      <bean id="transactionManager"
              class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
              <property name="dataSource" ref="mySqlDataSource" />
      </bean>
</beans>
在这个配置中可以看到首先配置两个真实的数据库连接，使用的msyql数据 库；master和slave是按照mysql配置的主从关系的数据库，数据会自动实时同步。mySqlDataSource会根
据上下文选择不同的数据源。
jdbctemplate是什么在这个配置中第一个property属性配置目标数据源， <entry key="slave" value-ref=" slave "/>中key的值必须要和JdbcContextHolder类中设置的参数值相同，如果有多个值，可以配置多个< entry>标签。第二个property属性配置默认的数据源，我们一般默认为主数据库。
有些朋友喜欢使用hibernate，只需要把上面的jdbcTemplate替换为hibernate的就可以了。
四、多数据库连接配置完毕，简单测试
public void testSave() throws Exception{ 
        dbcContextHolder.setSlave();//设置从数据源 
        Test test = new Test(); 
        test.setTest("www.wenhq");           

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。