本篇文章讲解如何在ssm(spring、springmvc、mybatis)结构的程序上集成sharding-jdbc(版本为2.0.3)进行分库分表;
假设分库分表行为如下:
- 将auth_user表分到4个库(user_0~user_3)中;
- 其他表不进行分库分表,保留在default_db库中;
1. POM配置
以spring配置文件为例,新增如下POM配置:
2. 配置数据源
spring-datasource.xml配置所有需要的数据源如下–auth_user分库分表后需要的4个库user_0~user_3,以及不分库分表的默认库default_db:
properties配置文件内容如下:
3. 集成sharding数据源
spring-sharding.xml配置如下:
说明:spring-sharding.xml配置的分库分表规则:auth_user表分到id为sj_ds_${0..3}的四个库中,表名保持不变;其他表在id为sj_ds_default库中,不分库也不分表;集成sharding-jdbc的核心就是将SqlSessionFactoryBean需要的dataSource属性修改为shardingDataSource,把数据源交给sharding-jdbc处理;
另外,通过对比这里和sharding-jdbc1.5.4.1版本的配置请戳链接:https://www.jianshu.com/p/602e24845ed3,差异还是比较大,大概提现在如下一些地方:
- namespace由rdb改为sharding;
- 默认数据库策略和默认表策略被设置为<sharding:sharding-rule>节点的属性,分别是default-database-strategy-ref和default-table-strategy-ref;
- 默认数据源被设置为<sharding:sharding-rule>节点的属性,即default-data-source-name;
- <sharding:table-rule>一些属性变更,例如:actual-tables改为actual-data-nodes,database-strategy改为database-strategy-ref;
我们平常开发过程中,可以参考sharding-jdbc源码sharding-jdbc-core-spring-namespace模块中META.rdb目录下的xml,作者对几乎各种使用方式都有实例;
分库逻辑AuthUserDatabaseShardingAlgorithm的代码很简单,源码如下:
这段代码参考sharding-jdbc源码中PreciseShardingAlgorithm.java接口的实现即可,例如PreciseModuloDatabaseShardingAlgorithm.java;这里和sharding-jdbc1.5.4.1版本的差异也比较大,sharding-jdbc1.5.4.1对于分库或者分表sharding算法实现的接口是不一样的,sharding-jdbc2.0.3将两者合二为一,且只有一个方法,即doSharding();
4. 注意事项
无法识别sharding-jdbc分库分表规则inline-expression问题,例如:
<rdb:table-rule logic-table="auth_user" actual-tables="sj_ds_${0..3}.auth_user" database-strategy="databaseStrategy"/>
- 根本原因:
- 根本原因是spring把${}当做占位符,${0..3}这种表达式,spring会尝试去properties文件中找key为0..3的属性。但是这里是sharding-jdbc分库分表规则的inline表达式,需要spring忽略这种行为。否则会抛出异常:
- java.lang.IllegalArgumentException: Could not resolve placeholder '0..3' in value "sj_ds_${0..3}.auth_user"
- 解决办法:
- 配置: <property name="ignoreUnresolvablePlaceholders" value="true"/>
- 或者: <context:property-placeholder ****** ignore-unresolvable="true" />
5. Main测试
Main.java用来测试分库分表是否OK,其源码如下:
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