shardingjdbc自定义分库算法

Sharding-JDBC 是一个基于 JDBC 驱动的分库分表中间件，它提供了多种分库分表策略和自定义分片算法的支持。

要自定义 Sharding-JDBC 的分库算法，需要实现 `com.dangdang.ddframe.rdb.sharding.api.strategy.database.DatabaseShardingAlgorithm` 接口。该接口包含一个方法：

Collection<String> doSharding(Collection<String> availableTargetNames, DatabaseShardingValue shardingValue);

在该方法中，`availableTargetNames` 参数是可用的目标库集合，`shardingValue` 参数是分片键的值。通过实现该方法，可以根据 shardingValue 的值，将数据分散到不同的目标库中。

例如，我们可以实现一个简单的按照奇偶数分库的算法：

public class OddEvenDatabaseShardingAlgorithm implements DatabaseShardingAlgorithm<Integer> {

    @Override
    public Collection<String> doSharding(Collection<String> availableTargetNames, DatabaseShardingValue<Integer> shardingValue) {
        Collection<String> result = new LinkedHashSet<>();
        for (Integer value : shardingValue.getValues()) {
            // 如果分片键是奇数，则选择 odd 数据库
            if (value % 2 == 1) {
                for (String dbName : availableTargetNames) {
                    if (dbName.endsWith("odd")) {
                        result.add(dbName);
                    }
                }
            }
            // 如果分片键是偶数，则选择 even 数据库
            else {
                for (String dbName : availableTargetNames) {
                    if (dbName.endsWith("even")) {
                        result.add(dbName);
                    }
                }
            }
        }
        return result;
    }
}

然后在 Sharding-JDBC 的配置文件中，配置自定义的分库算法：

# 配置分库策略
shardingRule:
  tables:
    # 配置分表规则
    order:
      actualDataNodes: ds${0..1}.order_${0..1}
      tableStrategy:
        inline:
          shardingColumn: order_id
          algorithmExpression: order_${order_id % 2}
  # 配置分库规则
  defaultDatabaseStrategy:
    inline:
      shardingColumn: user_id
      algorithmExpression: user_${user_id % 2}
  # 配置自定义分库算法
  defaultDatabaseShardingStrategy:
    standard:
      shardingAlgorithmName: oddEvenDatabaseShardingAlgorithm
      shardingAlgorithmClassName: com.example.OddEvenDatabaseShardingAlgorithm

在上面的配置中，我们将 `defaultDatabaseShardingStrategy` 配置为使用自定义的 `OddEvenDatabaseShardingAlgorithm` 分库算法。这样就可以根据分片键的值，将数据分散到不同的数据库中。