能否在单条MySQL SELECT语句中获取列类型并检查列值？

你的原查询报错的核心原因是：静态SQL无法将col.TABLE_NAME这类列值作为动态表名/列名解析，MySQL会把它当作字面量的表名（比如试图查找名为col.TABLE_NAME的表），自然触发权限错误。要同时从INFORMATION_SCHEMA获取元数据并检查列内容，必须使用动态SQL（结合存储过程或预处理语句）。

以下是具体的实现方案：

存储过程实现代码 #

通过存储过程遍历目标表的列，对每个符合varchar(5)条件的列，动态执行内容检查，最终生成SQLAlchemy列定义：

DELIMITER //

CREATE PROCEDURE GenerateAlchemyColumns(IN p_schema VARCHAR(64), IN p_table VARCHAR(64))
BEGIN
    DECLARE v_col_name VARCHAR(64);
    DECLARE v_data_type VARCHAR(64);
    DECLARE v_char_len INT;
    DECLARE v_is_bool INT DEFAULT 0;
    DECLARE done INT DEFAULT 0;
    
    -- 游标遍历目标表的所有列
    DECLARE col_cursor CURSOR FOR
        SELECT column_name, data_type, character_maximum_length
        FROM information_schema.columns
        WHERE table_schema = p_schema
          AND table_name = p_table
        ORDER BY ordinal_position;
    
    -- 游标结束处理
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
    
    -- 临时表存储生成的代码（可选，也可直接输出）
    DROP TEMPORARY TABLE IF EXISTS alchemy_columns;
    CREATE TEMPORARY TABLE alchemy_columns (definition TEXT);
    
    OPEN col_cursor;
    read_loop: LOOP
        FETCH col_cursor INTO v_col_name, v_data_type, v_char_len;
        IF done THEN
            LEAVE read_loop;
        END IF;
        
        SET v_is_bool = 0;
        
        -- 检查varchar(5)列的内容是否仅为True/False
        IF v_data_type = 'varchar' AND v_char_len = 5 THEN
            -- 动态拼接检查语句
            SET @check_sql = CONCAT(
                'SELECT COUNT(*) INTO @has_invalid ',
                'FROM `', p_schema, '`.`', p_table, '` ',
                'WHERE `', v_col_name, '` NOT IN ("True", "False") ',
                'OR `', v_col_name, '` IS NULL' -- 若允许NULL则删除此条件
            );
            PREPARE stmt FROM @check_sql;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
            
            -- 无无效值则标记为布尔列
            IF @has_invalid = 0 THEN
                SET v_is_bool = 1;
            END IF;
        END IF;
        
        -- 生成SQLAlchemy列定义
        SET @definition = CONCAT(
            'Column("', v_col_name, '", ',
            CASE
                WHEN v_data_type = 'int' THEN 'Integer'
                WHEN v_is_bool = 1 THEN 'BoolStoredAsVarchar'
                WHEN v_data_type = 'varchar' THEN CONCAT('String(', v_char_len, ')')
                ELSE v_data_type
            END,
            '),'
        );
        
        INSERT INTO alchemy_columns VALUES (@definition);
    END LOOP;
    
    CLOSE col_cursor;
    
    -- 输出最终结果
    SELECT definition AS alchemy FROM alchemy_columns;
END //

DELIMITER ;

使用方法 #

调用存储过程并传入目标库和表名：

CALL GenerateAlchemyColumns('my_schema', 'my_table');

关键说明 #

1. 动态SQL的必要性：只有动态SQL能在运行时解析表名和列名，静态SQL无法实现这种动态引用。
2. 反引号的作用：用反引号包裹表名和列名，避免因关键字冲突导致语法错误。
3. NULL处理：代码中默认将NULL视为无效值，若你的业务允许NULL作为布尔列的一部分，可删除OR ``, v_col_name, `` IS NULL这部分条件。
4. 权限要求：执行存储过程的用户需要具备：
   • 对information_schema.columns的查询权限
   • 对目标表的SELECT权限
   • 存储过程的执行权限

内容的提问来源于stack exchange，提问作者Freddy The Horse