mysql+spring+mybatis实现数据库读写分离的代码配置

场景:一个读数据源一个读写数据源。

原理:借助spring的【org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource】这个抽象类实现,看名字可以了解到是一个路由数据源的东西,这个类中有一个方法

/**
 * Determine the current lookup key. This will typically be
 * implemented to check a thread-bound transaction context.
 * <p>Allows for arbitrary keys. The returned key needs
 * to match the stored lookup key type, as resolved by the
 * {@link #resolveSpecifiedLookupKey} method.
 */
protected abstract Object determineCurrentLookupKey(); 

每次去连数据库的时候,spring会调用这个方法去找对应的数据源。返回值即对应的数据源的LookUpKey.那么这个LookUpKey在哪定义的呢?看下面的dataBase.xml的配置

<!--数据源 读写 -->
<bean id="dataSourceRW" class="org.logicalcobwebs.proxool.ProxoolDataSource">
  <property name="alias" value="ihotelRW"></property>
  <property name="delegateProperties">
    <value>user=${jdbc.username},password=${jdbc.password}
    </value>
  </property>
  <property name="user" value="${jdbc.username}" />
  <property name="password" value="${jdbc.password}" />
  <property name="driver" value="${jdbc.driverClassName}" />
  <property name="driverUrl" value="${jdbc.url}" />
  <property name="maximumConnectionCount" value="${jdbc.maximumConnectionCount}"></property>
  <property name="maximumActiveTime" value="${jdbc.maximumActiveTime}"></property>
  <property name="maximumConnectionLifetime" value="${jdbc.maximumConnectionLifetime}"></property>
  <property name="prototypeCount" value="${jdbc.prototypeCount}"></property>
  <property name="houseKeepingSleepTime" value="${jdbc.houseKeepingSleepTime}"></property>
  <property name="simultaneousBuildThrottle" value="${jdbc.simultaneousBuildThrottle}"></property>
  <property name="houseKeepingTestSql" value="${jdbc.houseKeepingTestSql}"></property>
  <property name="verbose" value="${jdbc.verbose}"></property>
  <property name="statistics" value="${jdbc.statistics}"></property>
  <property name="statisticsLogLevel" value="${jdbc.statisticsLogLevel}"></property>
</bean>
  <!--数据源 读-->
  <bean id="dataSourceR" class="org.logicalcobwebs.proxool.ProxoolDataSource">
    <property name="alias" value="ihotelR"></property>
    <property name="delegateProperties">
      <value>user=${jdbc.r.username},password=${jdbc.r.password}
      </value>
    </property>
    <property name="user" value="${jdbc.r.username}" />
    <property name="password" value="${jdbc.r.password}" />
    <property name="driver" value="${jdbc.r.driverClassName}" />
    <property name="driverUrl" value="${jdbc.r.url}" />
    <property name="maximumConnectionCount" value="${jdbc.maximumConnectionCount}"></property>
    <property name="maximumActiveTime" value="${jdbc.maximumActiveTime}"></property>
    <property name="maximumConnectionLifetime" value="${jdbc.maximumConnectionLifetime}"></property>
    <property name="prototypeCount" value="${jdbc.prototypeCount}"></property>
    <property name="houseKeepingSleepTime" value="${jdbc.houseKeepingSleepTime}"></property>
    <property name="simultaneousBuildThrottle" value="${jdbc.simultaneousBuildThrottle}"></property>
    <property name="houseKeepingTestSql" value="${jdbc.houseKeepingTestSql}"></property>
    <property name="verbose" value="${jdbc.verbose}"></property>
    <property name="statistics" value="${jdbc.statistics}"></property>
    <property name="statisticsLogLevel" value="${jdbc.statisticsLogLevel}"></property>
  </bean>
  <!-- 动态数据源 -->
  <bean id="dynamicDataSource" class="com.dao.datasource.DynamicDataSource">
    <!-- 通过key-value关联数据源 -->
    <property name="targetDataSources">
      <map>
        <entry value-ref="dataSourceRW" key="dataSourceKeyRW"></entry>
        <entry value-ref="dataSourceR" key="dataSourceKeyR"></entry>
      </map>
    </property>
    <property name="defaultTargetDataSource" ref="dataSourceRW" />
  </bean>
<!--mybatis与Spring整合 开始 -->
<bean id="sqlSessionFactory" name="sqlSessionFactory"
  class="org.mybatis.spring.SqlSessionFactoryBean">
  <property name="configLocation" value="classpath:conf/core/sqlMapConfig.xml" />
  <property name="dataSource" ref="dynamicDataSource" />
</bean> 

动态数据源dynamicDataSource中的dataSourceKeyRW、dataSourceKeyR就是

protected abstract Object determineCurrentLookupKey(); 

这个方法要返回的值。那么如何设置,让这个方法的返回值是根据我们的需要返回dataSourceKeyRW、dataSourceKeyR呢?由于这个方法没有入参,并且是spring自动调用的,因此考虑使用静态变量存储dataSource的key,在调用sql语句前设置静态变量的值,然后在这个方法中得到静态变量的值,返回。又考虑到多线程,同时可能会有很多请求,为避免线程之间相互干扰,考虑使用threadLocal。

先看存储dataSourceKey的容器类。

public class DBContextHolder {
  /**
   * 线程threadlocal
   */
  private static ThreadLocal<String> contextHolder = new ThreadLocal<>();
  private String DB_TYPE_RW = "dataSourceKeyRW";
  private String DB_TYPE_R = "dataSourceKeyR";
  public String getDbType() {
    String db = contextHolder.get();
    if (db == null) {
      db = DB_TYPE_RW;// 默认是读写库
    }
    return db;
  }
  /**
   * 设置本线程的dbtype
   * @param str
   * @see [相关类/方法](可选)
   * @since [产品/模块版本](可选)
   */
  public void setDbType(String str) {
    contextHolder.set(str);
  }
  /**
   * clearDBType
   * @Title: clearDBType
   * @Description: 清理连接类型
   */
  public static void clearDBType() {
    contextHolder.remove();
  }
} 

动态数据源的实现类。

public class DynamicDataSource extends AbstractRoutingDataSource {
  /*
   * (non-Javadoc)
   * @see javax.sql.CommonDataSource#getParentLogger()
   */
  @Override
  public Logger getParentLogger() throws SQLFeatureNotSupportedException {
    // TODO Auto-generated method stub
    return null;
  }
  /**
   * override determineCurrentLookupKey
   * <p>
   * Title: determineCurrentLookupKey
   * </p>
   * <p>
   * Description: 自动查找datasource
   * </p>
   * @return
   */
  @Override
  protected Object determineCurrentLookupKey() {
    return DBContextHolder.getDbType();
  }
} 

在DAO层中设置数据库类型。

/**
   * 添加邮件
   * @param sms
   * @return
   */
  public boolean insertEmail(Email email) {
    //根据具体需要设置不同的数据库
    DBContextHolder.setDbType(DBContextHolder.DB_TYPE_RW);
    //DBContextHolder.setDbType(DBContextHolder.DB_TYPE_R);
    int result = this.getSqlSession().insert(STATEMENT + ".addEntity",
        email);
    return result == 1;
  } 

在本例中,我们是在DAO中指定数据库,我们也可以根据需要在service或者controller中指定DB类型,需要记住的是setDbType是针对线程维度的。要考虑多线程的问题。

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对我们的支持。如果你想了解更多相关内容请查看下面相关链接

(0)

相关推荐

  • eclipse下整合springboot和mybatis的方法步骤

    1.新建maven项目 先新建一个maven项目,勾选上creat a simple project,填写groupid,artifactid 2.建立项目结构 3.添加依赖 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.3.RELEASE<

  • SpringBoot项目整合mybatis的方法步骤与实例

    1. 导入依赖的jar包 springboot项目整合mybatis之前首先要导入依赖的jar包,配置pom.xml文件如下: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  • 简单易懂的MyBatis分库分表方案分享

    前言 数据库分库分表除了使用中间件来代理请求分发之外,另外一种常见的方法就是在客户端层面来分库分表 -- 通过适当地包装客户端代码使得分库分表的数据库访问操作代码编写起来也很方便.本文的分库分表方案基于 MyBatis 框架,但是又不同于市面上常用的方案,它们一般都是通过编写复杂的 MyBatis 插件来重写 SQL 语句,这样的插件代码会巨复杂无比,可能最终只有插件的原作者自己可以完全吃透相关代码,给项目的维护性带来一定问题.本文的方案非常简单易懂,而且也不失使用上的便捷性.它的设计哲学来源于

  • mybatis利用association或collection传递多参数子查询

    有时候我们在查询数据库时,需要以查询结果为查询条件进行关联查询. 在mybatis 中通过 association 标签(一对一查询,collection 一对多 查询) 实现延迟加载子查询 <resultMap id="xxxMap" type="xxxx.bean.xxx" extends="zzzzMap"> <association property="destName" javaType="

  • mybatis动态sql之Map参数的讲解

    mybatis 动态sql之Map参数 Mapper文件: <mapper namespace="com.cn.shoje.oa.modules.logistics.dao.PurcDao"> <select id="findAll" parameterType="Map" resultType="Purchase"> select * from prod_purchase where 1=1 <

  • MyBatis insert操作插入数据之后返回插入记录的id

    MyBatis插入数据的时候,返回该记录的id <insert id="insert" keyProperty="id" useGeneratedKeys="true"
 parameterType="com.demo.domain.CountRateConfig">
 insert into query_rate_config (code,partner_type,search_count, booking_co

  • MyBatis异常-Property 'configLocation' not specified, using default MyBatis Configuration

    配置文件如下: base-context.xml文件如下: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http

  • Mybatis下动态sql中##和$$的区别讲解

    一.介绍 mybatis 中使用 Mapper.xml里面的配置进行 sql 查询,经常需要动态传递参数,例如我们需要根据用户的姓名来筛选用户时,sql 如下: select * from user where name = "Jack"; 上述 sql 中,我们希望 name 后的参数 "Jack" 是动态可变的,即不同的时刻根据不同的姓名来查询用户.在 Mapper.xml文件中使用如下的 sql 可以实现动态传递参数 name: select * from u

  • Mybatis MapperScannerConfigurer自动扫描Mapper接口生成代理注入到Spring的方法

    前言 Mybatis MapperScannerConfigurer 自动扫描 将Mapper接口生成代理注入到Spring Mybatis在与Spring集成的时候可以配置 MapperFactoryBean来生成Mapper接口的代理. 例如: <bean id="userMapper" class="org.mybatis.spring.mapper.MapperFactoryBean"> <property name="mappe

  • Mybatis模糊查询和动态sql语句的用法

    Mybatis 模糊查询和动态sql语句 模糊查询 对数据库最常用的操作就是查询了,但是如何使用Mybatis进行模糊查询呢?下面先看一个简单的模糊查询 <select id="select01" resultMap="BasicResultMap"> SELECT * FROM oa_employee WHERE emp_name LIKE #{asd} </select> 这是一条伪模糊查询, 因为没有实现真正的模糊 "%&qu

随机推荐