参考
yinjihuan 大佬的博客,以及包含github的源代码,6的飞起
https://www.jianshu.com/p/0e3905ae6ef2
数据分片(分库和分表的Springboot版本 配置说明)
http://shardingsphere.io/document/current/cn/manual/sharding-jdbc/configuration/config-spring-boot/
Demo
基于User业务的分库分表,按照sex字段进行分库,按照ID字段进行分表,纯springboot 配置文件式的指定关系和策略
https://github.com/huangzhenshi/shardingJdbc-SpringBoot
数据库分表的概述
- 数据库分表的目的是提升Mysql查询的效率,原理类似于数据库的分区,把一个大表,根据业务需求的特点,拆分成若干个子表,然后读写操作的时候,只要操作1个或者几个相关的子表,而不是全表扫描,从而大大提升查询的效率。同时也提升了写的速度,因为写的时候(比如删除或者修改)也需要先定位数据。
- 数据库的分表可以不借助中间件,直接通过编码的形式实现,例如Mybatis里面SQL,根据业务特点拼子表的表名,但是这种方式的缺点是编程复杂,而且不适用Hibernate和JPA。
- 数据库的分表最好是在一个数据库里面,避免了分布式事务的问题,不过理论上也是支持跨库的分表
- 可以借助Sharding-Jdbc帮助实现数据库的分表,通过预先配置表关系和实现接口设定数据分配规则,最终实现像操作一张表一样,操作多个子表,实现了类似数据库分区的效果。
配置方式
- 常规的pom.xml 依赖,只依赖一个jar包 sharding-jdbc-spring-boot-starter-2.0.0.M3.jar
- 表关系配置,多个子表指定一个逻辑表,编程的时候,只要操作逻辑表即可,中间件封装了复杂性
- 配置文件里面指定分表的逻辑,并且指定实现类,实现分表逻辑
<dependency>
<groupId>io.shardingjdbc</groupId>
<artifactId>sharding-jdbc-spring-boot-starter</artifactId>
<version>2.0.0.M3</version>
</dependency>
sharding.jdbc.datasource.names=ds_master
sharding.jdbc.datasource.ds_master.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds_master.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds_master.url=jdbc:mysql://localhost:3306/ds_master?characterEncoding=utf-8
sharding.jdbc.datasource.ds_master.username=root
sharding.jdbc.datasource.ds_master.password=123456
sharding.jdbc.config.sharding.tables.user.actual-data-nodes=ds_master.user_${0..3}
sharding.jdbc.config.sharding.tables.user.table-strategy.standard.sharding-column=id
sharding.jdbc.config.sharding.tables.user.table-strategy.standard.precise-algorithm-class-name=com.fangjia.sharding.MyPreciseShardingAlgorithm
public class MyPreciseShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
@Override
public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Long> shardingValue) {
for (String tableName : availableTargetNames) {
if (tableName.endsWith(shardingValue.getValue() % 4 + "")) {
return tableName;
}
}
throw new IllegalArgumentException();
}
}
- 代码编写时,和操作一张表一样,该怎么写就怎么写
<insert id="addUser">
INSERT INTO user (id, city, name ) VALUES (#{id},#{city},#{name})
</insert>
<select id="list" resultMap="baseResultMap">
SELECT u.* FROM user u
</select>
<select id="findById" resultMap="baseResultMap">
SELECT u.* FROM user u WHERE u.id=#{id,jdbcType=INTEGER}
</select>
注意事项
使用分表分库插入数据的时候,必须先手动生成分片键(比如ID),否则程序不知道该数据要插入到哪个数据库的哪张表中。
数据库分库
分库可以从物理层面上提升性能,一般用于垂直分片,把不同的业务分在不同的数据库上,当然也支持水平分片,例如我们的Demo,把User业务,按照sex字段进行分库
分库会引发分布式事务的问题
- 配置参考下面的,根据sex字段来进行分库,sex是奇数进 ds_1库,偶数进ds_0库
sharding.jdbc.datasource.names=ds_0,ds_1
sharding.jdbc.datasource.ds_0.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds_0.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds_0.url=jdbc:mysql://localhost:3306/ds_0?characterEncoding=utf-8
sharding.jdbc.datasource.ds_0.username=root
sharding.jdbc.datasource.ds_0.password=123456
sharding.jdbc.datasource.ds_1.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds_1.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds_1.url=jdbc:mysql://localhost:3306/ds_1?characterEncoding=utf-8
sharding.jdbc.datasource.ds_1.username=root
sharding.jdbc.datasource.ds_1.password=123456
sharding.jdbc.config.sharding.default-database-strategy.inline.sharding-column=sex
sharding.jdbc.config.sharding.default-database-strategy.inline.algorithm-expression=ds_${sex % 2}
- 插入的时候,记得要先指定好 sex字段值
for (long i = 0; i < 100; i++) {
User user = new User();
user.setId(i);
user.setCity("苏州");
user.setName("小燕儿female");
user.setSex(1);
userService.add(user);
}