前言:

记录一个小笔记

背景:

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

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

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

public class MyTableShardingStrategy implements PreciseShardingAlgorithm<Date> {@Overridepublic 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 语句执行创建和删除操作。