BigQuery：基于表存在性执行SQL及实现重试逻辑的语法错误问题求助

先来说你遇到的两个问题，逐个拆解解决：

一、修复语法错误 #

你的语句有几个明显的语法和逻辑问题，直接导致了"Expected ';' but got keyword END"错误：

1. 多余的THEN关键字：大多数SQL方言（比如SQL Server、PostgreSQL）的IF...ELSE结构不需要THEN；MySQL虽然用THEN，但需要配合BEGIN...END和分隔符调整。
2. 表名判断字段错误：你用了Table_Schema like 't1*'，但Table_Schema存储的是模式/架构名（比如SQL Server里的dbo，MySQL里的数据库名），要判断表t1是否存在，应该用TABLE_NAME字段。另外SQL的通配符是%而不是*，如果是精确匹配t1，直接用=更准确。
3. 缺少闭合的END块：IF语句需要用END（SQL Server）或END IF（MySQL）来闭合，这是你报错的直接原因。

针对不同数据库的修正示例： #

SQL Server

-- 假设你的表在dbo模式下，可根据实际情况修改TABLE_SCHEMA
IF EXISTS (SELECT * FROM d.INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 't1' AND TABLE_SCHEMA = 'dbo')
BEGIN
    -- 这里写你要执行的SQL命令，比如：
    SELECT * FROM t1;
END
ELSE
BEGIN
    PRINT '表t1不存在，无法执行操作';
END

MySQL

DELIMITER // -- 临时修改分隔符，避免与语句中的;冲突
IF EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'd' AND TABLE_NAME = 't1') THEN
    -- 你的SQL命令
    INSERT INTO target_table SELECT * FROM t1;
ELSE
    SELECT '表t1不存在，无法执行操作' AS message;
END IF //
DELIMITER ; -- 恢复默认分隔符

二、实现"停止查询并1小时后重复"的功能 #

很遗憾，纯SQL语句无法实现暂停1小时再重试的逻辑——SQL是一次性执行的查询语言，没有内置的休眠/定时重试机制。要实现这个需求，有两种靠谱的方案：

方案1：利用数据库内置的调度任务 #

主流数据库都提供了定时任务功能，你可以创建一个每小时执行一次的任务，任务逻辑是先检查表t1是否存在，存在就执行你的SQL，不存在就跳过（等下一次调度）。

示例：MySQL事件调度器

-- 先开启事件调度器（需要权限）
SET GLOBAL event_scheduler = ON;

-- 创建定时事件，每小时执行一次
CREATE EVENT check_t1_and_run
ON SCHEDULE EVERY 1 HOUR
STARTS CURRENT_TIMESTAMP
DO
BEGIN
    IF EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'd' AND TABLE_NAME = 't1') THEN
        -- 执行你的SQL命令
        UPDATE some_table SET status = 'processed' WHERE id IN (SELECT id FROM t1);
        -- 如果只需要执行一次，执行完可以禁用事件
        ALTER EVENT check_t1_and_run DISABLE;
    END IF;
END;

示例：SQL Server Agent作业

1. 打开SQL Server Management Studio，创建一个新作业
2. 添加一个作业步骤，写入前面修正后的IF EXISTS检查逻辑
3. 设置作业计划为每小时执行一次
4. 保存作业后，它会自动按计划执行，直到表t1存在并完成操作

方案2：用外部脚本实现循环重试 #

你可以用Python、PowerShell、Shell脚本等写一个简单的循环，每次检查数据库表是否存在，存在就执行SQL，不存在就休眠1小时再重试。

Python示例（用pyodbc连接SQL Server）

import time
import pyodbc

# 数据库连接字符串，根据你的数据库类型调整
conn_str = "DRIVER={SQL Server};SERVER=your_server;DATABASE=d;UID=your_user;PWD=your_pwd"

def execute_task():
    try:
        conn = pyodbc.connect(conn_str)
        cursor = conn.cursor()
        
        # 检查表是否存在
        cursor.execute("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 't1' AND TABLE_SCHEMA = 'dbo'")
        table_exists = cursor.fetchone()[0] > 0
        
        if table_exists:
            # 执行你的SQL命令
            cursor.execute("INSERT INTO archive_table SELECT * FROM t1")
            conn.commit()
            print("任务执行成功，退出循环")
            conn.close()
            return True
        else:
            print("表t1不存在，1小时后重试...")
            conn.close()
            return False
    except Exception as e:
        print(f"出错了：{str(e)}")
        conn.close()
        return False

# 循环重试直到任务完成
while True:
    if execute_task():
        break
    time.sleep(3600)  # 休眠1小时（3600秒）

总结 #

• 语法错误通过修正IF结构的语法、调整表存在性判断的字段即可解决
• 定时重试需要依赖数据库调度任务或外部脚本，纯SQL做不到这个功能

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