193 lines
8.2 KiB
SQL
193 lines
8.2 KiB
SQL
-- 市场移动端运费批次查询与并发关联约束（MySQL 5.7，幂等）。
|
|
-- 若存量数据冲突或同名对象定义错误则明确中止，不静默移动/删除数据。
|
|
|
|
SET NAMES utf8mb4;
|
|
|
|
DELIMITER $$
|
|
|
|
DROP PROCEDURE IF EXISTS `ensure_market_freight_indexes`$$
|
|
CREATE PROCEDURE `ensure_market_freight_indexes`()
|
|
BEGIN
|
|
DECLARE duplicate_rows INT DEFAULT 0;
|
|
DECLARE object_count INT DEFAULT 0;
|
|
DECLARE index_non_unique INT DEFAULT 1;
|
|
DECLARE index_columns VARCHAR(512) DEFAULT '';
|
|
DECLARE index_prefix_count INT DEFAULT 0;
|
|
DECLARE index_type_count INT DEFAULT 0;
|
|
DECLARE index_type_name VARCHAR(32) DEFAULT '';
|
|
DECLARE generated_extra VARCHAR(255) DEFAULT '';
|
|
DECLARE generated_expression TEXT;
|
|
DECLARE normalized_generation_expression TEXT;
|
|
DECLARE generated_data_type VARCHAR(64) DEFAULT '';
|
|
DECLARE generated_length BIGINT DEFAULT 0;
|
|
DECLARE generated_nullable VARCHAR(3) DEFAULT '';
|
|
DECLARE exact_freight_unique_indexes INT DEFAULT 0;
|
|
|
|
SELECT COUNT(*) INTO duplicate_rows
|
|
FROM (
|
|
SELECT tenant_no, freight_no
|
|
FROM biz_sample_freight
|
|
GROUP BY tenant_no, freight_no
|
|
HAVING COUNT(*) > 1
|
|
) duplicate_freights;
|
|
IF duplicate_rows > 0 THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'duplicate freight numbers found; reconcile them before rerunning migration';
|
|
END IF;
|
|
|
|
SELECT COUNT(*) INTO duplicate_rows
|
|
FROM (
|
|
SELECT tenant_no, sample_source, sample_id
|
|
FROM biz_sample_freight_item
|
|
WHERE del_flag = 0
|
|
GROUP BY tenant_no, sample_source, sample_id
|
|
HAVING COUNT(*) > 1
|
|
) duplicate_active_links;
|
|
IF duplicate_rows > 0 THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'duplicate active sample freight links found; reconcile them before rerunning migration';
|
|
END IF;
|
|
|
|
SELECT COUNT(*) INTO object_count
|
|
FROM information_schema.COLUMNS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight_item'
|
|
AND COLUMN_NAME = 'active_sample_key';
|
|
IF object_count = 0 THEN
|
|
ALTER TABLE biz_sample_freight_item
|
|
ADD COLUMN active_sample_key VARCHAR(170)
|
|
GENERATED ALWAYS AS (
|
|
IF(del_flag = 0, CONCAT(tenant_no, '#', sample_source, '#', sample_id), NULL)
|
|
) STORED;
|
|
ELSE
|
|
SELECT EXTRA, GENERATION_EXPRESSION, DATA_TYPE,
|
|
CHARACTER_MAXIMUM_LENGTH, IS_NULLABLE
|
|
INTO generated_extra, generated_expression, generated_data_type,
|
|
generated_length, generated_nullable
|
|
FROM information_schema.COLUMNS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight_item'
|
|
AND COLUMN_NAME = 'active_sample_key';
|
|
SET normalized_generation_expression = LOWER(
|
|
REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(
|
|
COALESCE(generated_expression, ''),
|
|
'`', ''), ' ', ''), CHAR(9), ''), CHAR(10), ''), '(', ''), ')', '')
|
|
);
|
|
IF UPPER(COALESCE(generated_extra, '')) NOT LIKE '%STORED GENERATED%'
|
|
OR LOWER(COALESCE(generated_data_type, '')) <> 'varchar'
|
|
OR COALESCE(generated_length, 0) <> 170
|
|
OR UPPER(COALESCE(generated_nullable, '')) <> 'YES'
|
|
OR normalized_generation_expression <>
|
|
'ifdel_flag=0,concattenant_no,''#'',sample_source,''#'',sample_id,null' THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'wrong active_sample_key type/expression; drop column and dependent index, then rerun migration';
|
|
END IF;
|
|
END IF;
|
|
|
|
SELECT COUNT(*), COALESCE(MIN(NON_UNIQUE), 1),
|
|
COALESCE(GROUP_CONCAT(COLUMN_NAME ORDER BY SEQ_IN_INDEX SEPARATOR ','), ''),
|
|
SUM(CASE WHEN SUB_PART IS NOT NULL THEN 1 ELSE 0 END),
|
|
COUNT(DISTINCT INDEX_TYPE), COALESCE(MIN(INDEX_TYPE), '')
|
|
INTO object_count, index_non_unique, index_columns,
|
|
index_prefix_count, index_type_count, index_type_name
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight_item'
|
|
AND INDEX_NAME = 'uk_bsfi_active_sample';
|
|
IF object_count = 0 THEN
|
|
ALTER TABLE biz_sample_freight_item
|
|
ADD UNIQUE INDEX uk_bsfi_active_sample (active_sample_key);
|
|
ELSEIF object_count <> 1 OR index_non_unique <> 0
|
|
OR index_columns <> 'active_sample_key' OR index_prefix_count <> 0
|
|
OR index_type_count <> 1 OR index_type_name <> 'BTREE' THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'wrong index uk_bsfi_active_sample; drop it and rerun migration';
|
|
END IF;
|
|
|
|
-- 旧迁移已创建 uk_sample_freight_tenant_no；任何名称的等价精确唯一索引均复用。
|
|
-- 但若本迁移预留名称已存在且定义错误，必须先修复，不能静默绕过。
|
|
SELECT COUNT(*), COALESCE(MIN(NON_UNIQUE), 1),
|
|
COALESCE(GROUP_CONCAT(COLUMN_NAME ORDER BY SEQ_IN_INDEX SEPARATOR ','), ''),
|
|
SUM(CASE WHEN SUB_PART IS NOT NULL THEN 1 ELSE 0 END),
|
|
COUNT(DISTINCT INDEX_TYPE), COALESCE(MIN(INDEX_TYPE), '')
|
|
INTO object_count, index_non_unique, index_columns,
|
|
index_prefix_count, index_type_count, index_type_name
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight'
|
|
AND INDEX_NAME = 'uk_bsf_tenant_freight_no';
|
|
IF object_count > 0 AND (object_count <> 2 OR index_non_unique <> 0
|
|
OR index_columns <> 'tenant_no,freight_no' OR index_prefix_count <> 0
|
|
OR index_type_count <> 1 OR index_type_name <> 'BTREE') THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'wrong index uk_bsf_tenant_freight_no; drop it and rerun migration';
|
|
END IF;
|
|
|
|
SELECT COUNT(*) INTO exact_freight_unique_indexes
|
|
FROM (
|
|
SELECT INDEX_NAME
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight'
|
|
GROUP BY INDEX_NAME
|
|
HAVING MIN(NON_UNIQUE) = 0
|
|
AND MAX(NON_UNIQUE) = 0
|
|
AND GROUP_CONCAT(COLUMN_NAME ORDER BY SEQ_IN_INDEX SEPARATOR ',') =
|
|
'tenant_no,freight_no'
|
|
AND SUM(CASE WHEN SUB_PART IS NOT NULL THEN 1 ELSE 0 END) = 0
|
|
AND COUNT(DISTINCT INDEX_TYPE) = 1
|
|
AND MIN(INDEX_TYPE) = 'BTREE'
|
|
) exact_freight_unique_index_definitions;
|
|
IF exact_freight_unique_indexes = 0 THEN
|
|
ALTER TABLE biz_sample_freight
|
|
ADD UNIQUE INDEX uk_bsf_tenant_freight_no (tenant_no, freight_no);
|
|
END IF;
|
|
|
|
SELECT COUNT(*), COALESCE(MIN(NON_UNIQUE), 1),
|
|
COALESCE(GROUP_CONCAT(COLUMN_NAME ORDER BY SEQ_IN_INDEX SEPARATOR ','), ''),
|
|
SUM(CASE WHEN SUB_PART IS NOT NULL THEN 1 ELSE 0 END),
|
|
COUNT(DISTINCT INDEX_TYPE), COALESCE(MIN(INDEX_TYPE), '')
|
|
INTO object_count, index_non_unique, index_columns,
|
|
index_prefix_count, index_type_count, index_type_name
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight'
|
|
AND INDEX_NAME = 'idx_bsf_market_list';
|
|
IF object_count = 0 THEN
|
|
ALTER TABLE biz_sample_freight
|
|
ADD INDEX idx_bsf_market_list (tenant_no, del_flag, create_time, id);
|
|
ELSEIF object_count <> 4 OR index_non_unique <> 1
|
|
OR index_columns <> 'tenant_no,del_flag,create_time,id'
|
|
OR index_prefix_count <> 0 OR index_type_count <> 1
|
|
OR index_type_name <> 'BTREE' THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'wrong index idx_bsf_market_list; drop it and rerun migration';
|
|
END IF;
|
|
|
|
SELECT COUNT(*), COALESCE(MIN(NON_UNIQUE), 1),
|
|
COALESCE(GROUP_CONCAT(COLUMN_NAME ORDER BY SEQ_IN_INDEX SEPARATOR ','), ''),
|
|
SUM(CASE WHEN SUB_PART IS NOT NULL THEN 1 ELSE 0 END),
|
|
COUNT(DISTINCT INDEX_TYPE), COALESCE(MIN(INDEX_TYPE), '')
|
|
INTO object_count, index_non_unique, index_columns,
|
|
index_prefix_count, index_type_count, index_type_name
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = 'biz_sample_freight_item'
|
|
AND INDEX_NAME = 'idx_bsfi_market_batch';
|
|
IF object_count = 0 THEN
|
|
ALTER TABLE biz_sample_freight_item
|
|
ADD INDEX idx_bsfi_market_batch (tenant_no, freight_id, del_flag, create_time, id);
|
|
ELSEIF object_count <> 5 OR index_non_unique <> 1
|
|
OR index_columns <> 'tenant_no,freight_id,del_flag,create_time,id'
|
|
OR index_prefix_count <> 0 OR index_type_count <> 1
|
|
OR index_type_name <> 'BTREE' THEN
|
|
SIGNAL SQLSTATE '45000'
|
|
SET MESSAGE_TEXT = 'wrong index idx_bsfi_market_batch; drop it and rerun migration';
|
|
END IF;
|
|
END$$
|
|
|
|
CALL `ensure_market_freight_indexes`()$$
|
|
DROP PROCEDURE `ensure_market_freight_indexes`$$
|
|
|
|
DELIMITER ;
|