分庫分表(5) ---SpringBoot + ShardingSphere 實現分庫分表

分庫分表(5)--- ShardingSphere實現分庫分表

有關分庫分表前面寫了四篇博客:

一、分庫分表(1) --- 理論

二、分庫分表(2) --- ShardingSphere(理論)

三、分庫分表(3) ---SpringBoot + ShardingSphere實現讀寫分離

四、分庫分表(4) ---SpringBoot + ShardingSphere 實現分表

這篇博客經過ShardingSphere實現分庫分表，並在文章最下方附上項目Github地址。

1、項目概述

一、技術架構

項目整體技術選型

SpringBoot2.0.6 + shardingsphere4.0.0-RC1 + Maven3.5.4  + MySQL + lombok(插件)

二、項目說明

場景 在實際開發中，若是表的數據過大咱們須要把一張表拆分紅多張表，也能夠垂直切分把一個庫拆分紅多個庫，這裏就是經過ShardingSphere實現分庫分表功能。

三、數據庫設計

分庫 ds一個庫分爲 ds0庫 和 ds1庫。

分表 tab_user一張表分爲tab_user0表 和 tab_user1表。

如圖

ds0庫

ds1庫

具體的建立表SQL也會放到GitHub項目裏

2、核心代碼

說明 完整的代碼會放到GitHub上，這裏只放一些核心代碼。

一、application.properties

server.port=8084

#指定mybatis信息
mybatis.config-location=classpath:mybatis-config.xml
#打印sql
spring.shardingsphere.props.sql.show=true

spring.shardingsphere.datasource.names=ds0,ds1

spring.shardingsphere.datasource.ds0.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.ds0.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.ds0.url=jdbc:mysql://localhost:3306/ds0?characterEncoding=utf-8
spring.shardingsphere.datasource.ds0.username=root
spring.shardingsphere.datasource.ds0.password=root

spring.shardingsphere.datasource.ds1.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.ds1.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.ds1.url=jdbc:mysql://localhost:3306/ds1?characterEncoding=utf-8
spring.shardingsphere.datasource.ds1.username=root
spring.shardingsphere.datasource.ds1.password=root

#根據年齡分庫
spring.shardingsphere.sharding.default-database-strategy.inline.sharding-column=age
spring.shardingsphere.sharding.default-database-strategy.inline.algorithm-expression=ds$->{age % 2}
#根據id分表
spring.shardingsphere.sharding.tables.tab_user.actual-data-nodes=ds$->{0..1}.tab_user$->{0..1}
spring.shardingsphere.sharding.tables.tab_user.table-strategy.inline.sharding-column=id
spring.shardingsphere.sharding.tables.tab_user.table-strategy.inline.algorithm-expression=tab_user$->{id % 2}

Sharding-JDBC能夠經過Java，YAML，Spring命名空間和Spring Boot Starter四種方式配置，開發者可根據場景選擇適合的配置方式。具體能夠看官網。

二、UserController

@RestController
public class UserController {

    @Autowired
    private UserService userService;

    /**
     * 模擬插入數據
     */
    List<User> userList = Lists.newArrayList();
    /**
     * 初始化插入數據
     */
    @PostConstruct
    private void getData() {
        userList.add(new User(1L,"小小", "女", 3));
        userList.add(new User(2L,"爸爸", "男", 30));
        userList.add(new User(3L,"媽媽", "女", 28));
        userList.add(new User(4L,"爺爺", "男", 64));
        userList.add(new User(5L,"奶奶", "女", 62));
    }
    /**
     * @Description: 批量保存用戶
     */
    @PostMapping("save-user")
    public Object saveUser() {
        return userService.insertForeach(userList);
    }
    /**
     * @Description: 獲取用戶列表
     */
    @GetMapping("list-user")
    public Object listUser() {
        return userService.list();
    }

3、測試驗證

一、批量插入數據

請求接口

localhost:8084/save-user

咱們能夠從商品接口代碼中能夠看出，它會批量插入5條數據。咱們先看控制檯輸出SQL語句

咱們能夠從SQL語句能夠看出 ds0 和 ds1 庫中都插入了數據。

咱們再來看數據庫

ds0.tab_user0

ds0.tab_user1

ds1.tab_user0

ds1.tab_user1

完成分庫分表插入數據。

二、獲取數據

這裏獲取列表接口的SQL，這裏對SQL作了order排序操做，具體ShardingSphere分表實現order操做的原理能夠看上面一篇博客。

select *  from tab_user order by age  <!--根據年齡排序-->

請求接口結果

咱們能夠看出雖然已經分庫分表，但依然能夠將多表數據聚合在一塊兒並能夠支持按age排序。

注意 ShardingSphere並不支持CASE WHEN、HAVING、UNION (ALL)，有限支持子查詢。這個官網有詳細說明。

Github地址：https://github.com/yudiandemingzi/spring-boot-sharding-sphere

參考

一、ShardingSphere中文文檔

二、ShardingSphere官網

三、Shardingsphere Github庫

我相信，不管從此的道路多麼坎坷，只要抓住今天，早晚會在奮鬥中嚐到人生的甘甜。抓住人生中的一分一秒，賽過虛度中的一月一年！(20）