Mysql

Sharding-jdbc 分库分表Springboot配置式

2019-01-26  本文已影响116人  黄靠谱

参考

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

数据库分表的概述

  1. 数据库分表的目的是提升Mysql查询的效率,原理类似于数据库的分区,把一个大表,根据业务需求的特点,拆分成若干个子表,然后读写操作的时候,只要操作1个或者几个相关的子表,而不是全表扫描,从而大大提升查询的效率。同时也提升了写的速度,因为写的时候(比如删除或者修改)也需要先定位数据。
  2. 数据库的分表可以不借助中间件,直接通过编码的形式实现,例如Mybatis里面SQL,根据业务特点拼子表的表名,但是这种方式的缺点是编程复杂,而且不适用Hibernate和JPA。
  3. 数据库的分表最好是在一个数据库里面,避免了分布式事务的问题,不过理论上也是支持跨库的分表
  4. 可以借助Sharding-Jdbc帮助实现数据库的分表,通过预先配置表关系和实现接口设定数据分配规则,最终实现像操作一张表一样,操作多个子表,实现了类似数据库分区的效果。

配置方式

  1. 常规的pom.xml 依赖,只依赖一个jar包 sharding-jdbc-spring-boot-starter-2.0.0.M3.jar
  2. 表关系配置,多个子表指定一个逻辑表,编程的时候,只要操作逻辑表即可,中间件封装了复杂性
  3. 配置文件里面指定分表的逻辑,并且指定实现类,实现分表逻辑
<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();
    }
}
  1. 代码编写时,和操作一张表一样,该怎么写就怎么写
    <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字段进行分库
分库会引发分布式事务的问题

  1. 配置参考下面的,根据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}
  1. 插入的时候,记得要先指定好 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);
    }
上一篇下一篇

猜你喜欢

热点阅读