[Java水平分表?这个表是怎么来的?]

分手后的思念是犯贱 2023-10-12 11:53 53阅读 0赞

**目录**

前言:

记录一个小笔记

背景:

示例代码，使用 ShardingSphere 创建和删除水平分表：

需要注意的是，在使用水平分表时，需要考虑数据的一致性和查询效率等问题

--------------------

## 前言: ##

## 记录一个小笔记 ##

## 背景: ##

水平分表是通过代码创建的，而不是库里面提前就创建好了对应分表。在水平分表的场景下，数据会被分散到多个表中，每个表中存储一部分数据。因此，在使用水平分表时，需要动态地创建和删除表，以适应数据的变化。

在 ShardingSphere 中，可以使用 `DataSource` 对象来访问分片数据源。在访问分片数据源时，ShardingSphere 会根据分片规则和分表策略来计算目标表的名称，然后动态地创建和删除表，以适应数据的变化。

### 示例代码，使用 ShardingSphere 创建和删除水平分表： ###

public class MyTableShardingStrategy implements PreciseShardingAlgorithm<Date> {
    
        @Override
        public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Date> shardingValue) {
            // 根据分表键的值，计算出目标表的名称
            // 例如，可以使用日期格式化将数据分散到多个表中
            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMM");
            String tableName = "my_table_" + sdf.format(shardingValue.getValue());
            if (availableTargetNames.contains(tableName)) {
                return tableName;
            }
            // 如果目标表不存在，则动态创建表
            createTable(tableName);
            return tableName;
        }
    
        private void createTable(String tableName) {
            // 使用 DataSource 对象创建表
            DataSource dataSource = ShardingDataSourceFactory.getDataSource();
            try (Connection conn = dataSource.getConnection()) {
                String sql = "CREATE TABLE " + tableName + " (id INT PRIMARY KEY, name VARCHAR(50))";
                try (Statement stmt = conn.createStatement()) {
                    stmt.executeUpdate(sql);
                }
            } catch (SQLException e) {
                throw new RuntimeException("Failed to create table: " + tableName, e);
            }
        }
    
        public void dropTable(String tableName) {
            // 使用 DataSource 对象删除表
            DataSource dataSource = ShardingDataSourceFactory.getDataSource();
            try (Connection conn = dataSource.getConnection()) {
                String sql = "DROP TABLE IF EXISTS " + tableName;
                try (Statement stmt = conn.createStatement()) {
                    stmt.executeUpdate(sql);
                }
            } catch (SQLException e) {
                throw new RuntimeException("Failed to drop table: " + tableName, e);
            }
        }
    }

#### 需要注意的是，在使用水平分表时，需要考虑数据的一致性和查询效率等问题 ####

`MyTableShardingStrategy` 类实现了 `PreciseShardingAlgorithm` 接口，用于处理水平分表的场景。在 `doSharding` 方法中，根据分表键的值计算出目标表的名称，如果目标表不存在，则动态创建表。具体来说，可以使用 `DataSource` 对象创建和删除表，然后使用 SQL 语句执行创建和删除操作。