sharding-jdbc按照月份动态分表

### 使用 Sharding-JDBC 按照月份进行动态分表 #### 配置环境与依赖 确保使用的 Sharding-JDBC 版本与数据库兼容，并正确配置连接参数和分库分表规则[^2]。在 `pom.xml` 文件中引入必要的 Maven 依赖： ```xml <dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>${shardingjdbc.version}</version> </dependency> ``` #### 数据源配置 定义数据源以及分片策略，在 Spring Boot 中可以通过 YAML 或者 properties 文件完成配置工作。 ```yaml spring: shardingsphere: datasource: names: ds_0,ds_1 ds_0: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/db_name?serverTimezone=UTC&useSSL=false username: root password: pwd ds_1: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3307/db_name?serverTimezone=UTC&useSSL=false username: root password: pwd ``` #### 动态分表逻辑设计 对于按月创建的新表，可以采用时间字段作为分片键，通过自定义算法实现基于当前日期自动切换目标表格的功能。具体来说，可以在应用启动时加载现有表结构信息并定期刷新缓存；当有新请求到来时计算出对应的目标表名再执行 SQL 查询操作。 #### 自定义分片算法 编写 Java 类继承 AbstractShardingKeyGenerator 和 StandardShardingAlgorithm 来定制化分片规则。这里提供了一个简单的例子用于说明如何根据年份加月份生成不同的物理表名称： ```java public class MonthBasedTableShardingAlgorithm extends StandardShardingAlgorithm<String> { @Override protected Collection<String> doSharding(Collection<String> availableTargetNames, PreciseShardingValue<String> shardingValue) { String logicTableName = shardingValue.getLogicTableName(); Date date = (Date) shardingValue.getValue(); // 假设传入的是 java.util.Date 对象 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); Calendar cal = Calendar.getInstance(); cal.setTime(date); List<String> result = new ArrayList<>(); for (String each : availableTargetNames) { if (each.startsWith(logicTableName)) { try { int tableYearMonth = Integer.parseInt(each.substring(logicTableName.length())); int targetYearMonth = Integer.parseInt(sdf.format(cal.getTime()).substring(0, 6)); if (tableYearMonth == targetYearMonth) { result.add(each); } } catch (NumberFormatException ignored) {} } } return result; } } ``` 此代码片段实现了基于给定日期查找匹配的物理表功能。实际开发过程中还需要考虑更多边界情况，比如闰秒、夏令时等因素的影响。 #### 表结构初始化脚本 考虑到每月都会新增一张表，建议预先准备好建表语句模板，运行定时任务于月初创建下个月所需的空表。例如 MySQL 下面这样的 DDL 可以用来建立 alarm_history_yyyymm 形式的表： ```sql CREATE TABLE IF NOT EXISTS ${logic_table}_${year}${month} ( id BIGINT AUTO_INCREMENT PRIMARY KEY, node_id INT NOT NULL COMMENT '节点ID', metric_value DOUBLE DEFAULT NULL COMMENT '指标数值', collect_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '采集时间' ) ENGINE=InnoDB CHARSET=utf8mb4 COLLATE utf8mb4_general_ci; ``` 其中 `${logic_table}` 是业务逻辑层中的统一表名占位符，`${year}`, `${month}` 则由程序填充具体的四位数表示法的年份和两位数表示法的月份。 #### 应用部署优化 为了提升部署效率和可维护性，推荐使用容器化技术如 Docker 进行打包发布。这不仅简化了运维流程还增强了系统的移植性和稳定性。