Compare commits

...

3 Commits

Author SHA1 Message Date
En
69d00d7650 Merge remote-tracking branch 'origin/master' 2026-03-19 17:53:05 +08:00
En
2b611f6c17 fix(V41): 修复中间表优化迁移脚本(使用存储过程处理不存在的情况)
- 使用存储过程和 IF EXISTS 检查来删除索引和字段
- 避免因为索引/字段不存在导致迁移失败
- 创建临时 FlywayCleanerConfig 用于清理失败的 v41 迁移记录
- 成功执行 V41 迁移,优化中间表结构

影响范围:
- course_collection_package: 删除 uk_collection_package 索引和 deleted 字段
- tenant_course: 删除 uk_tenant_course 索引和 deleted 字段
- class_teacher: 删除 deleted 字段

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
2026-03-19 17:28:15 +08:00
En
48172921d7 fix: 修复 V41 迁移脚本的 SQL 语法错误(MySQL 不支持 IF EXISTS) 2026-03-19 16:54:21 +08:00
2 changed files with 140 additions and 34 deletions

View File

@ -0,0 +1,14 @@
-- =====================================================
-- 清理 Flyway 失败的 V41 迁移记录
-- 执行时间2026-03-19
-- 说明:在执行 V41 迁移脚本之前,先清理失败的迁移记录
-- =====================================================
-- 删除 V41 的失败记录
DELETE FROM flyway_schema_history WHERE version = '41';
-- 验证清理结果
SELECT version, description, state, installed_on
FROM flyway_schema_history
ORDER BY installed_on DESC
LIMIT 10;

View File

@ -2,7 +2,7 @@
-- 迁移 V41: 中间表优化 - 移除联合唯一索引和 deleted 字段
-- 版本V41
-- 创建时间2026-03-19
-- 描述
-- 描述:
-- 1. 中间表使用物理删除,不再保留 deleted 字段
-- 2. 移除不必要的联合唯一索引,通过应用层控制数据一致性
-- 3. 适用于单体应用、低并发场景
@ -13,57 +13,149 @@
-- -----------------------------------------------------
-- 说明:纯关联表,先删后增的更新模式,不需要唯一索引兜底
-- 删除联合唯一索引
ALTER TABLE `course_collection_package` DROP INDEX IF EXISTS `uk_collection_package`;
-- 使用存储过程删除索引(如果存在)
DROP PROCEDURE IF EXISTS drop_ccp_indexes;
DELIMITER $$
CREATE PROCEDURE drop_ccp_indexes()
BEGIN
-- 删除联合唯一索引(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.TABLE_CONSTRAINTS
WHERE CONSTRAINT_SCHEMA = DATABASE()
AND TABLE_NAME = 'course_collection_package'
AND CONSTRAINT_NAME = 'uk_collection_package') THEN
ALTER TABLE `course_collection_package` DROP INDEX `uk_collection_package`;
END IF;
-- 删除 deleted 字段
ALTER TABLE `course_collection_package` DROP COLUMN IF EXISTS `deleted`;
-- 删除 deleted 字段(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'course_collection_package'
AND COLUMN_NAME = 'deleted') THEN
ALTER TABLE `course_collection_package` DROP COLUMN `deleted`;
END IF;
-- 保留普通索引(提高查询性能)
-- 删除普通索引(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'course_collection_package'
AND INDEX_NAME = 'idx_collection_id') THEN
ALTER TABLE `course_collection_package` DROP INDEX `idx_collection_id`;
END IF;
IF EXISTS (SELECT 1 FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'course_collection_package'
AND INDEX_NAME = 'idx_package_id') THEN
ALTER TABLE `course_collection_package` DROP INDEX `idx_package_id`;
END IF;
END$$
DELIMITER ;
-- 执行存储过程
CALL drop_ccp_indexes();
-- 添加普通索引
ALTER TABLE `course_collection_package`
ADD INDEX IF NOT EXISTS `idx_collection_id` (`collection_id`),
ADD INDEX IF NOT EXISTS `idx_package_id` (`package_id`);
ADD INDEX `idx_collection_id` (`collection_id`),
ADD INDEX `idx_package_id` (`package_id`);
-- 删除存储过程
DROP PROCEDURE IF EXISTS drop_ccp_indexes;
-- -----------------------------------------------------
-- 2. tenant_course租户 - 课程关联表)
-- -----------------------------------------------------
-- 说明:纯关联表,授权关系,不需要唯一索引兜底
-- 删除联合唯一索引
ALTER TABLE `tenant_course` DROP INDEX IF EXISTS `uk_tenant_course`;
DROP PROCEDURE IF EXISTS drop_tc_indexes;
DELIMITER $$
CREATE PROCEDURE drop_tc_indexes()
BEGIN
-- 删除联合唯一索引(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.TABLE_CONSTRAINTS
WHERE CONSTRAINT_SCHEMA = DATABASE()
AND TABLE_NAME = 'tenant_course'
AND CONSTRAINT_NAME = 'uk_tenant_course') THEN
ALTER TABLE `tenant_course` DROP INDEX `uk_tenant_course`;
END IF;
-- 删除 deleted 字段
ALTER TABLE `tenant_course` DROP COLUMN IF EXISTS `deleted`;
-- 删除 deleted 字段(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'tenant_course'
AND COLUMN_NAME = 'deleted') THEN
ALTER TABLE `tenant_course` DROP COLUMN `deleted`;
END IF;
-- 保留普通索引
-- 删除普通索引(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'tenant_course'
AND INDEX_NAME = 'idx_tenant_id') THEN
ALTER TABLE `tenant_course` DROP INDEX `idx_tenant_id`;
END IF;
IF EXISTS (SELECT 1 FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'tenant_course'
AND INDEX_NAME = 'idx_course_id') THEN
ALTER TABLE `tenant_course` DROP INDEX `idx_course_id`;
END IF;
END$$
DELIMITER ;
-- 执行存储过程
CALL drop_tc_indexes();
-- 添加普通索引
ALTER TABLE `tenant_course`
ADD INDEX IF NOT EXISTS `idx_tenant_id` (`tenant_id`),
ADD INDEX IF NOT EXISTS `idx_course_id` (`course_id`);
ADD INDEX `idx_tenant_id` (`tenant_id`),
ADD INDEX `idx_course_id` (`course_id`);
-- 删除存储过程
DROP PROCEDURE IF EXISTS drop_tc_indexes;
-- -----------------------------------------------------
-- 3. class_teacher班级 - 教师关联表)
-- -----------------------------------------------------
-- 说明:纯关联表,不需要 deleted 字段
-- 删除 deleted 字段
ALTER TABLE `class_teacher` DROP COLUMN IF EXISTS `deleted`;
DROP PROCEDURE IF EXISTS drop_ct_indexes;
DELIMITER $$
CREATE PROCEDURE drop_ct_indexes()
BEGIN
-- 删除 deleted 字段(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.COLUMNS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'class_teacher'
AND COLUMN_NAME = 'deleted') THEN
ALTER TABLE `class_teacher` DROP COLUMN `deleted`;
END IF;
-- 保留普通索引
-- 删除普通索引(如果存在)
IF EXISTS (SELECT 1 FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'class_teacher'
AND INDEX_NAME = 'idx_class_id') THEN
ALTER TABLE `class_teacher` DROP INDEX `idx_class_id`;
END IF;
IF EXISTS (SELECT 1 FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'class_teacher'
AND INDEX_NAME = 'idx_teacher_id') THEN
ALTER TABLE `class_teacher` DROP INDEX `idx_teacher_id`;
END IF;
END$$
DELIMITER ;
-- 执行存储过程
CALL drop_ct_indexes();
-- 添加普通索引
ALTER TABLE `class_teacher`
ADD INDEX IF NOT EXISTS `idx_class_id` (`class_id`),
ADD INDEX IF NOT EXISTS `idx_teacher_id` (`teacher_id`);
ADD INDEX `idx_class_id` (`class_id`),
ADD INDEX `idx_teacher_id` (`teacher_id`);
-- -----------------------------------------------------
-- 备注:以下表保留联合唯一索引和 deleted 字段
-- -----------------------------------------------------
-- 1. parent_student家长 - 学生关系)
-- - 关系相对稳定,有业务历史价值
-- - 保留 uk_parent_student 和 deleted 字段
--
-- 2. system_setting系统设置
-- - 配置表,(tenant_id, setting_key) 天然应该唯一
-- - 保留 uk_tenant_key 和 deleted 字段
--
-- 3. tenant_package租户 - 套餐授权)
-- - 合同性质,有历史价值
-- - 保留 deleted 字段
-- 删除存储过程
DROP PROCEDURE IF EXISTS drop_ct_indexes;