分布式数据库(三) 基于ShardingJDBC 分库分表

- 日理万妓 2022-09-17 04:25 359阅读 0赞

### 文章目录 ###

*   *   *  一、简介
         *  二、ShardingJDBC帮我干了什么？
         *  分布式的Sharding JDBC 如何保证分布式事务管理？
         *   *  1.本地非跨库
             *  2.分布式跨库
             *  刚性—XA 事务
             *  柔性—使用BASE事务
         *  Sharding JDBC数据分片的配置项

### 一、简介 ###

shardingsphere是Apache的一个产品，主要包括`Sharding JDBC`和`Sharding Proxy`，前者可以看作是增强版的JDBC，后者是独立出来的代理系统，无需耦合在代码中，在这点上，与Mycat很想  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6Ziz5YWJ5aSn55S35a2pIQ_size_20_color_FFFFFF_t_70_g_se_x_16]

### 二、ShardingJDBC帮我干了什么？ ###

在使用`Sharding JDBC`的时候，我们需要在配置文件去配置规则，这个规则用来告诉它如何解析我们发送的一条SQL，例如下图，逻辑表`ksd_order`根本不存在，他会按照我们配置的规则去判断数据源及对应数据源的表，最后把SQL转换，发送到对应数据源执行。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6Ziz5YWJ5aSn55S35a2pIQ_size_16_color_FFFFFF_t_70_g_se_x_16]

### 分布式的Sharding JDBC 如何保证分布式事务管理？ ###

#### 1.本地非跨库 ####

这种情况下，使用本地事务即可，例如直接使用`@Transactional`注解

#### 2.分布式跨库 ####

这种情况下，对于`两阶段XA事务`有比较好的支持，引入依赖，使用注解`@ShardingTransactionType`实现

#### 刚性—XA 事务 ####

XA 事务提供基于两阶段提交协议的实现机制。所谓两阶段提交，顾名思义分成两个阶段，**一个是准备阶段，一个是执行阶段**。在准备阶段中，协调者发起一个提议，分别询问各参与者是否接受。在执行阶段，协调者根据参与者的反馈，提交或终止事务。如果参与者全部同意则提交，只要有一个参与者不同意就终止。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6Ziz5YWJ5aSn55S35a2pIQ_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
目前，业界在实现 XA 事务时也存在一些主流工具库，包括 Atomikos、Narayana 和 Bitronix。ShardingSphere 对这三种工具库都进行了集成，并默认使用 Atomikos 来完成两阶段提交。

#### 柔性—使用BASE事务 ####

相较于 XA 事务，在业务代码中集成 BASE 事务的过程就显得相对复杂一点，因为我们需要借助外部框架来做到这一点。这里，我们将基于阿里巴巴提供的 Seata 框架来演示如何使用 BASE 事务。

从 XA 事务转到 BASE 事务唯一要做的事情就是重新设置 `TransactionType`，也就是修改一行代码：

@Override
    	public void processWithBASE() throws SQLException {
        
    		TransactionTypeHolder.set(TransactionType.BASE);
    		 
    		insertHealthRecords();
    	}

### Sharding JDBC数据分片的配置项 ###

dataSources: # 省略数据源配置，请参考使用手册
    
    rules:
    - !SHARDING
      tables: # 数据分片规则配置
        <logic-table-name> (+): # 逻辑表名称
          actualDataNodes (?): # 由数据源名 + 表名组成（参考Inline语法规则）
          databaseStrategy (?): # 分库策略，缺省表示使用默认分库策略，以下的分片策略只能选其一
            standard: # 用于单分片键的标准分片场景
              shardingColumn: # 分片列名称
              shardingAlgorithmName: # 分片算法名称
            complex: # 用于多分片键的复合分片场景
              shardingColumns: #分片列名称，多个列以逗号分隔
              shardingAlgorithmName: # 分片算法名称
            hint: # Hint 分片策略
              shardingAlgorithmName: # 分片算法名称
            none: # 不分片
          tableStrategy: # 分表策略，同分库策略
          keyGenerateStrategy: # 分布式序列策略
            column: # 自增列名称，缺省表示不使用自增主键生成器
            keyGeneratorName: # 分布式序列算法名称
      autoTables: # 自动分片表规则配置
        t_order_auto: # 逻辑表名称
          actualDataSources (?): # 数据源名称
          shardingStrategy: # 切分策略
            standard: # 用于单分片键的标准分片场景
              shardingColumn: # 分片列名称
              shardingAlgorithmName: # 自动分片算法名称
      bindingTables (+): # 绑定表规则列表
        - <logic_table_name_1, logic_table_name_2, ...> 
        - <logic_table_name_1, logic_table_name_2, ...> 
      broadcastTables (+): # 广播表规则列表
        - <table-name>
        - <table-name>
      defaultDatabaseStrategy: # 默认数据库分片策略
      defaultTableStrategy: # 默认表分片策略
      defaultKeyGenerateStrategy: # 默认的分布式序列策略
      defaultShardingColumn: # 默认分片列名称
      
      # 分片算法配置
      shardingAlgorithms:
        <sharding-algorithm-name> (+): # 分片算法名称
          type: # 分片算法类型
          props: # 分片算法属性配置
          # ...
      
      # 分布式序列算法配置
      keyGenerators:
        <key-generate-algorithm-name> (+): # 分布式序列算法名称
          type: # 分布式序列算法类型
          props: # 分布式序列算法属性配置
          # ...
    
    props:
      # ...

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6Ziz5YWJ5aSn55S35a2pIQ_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/f5798a20e163489d8972aab468c3adfd.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6Ziz5YWJ5aSn55S35a2pIQ_size_16_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/7cb5c98e5de448edaaf704307f727b35.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6Ziz5YWJ5aSn55S35a2pIQ_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/f60c5b4957ff492e9ecf59609ff82421.png