欢迎光临
我们一直在努力

11. sharding-jdbc集成–基于ssm

10. sharding-jdbc源码之异步送达JOB

本篇文章讲解如何在ssm(spring、springmvc、mybatis)结构的程序上集成sharding-jdbc(版本为1.5.4.1)进行分库分表;

假设分库分表行为如下:

  • 将auth_user表分到4个库(user_0~user_3)中;
  • 其他表不进行分库分表,保留在default_db库中;

1. POM配置

以spring配置文件为例,新增如下POM配置:

11. sharding-jdbc集成--基于ssm

 

此次集成sharding-jdbc以1.5.4.1版本为例,如果是2.x版本的sharding-jdbc,那么需要将坐标<groupId>com.dangdang</groupId>修改为<groupId>io.shardingjdbc</groupId>;另外,如果是yaml配置,那么需要将坐标<artifactId>sharding-jdbc-config-spring</artifactId>修改为<artifactId>sharding-jdbc-config-yaml</artifactId>;

2. 配置数据源

spring-datasource.xml配置所有需要的数据源如下–auth_user分库分表后需要的4个库user_0~user_3,以及不分库分表的默认库default_db:

11. sharding-jdbc集成--基于ssm

 

11. sharding-jdbc集成--基于ssm

 

properties配置文件内容如下:

11. sharding-jdbc集成--基于ssm

 

3. 集成sharding数据源

spring-sharding.xml配置如下:

11. sharding-jdbc集成--基于ssm

 

11. sharding-jdbc集成--基于ssm

 

说明:spring-sharding.xml配置的分库分表规则:auth_user表分到id为sj_ds_${0..3}的四个库中,表名保持不变;其他表在id为sj_ds_default库中,不分库也不分表;集成sharding-jdbc的核心就是将SqlSessionFactoryBean需要的dataSource属性修改为shardingDataSource,把数据源交给sharding-jdbc处理;

分库逻辑AuthUserDatabaseShardingAlgorithm的代码很简单,源码如下:

11. sharding-jdbc集成--基于ssm

 

11. sharding-jdbc集成--基于ssm

 

这段代码参考sharding-jdbc源码中DatabaseShardingAlgorithm.java接口的实现即可,例如ModuloDatabaseShardingAlgorithm.java;

4. 注意事项

无法识别sharding-jdbc分库分表规则inline-expression问题,例如:

<rdb:table-rule logic-table="auth_user" actual-tables="sj_ds_${0..3}.auth_user" database-strategy="databaseStrategy"/>

  1. 根本原因:
  2. 根本原因是spring把${}当做占位符,${0..3}这种表达式,spring会尝试去properties文件中找key为0..3的属性。但是这里是sharding-jdbc分库分表规则的inline表达式,需要spring忽略这种行为。否则会抛出异常:
  3. java.lang.IllegalArgumentException: Could not resolve placeholder '0..3' in value "sj_ds_${0..3}.auth_user"
  4. 解决办法:
  5. 配置: <property name="ignoreUnresolvablePlaceholders" value="true"/>
  6. 或者: <context:property-placeholder ****** ignore-unresolvable="true" />

5. Main测试

Main.java用来测试分库分表是否OK,其源码如下:

11. sharding-jdbc集成--基于ssm

 

AuthUserMapper.selectByPrimaryKey()和UserPermissionMapper.selectPermissionByUsername()的代码和没有分库分表的代码完全一样;

6. 遗留问题

Main方法测试,或者启动服务后的调用测试都没有问题,但是通过junit测试用例访问就会抛出异常,作为一个待解决的遗留问题:

org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type 'javax.sql.DataSource' available: expected single matching bean but found 6: sj_ds_0,sj_ds_1,sj_ds_2,sj_ds_3,sj_ds_default,shardingDataSource
 收藏 (0) 打赏

您可以选择一种方式赞助本站

支付宝扫一扫赞助

微信钱包扫描赞助

未经允许不得转载:英协网 » 11. sharding-jdbc集成–基于ssm

分享到: 生成海报
avatar

热门文章

  • 评论 抢沙发

    • QQ号
    • 昵称 (必填)
    • 邮箱 (必填)
    • 网址

    登录

    忘记密码 ?

    切换登录

    注册

    我们将发送一封验证邮件至你的邮箱, 请正确填写以完成账号注册和激活