shardingjdbc分片策略模拟广播表数据的插入与更新

Question

有数据库a，它有des信息表，有数据库b，它也有des信息表，shardingjdbc配置文件中设置did为分片值，映射真实表为a.des，b.des，那么使用standard策略，它的分库精确值算法类不管did值为多少，都返回a、b，分表精确值算法类不管did值为多少，都返回des，那么是不是在进行数据插入时，两个库的des都会插入同样的数据 ，理论上比如插入一条did为1的数据，两个表都会有这条数据。对其中某一个表进行操作，另外一个表也会进行一样的操作，我这个算不算用分片策略模拟了广播表的插入与更新？

Answer 1

引自免费微信小程序：皆我百晓生

要使用ShardingJDBC模拟广播表的插入与更新行为，确实可以通过特定的分片策略实现。在标准分片策略（StandardShardingStrategyConfiguration）中，你可以自定义分库和分表策略，使得不论传入的分片键是什么值，数据都能被路由到所有指定的数据库和表上。

配置示例

首先，创建分库策略类和分表策略类，它们将始终返回所有数据库和表，无论分片键是什么。

1. 分库策略类

public class AlwaysAllDatabasesShardingAlgorithm implements ShardingSphereAlgorithm {

    @Override
    public Collection<String> doSharding(Collection<String> availableTargetNames, ShardingValue shardingValue) {
        return availableTargetNames;
    }
}

2. 分表策略类

public class AlwaysAllTablesShardingAlgorithm implements ShardingSphereAlgorithm {

    @Override
    public Collection<String> doSharding(Collection<String> availableTargetNames, ShardingValue shardingValue) {
        return availableTargetNames;
    }
}

3. ShardingJDBC配置

在ShardingJDBC的配置中，使用上述自定义的策略类：

ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
shardingRuleConfig.getTableRuleConfigs().add(getOrderTableRuleConfiguration());
shardingRuleConfig.setBindingTableGroups(Arrays.asList("t_order,t_order_item"));
shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new StandardShardingStrategyConfiguration("did", new AlwaysAllDatabasesShardingAlgorithm()));
shardingRuleConfig.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("did", new AlwaysAllTablesShardingAlgorithm()));

DataSourceRuleConfiguration dataSourceRuleConfig = new DataSourceRuleConfiguration();
dataSourceRuleConfig.getDataSources().put("ds_0", new DataSourceParameter("jdbc:mysql://localhost:3306/db_a?serverTimezone=UTC&useSSL=false", "root", "password"));
dataSourceRuleConfig.getDataSources().put("ds_1", new DataSourceParameter("jdbc:mysql://localhost:3306/db_b?serverTimezone=UTC&useSSL=false", "root", "password"));

ShardingSphereDataSource dataSource = ShardingSphereDataSourceFactory.createDataSource(dataSourceRuleConfig, shardingRuleConfig, new Properties());

测试插入与更新

为了验证数据是否正确地被插入并更新到所有的数据库和表中，可以编写一些测试代码：

public class BroadcastTest {
    private static final String SQL_INSERT = "INSERT INTO t_order (order_id, user_id, status) VALUES (?, ?, ?)";
    private static final String SQL_UPDATE = "UPDATE t_order SET status = ? WHERE order_id = ?";
    
    @Test
    public void testInsert() throws SQLException {
        try (Connection conn = dataSource.getConnection();
             PreparedStatement ps = conn.prepareStatement(SQL_INSERT)) {
            ps.setInt(1, 1);
            ps.setInt(2, 1);
            ps.setString(3, "INIT");
            ps.executeUpdate();
        }
    }

    @Test
    public void testUpdate() throws SQLException {
        try (Connection conn = dataSource.getConnection();
             PreparedStatement ps = conn.prepareStatement(SQL_UPDATE)) {
            ps.setString(1, "FINISH");
            ps.setInt(2, 1);
            ps.executeUpdate();
        }
    }
}

结论

通过上述配置和测试，每次执行插入或更新操作时，数据将被复制到所有分片中的对应表。这实质上实现了广播表的功能，即每个分片都包含相同的数据集。不过，要注意的是，这种策略可能会导致数据冗余和存储成本增加，因此在实际生产环境中使用时需谨慎考虑。