MySQL实现：存在指定Schema时才查询其中数据的方法

你之前的写法之所以报错，是因为MySQL在解析SQL语句阶段就会检查所有引用的表是否存在，不会等到执行阶段再判断WHERE EXISTS的条件。哪怕你加了存在性判断，只要目标表实际不存在，解析时就会直接抛出1146错误。

要实现"存在则查询，不存在则跳过"的逻辑，必须使用动态SQL——也就是在执行阶段才拼接并解析SQL语句，这样就能先判断对象是否存在，再决定是否包含对应的查询部分。

针对你给出的多Schema UNION ALL场景，推荐用存储过程来封装逻辑，具体代码如下：

DELIMITER //
CREATE PROCEDURE GetMessages()
BEGIN
    DECLARE sql_query TEXT DEFAULT '';
    
    -- 检查第一个Schema下的表是否存在，存在则拼接查询语句
    IF EXISTS (SELECT 1 FROM information_schema.tables WHERE table_schema = 'my_schema_1' AND table_name = 'some_table') THEN
        SET sql_query = CONCAT(sql_query, 'SELECT message FROM my_schema_1.some_table');
    END IF;
    
    -- 检查第二个Schema
    IF EXISTS (SELECT 1 FROM information_schema.tables WHERE table_schema = 'my_schema_2' AND table_name = 'some_table') THEN
        SET sql_query = CONCAT(sql_query, IF(sql_query != '', ' UNION ALL ', ''), 'SELECT message FROM my_schema_2.some_table');
    END IF;
    
    -- 检查第三个Schema
    IF EXISTS (SELECT 1 FROM information_schema.tables WHERE table_schema = 'my_schema_3' AND table_name = 'some_table') THEN
        SET sql_query = CONCAT(sql_query, IF(sql_query != '', ' UNION ALL ', ''), 'SELECT message FROM my_schema_3.some_table');
    END IF;
    
    -- 如果有有效查询语句，执行并添加limit
    IF sql_query != '' THEN
        SET sql_query = CONCAT('SELECT * FROM (', sql_query, ') AS result LIMIT 1000');
        PREPARE stmt FROM sql_query;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
    ELSE
        -- 所有Schema下的表都不存在时，返回空结果集
        SELECT NULL AS message LIMIT 0;
    END IF;
END //
DELIMITER ;

使用方法 #

创建完存储过程后，直接调用即可获取结果：

CALL GetMessages();

补充说明 #

• 存储过程会逐个检查每个schema.table的存在性，只拼接存在的表的查询语句，避免了不存在对象导致的报错。
• 如果所有指定的表都不存在，会返回一个空的结果集（不会报错）。
• 这种方式完全在MySQL内部实现，不需要外部脚本介入。

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