通用JdbcDao更新,增加动态数据源,支持权重和读写分离

分类: Spring 0人评论 1年前发布

注意:本组件已重构并全新发布,更加方便易于使用。代码全部开源,详情访问 Github仓库码云

版本:V1.2.3

本次更新增加了动态数据源的支持,可以十分方便的在配置文件中将原来的单数据源修改成动态数据源,而无须修改任何的业务代码。

下面来看看如何使用动态数据源,关于动态数据源的实现,请看这里:Spring实现动态数据源,支持动态添加、删除和设置权重及读写分离

第一步 当然是在spring中声明数据源bean了

<bean id="dynamicDataSource" class="com.dexcoder.assistant.persistence.DynamicDataSource">
    <property name="dsConfigFile" value="dynamic-ds.xml"/>
</bean>

像其它普通的bean一样,声明DynamicDataSource,只有一个属性参数dsConfigFile指定动态数据源的配置文件,默认为dynamic-ds.xml。上面的跟默认相同,可以省略。

对于dsConfigFile配置文件的查找会遵循以下顺序:

Tomcat的conf目录 -> project目录 -> classpath

这是为了方便在部署项目时,不管在开发环境还是正式环境都不用去频繁的修改配置信息,其实现效果可以参考:让项目、Spring在不同的环境加载不同的配置文件

另外,别忘了将你使用数据源的地方改为dynamicDataSource:

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource">
        <ref bean="dynamicDataSource"/>
    </property>
</bean>

还有事务管理:

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dynamicDataSource"/>
</bean>

第二步 编写动态数据源配置文件

先来看个样例:

<?xml version="1.0" encoding="UTF-8"?>
<dataources>
    <datasource id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource" default="true">
        <property name="weight" value="10"/>
        <property name="mode" value="w"/>
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/db1?useUnicode=true&characterEncoding=utf-8"/>
        <property name="username" value="root"/>
        <property name="password" value=""/>
    </datasource>
    <datasource id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="weight" value="5"/>
        <property name="mode" value="r"/>
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/db2?useUnicode=true&characterEncoding=utf-8"/>
        <property name="username" value="root"/>
        <property name="password" value=""/>
    </datasource>
    <datasource id="dataSource3" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="weight" value="5"/>
        <property name="mode" value="r"/>
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/db3?useUnicode=true&characterEncoding=utf-8"/>
        <property name="username" value="root"/>
        <property name="password" value=""/>
    </datasource>
</dataources>
  • dataources 根标签,固定
  • datasource 对应一个数据源
    • Attributes:
      • id 数据源的id,方便在日志中查看当前操作使用了哪个数据源
      • class 数据源使用的DataSource类,可以是dbcp,c3p0等各大数据源
      • default 是否默认,对应spring中的defaultTargetDataSource,应该只有一个
    • properties:
      • weight 权重,value为int型,虽然没有做限定,但仍建议为其设置一个合理且容易理解的值,如权重总和为10
      • mode 读写模式,r-读、w-写、rw-读写
      • 其它的属性,由你使用的具体数据源决定。等同于数据源在spring中声明时可以注入的属性都可以在这里进行设置

第三步 声明使用动态数据源的拦截器:

<bean id="dynamicDsInterceptor" class="com.dexcoder.assistant.interceptor.DynamicDsInterceptor"></bean>

这就可以,大功告成了,接下来就可以在你的项目中尽情的使用动态数据源了。

小贴士

1、说到使用动态数据源,很多人会认为这事务就不好控制了,其实不然。做过读写分离有经验的同学,应该都知道要解决一个“读己之所写”的问题,一般情况下解决了该问题线程从头到尾都是使用的同一个数据源也就解决了事务问题。

2、动态修改数据源,请看这里:动态修改数据源