新手求助：如何创建存储过程批量生成DELETE语句删除指定数据

针对你的需求，核心思路是动态SQL——因为表名是运行时确定的，没法直接写在静态DELETE语句里。下面以SQL Server为例给出实现方案，最后补充MySQL的差异写法。

步骤1：拼接Request_ID列表 #

先把query_2返回的request_id合并成一个逗号分隔的字符串，方便后续在IN子句中使用：

DECLARE @request_ids NVARCHAR(MAX);
SELECT @request_ids = STRING_AGG(request_id, ',') FROM (
    -- 这里替换成你的query_2
    SELECT 15 AS request_id UNION ALL SELECT 23 UNION ALL SELECT 33
) AS q2;

如果是SQL Server 2016之前的版本，没有STRING_AGG函数，就用FOR XML PATH方式拼接：

DECLARE @request_ids NVARCHAR(MAX);
SELECT @request_ids = STUFF((
    SELECT ',' + CAST(request_id AS NVARCHAR) 
    FROM (
        -- 替换为你的query_2
        SELECT 15 AS request_id UNION ALL SELECT 23 UNION ALL SELECT 33
    ) AS q2
    FOR XML PATH('')), 1, 1, '');

步骤2：遍历表名生成并执行DELETE语句 #

用游标遍历query_1返回的表名，逐个生成动态DELETE语句并执行：

DECLARE @table_name NVARCHAR(128);
DECLARE table_cursor CURSOR FOR
    -- 替换为你的query_1
    SELECT 'Table_1' AS table_name UNION ALL SELECT 'Table_2' UNION ALL SELECT 'Table_3';

OPEN table_cursor;
FETCH NEXT FROM table_cursor INTO @table_name;

WHILE @@FETCH_STATUS = 0
BEGIN
    -- 拼接动态DELETE语句，用QUOTENAME防护非法表名
    DECLARE @sql NVARCHAR(MAX);
    SET @sql = N'DELETE ' + QUOTENAME(@table_name) + N' WHERE request_id IN (' + @request_ids + N');';
    
    -- 测试阶段先PRINT验证语句正确性，确认后再改成EXEC执行
    PRINT @sql;
    -- EXEC sp_executesql @sql;

    FETCH NEXT FROM table_cursor INTO @table_name;
END

CLOSE table_cursor;
DEALLOCATE table_cursor;

关键注意事项 #

• SQL注入防护：必须用QUOTENAME()包裹表名，既能处理含特殊字符的表名，也能避免恶意注入风险。
• 事务控制：如果需要确保所有表的删除操作要么全部成功要么全部回滚，可在存储过程开头加BEGIN TRANSACTION，结尾加COMMIT，出错时执行ROLLBACK。
• 数据安全：测试阶段一定要先通过PRINT输出动态SQL，确认语句符合预期后再执行EXEC，避免误删数据。

MySQL版本差异 #

如果使用MySQL环境，拼接字符串用GROUP_CONCAT，执行动态SQL用PREPARE+EXECUTE组合：

DELIMITER //
CREATE PROCEDURE batch_delete()
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE table_name VARCHAR(128);
    DECLARE request_ids VARCHAR(1000);
    
    -- 获取request_id列表
    SELECT GROUP_CONCAT(request_id) INTO request_ids FROM (
        -- 替换为你的query_2
        SELECT 15 AS request_id UNION ALL SELECT 23 UNION ALL SELECT 33
    ) q2;
    
    -- 声明游标遍历表名
    DECLARE table_cursor CURSOR FOR
        -- 替换为你的query_1
        SELECT 'Table_1' UNION ALL SELECT 'Table_2' UNION ALL SELECT 'Table_3';
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
    
    OPEN table_cursor;
    read_loop: LOOP
        FETCH table_cursor INTO table_name;
        IF done THEN
            LEAVE read_loop;
        END IF;
        
        -- 拼接并执行动态SQL
        SET @sql = CONCAT('DELETE FROM ', table_name, ' WHERE request_id IN (', request_ids, ');');
        PREPARE stmt FROM @sql;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
    END LOOP;
    
    CLOSE table_cursor;
END //
DELIMITER ;

内容的提问来源于stack exchange，提问作者Spk