datasource:
    driver-class-name: org.apache.shardingsphere.driver.ShardingSphereDriver
    url: jdbc:shardingsphere:classpath:sharding-dev.yml

HHH000342: Could not obtain connection to query metadata : Failed to initialize pool: Cannot create property=rules for JavaBean=org.apache.shardingsphere.infra.yaml.config.pojo.YamlRootConfiguration@7f22687e 
in 'reader', line 1, column 1: dataSources:

# 数据源集合
dataSources:
  # 数据库1
  ds_0:
    dataSourceClassName: com.zaxxer.hikari.HikariDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    jdbcUrl: jdbc:mysql://127.0.0.1:3306/orderdb?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&allowMultiQueries=true&serverTimezone=Asia/Shanghai
    username: root
    password: xxxxxx
rules:
  - !SHARDING
    tables:
      tb_erporder:
        # 真实数据节点，比如数据库源以及数据库在数据库中真实存在的
        actualDataNodes: ds_0.tb_erporder_$->{202501..205012}
        # 分表策略
        tableStrategy:
          # 用于单分片键的标准分片场景
          standard:
            # 分片键
            shardingColumn: send_date
            # 分片算法，对应 rules[0].shardingAlgorithms
            shardingAlgorithmName: tb_erporder-inline
      tb_erporder_items:
        actualDataNodes: ds_0.tb_erporder_items_$->{202501..205012}
        tableStrategy:
          standard:
            shardingColumn: send_date
            shardingAlgorithmName: tb_erporder_items-inline
    # 分片算法
    shardingAlgorithms:
      # 数据表分片算法
      tb_erporder-inline:
        # 根据分片键 分片
        type: INLINE
        # 分片算法
        props:
          algorithm-expression: tb_erporder_$->{new java.text.SimpleDateFormat("yyyyMM").format(send_date)}
      tb_erporder_items-inline:
        type: INLINE
        props:
          algorithm-expression: tb_erporder_items_$->{new java.text.SimpleDateFormat("yyyyMM").format(send_date)}
# 展现逻辑 SQL & 真实 SQL
props:
  sql-show: true

/**
 * @author: zhouyu
 * @date: 2025/4/5
 * @Description:
 */
public class MonthRangeShardingAlgorithm implements StandardShardingAlgorithm {
    @Override
    public String doSharding(Collection availableTargetNames, PreciseShardingValue shardingValue) {
        // 精确分片逻辑（单月查询）
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMM");
        String tableSuffix = sdf.format(shardingValue.getValue());
        String tableName = shardingValue.getLogicTableName() + "_" + tableSuffix;

        // 检查表是否存在
        if (availableTargetNames.contains(tableName)) {
            return tableName;
        }
        throw new IllegalArgumentException("无效的表名: " + tableName);
    }

    @Override
    public Collection<String> doSharding(Collection availableTargetNames, RangeShardingValue shardingValue) {
        // 范围查询分片逻辑
        Set<String> result = new LinkedHashSet<>();

        // 1. 获取查询范围
        Range<Date> range = shardingValue.getValueRange();
        Date lower = range.hasLowerBound() ? range.lowerEndpoint() : null;
        Date upper = range.hasUpperBound() ? range.upperEndpoint() : null;

        // 2. 如果没有范围（全表查询），返回所有可用表（或根据业务限制）
        if (lower == null && upper == null) {
            return availableTargetNames;
        }

        // 3. 计算涉及的月份范围
        Calendar cal = Calendar.getInstance();
        if (lower != null) {
            cal.setTime(lower);
        } else if (upper != null) {
            cal.setTime(upper);
        }

        // 4. 如果是单月查询（不跨月）
        if (isSameMonth(lower, upper)) {
            String tableName = shardingValue.getLogicTableName() + "_" +
                    new SimpleDateFormat("yyyyMM").format(lower != null ? lower : upper);
            if (availableTargetNames.contains(tableName)) {
                result.add(tableName);
            }
            return result;
        }

        // 5. 处理跨月查询
        Calendar current = (Calendar) cal.clone();
        while (upper == null || !current.getTime().after(upper)) {
            String tableName = shardingValue.getLogicTableName() + "_" +
                    new SimpleDateFormat("yyyyMM").format(current.getTime());
            if (availableTargetNames.contains(tableName)) {
                result.add(tableName);
            }

            // 移动到下个月
            current.add(Calendar.MONTH, 1);
            if (upper != null && current.getTime().after(upper)) {
                break;
            }
        }

        return result;
    }
    private boolean isSameMonth(Date d1, Date d2) {
        if (d1 == null || d2 == null) return false;
        Calendar cal1 = Calendar.getInstance();
        cal1.setTime(d1);
        Calendar cal2 = Calendar.getInstance();
        cal2.setTime(d2);
        return cal1.get(Calendar.YEAR) == cal2.get(Calendar.YEAR) &&
                cal1.get(Calendar.MONTH) == cal2.get(Calendar.MONTH);
    }

 # 分片算法
    shardingAlgorithms:
      # 数据表分片算法
      tb_erporder-inline:
        # 根据分片键 Hash 分片
        type: CLASS_BASED
        # 分片数量
        props:
          strategy: standard
          algorithmClassName: com.nantangju.backorder.config.MonthRangeShardingAlgorithm
      tb_erporder_items-inline:
        type: CLASS_BASED
        props:
          strategy: standard
          algorithmClassName: com.nantangju.backorder.config.MonthRangeShardingAlgorithm