如何在列数不同的SQL表中实现通用的event过滤函数？

问题核心 #

festivals表（5列）和concert表（6列）列数不一致，直接编写通用过滤逻辑时，因返回列数不匹配触发报错，常规别名统一列的方式无法适配任意列数的场景。

可行解决方案 #

1. 动态SQL拼接（适配任意列数） #

通过获取目标表的所有列名，动态拼接查询语句，彻底解决列数差异问题。以MySQL为例编写存储过程：

DELIMITER //
CREATE PROCEDURE FilterByEvent(IN tableName VARCHAR(255), IN eventValue VARCHAR(255))
BEGIN
    DECLARE cols VARCHAR(1000);
    -- 校验表名白名单，防止SQL注入
    IF tableName NOT IN ('festivals', 'concert') THEN
        SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '仅允许查询指定表';
    END IF;
    -- 获取目标表的所有列名
    SELECT GROUP_CONCAT(column_name SEPARATOR ', ') INTO cols
    FROM information_schema.columns
    WHERE table_schema = DATABASE() AND table_name = tableName;
    -- 拼接并执行动态SQL
    SET @sql = CONCAT('SELECT ', cols, ' FROM `', tableName, '` WHERE `event` = ?');
    PREPARE stmt FROM @sql;
    SET @event = eventValue;
    EXECUTE stmt USING @event;
    DEALLOCATE PREPARE stmt;
END //
DELIMITER ;

调用示例：

-- 查询festivals表中指定event的数据
CALL FilterByEvent('festivals', '夏日音乐节');
-- 查询concert表中指定event的数据
CALL FilterByEvent('concert', '摇滚演唱会');

2. 限定返回共同字段（业务允许时使用） #

如果业务不需要返回所有列，仅需两张表的共同字段，可直接指定这些字段实现通用过滤：

假设两张表共同字段为id, event, title, hold_date，编写函数：

CREATE FUNCTION FilterEventCommon(eventValue VARCHAR(255))
RETURNS TABLE
AS RETURN
(
    SELECT id, event, title, hold_date FROM festivals WHERE event = eventValue
    UNION ALL
    SELECT id, event, title, hold_date FROM concert WHERE event = eventValue
);

3. JSON格式统一返回（适配任意列数） #

将整行数据转为JSON格式返回，规避列数差异问题，以MySQL为例：

DELIMITER //
CREATE FUNCTION FilterEventAsJson(eventValue VARCHAR(255), tableName VARCHAR(255))
RETURNS JSON
BEGIN
    DECLARE result JSON;
    -- 表名校验
    IF tableName NOT IN ('festivals', 'concert') THEN
        SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '仅允许查询指定表';
    END IF;
    -- 拼接JSON_OBJECT语句，将每行转为JSON
    SET @sql = CONCAT('SELECT JSON_OBJECT(', 
        (SELECT GROUP_CONCAT('''', column_name, ''', `', column_name, '''') 
         FROM information_schema.columns 
         WHERE table_schema = DATABASE() AND table_name = tableName),
        ') FROM `', tableName, '` WHERE `event` = ?');
    PREPARE stmt FROM @sql;
    SET @event = eventValue;
    EXECUTE stmt INTO result USING @event;
    DEALLOCATE PREPARE stmt;
    RETURN result;
END //
DELIMITER ;

注意事项 #

• 动态SQL需添加表名白名单校验，避免SQL注入风险；
• 不同数据库的系统表语法不同：SQL Server用sys.columns，Oracle用all_tab_columns，需对应调整；
• 若使用函数而非存储过程，需注意部分数据库对函数内执行动态SQL的限制（比如MySQL函数默认不支持，需调整参数或改用存储过程）。

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