shardingsphere-jdbc 自定义分片策略

在ShardingSphere-JDBC中，自定义分片策略需要实现`ShardingAlgorithm`接口，并在配置文件中引用该自定义算法。

例如，假设要按照部门名称前缀进行分片，可以自定义一个`DeptNamePrefixShardingAlgorithm`算法，实现如下：

public class DeptNamePrefixShardingAlgorithm implements ShardingAlgorithm<String> {

    @Override
    public Collection<String> doSharding(Collection<String> availableTargetNames, ShardingValue<String> shardingValue) {
        Set<String> result = new HashSet<>();
        for (String targetName : availableTargetNames) {
            for (String value : shardingValue.getValues()) {
                if (targetName.endsWith(value.substring(0, 1))) {
                    result.add(targetName);
                }
            }
        }
        return result;
    }
}

在ShardingSphere配置文件中引用该算法，例如：

shardingRule:
  tables:
    dept:
      actualDataNodes: ds${0..1}.dept_${0..3}
      tableStrategy:
        standard:
          shardingColumn: dept_name
          shardingAlgorithmName: deptNamePrefixShardingAlgorithm
  shardingAlgorithms:
    deptNamePrefixShardingAlgorithm:
      type: INLINE
      props:
        algorithm.expression: dept_${dept_name.substring(0, 1)}
        algorithm.shardingColumns: dept_name

在代码中进行数据库操作时，需要将部门名称前缀作为分片键，例如：

try (Connection conn = dataSource.getConnection()) {
    String sql = "SELECT * FROM dept WHERE dept_name = ?";
    try (PreparedStatement ps = conn.prepareStatement(sql)) {
        ps.setString(1, "IT");
        try (ResultSet rs = ps.executeQuery()) {
            while (rs.next()) {
                // 处理查询结果
            }
        }
    }
}

需要注意的是，自定义分片策略需要实现`ShardingAlgorithm`接口，并根据具体业务需求进行调整。