JayDeBeApi连接SQL Server执行脚本未捕获重复键插入错误

我之前也踩过这个坑，JayDeBeApi结合SQL Server JDBC驱动时，批处理中间的运行时错误不会主动触发Python的异常，得靠我们主动去捕获或者调整执行方式。给你几个可行的方案：

1. 主动检查游标中的错误消息 #

SQL Server的JDBC驱动会把执行过程中的警告和错误存在游标messages属性里（你可以先打印dir(localCursor)确认属性名）。我们可以在execute()之后主动检查这个属性，如果有错误级别（SQL Server中16及以上为错误）的消息，就主动抛出异常：

try:
    localCursor = dbConnection.cursor()
    x = localCursor.execute(query)
    
    # 主动检查执行过程中的错误
    if hasattr(localCursor, 'messages') and localCursor.messages:
        for msg in localCursor.messages:
            # msg通常是元组，格式为(错误级别, 错误消息, ...)
            error_level = msg[0]
            error_msg = msg[1]
            if error_level >= 16:
                raise Exception(f"SQL执行错误: {error_msg}")
    
    logInfo("Run script %s... done" % (scriptNameAndPath), "run script", diagnosticLog)
except Exception as e:
    logError("Error running sql statement " + scriptNameAndPath + ". Skipping rest of row.", "run script", e, diagnosticLog)
    myrow = skipRowAndLogRecord(startRowTime, cursor, recordLog)
    continue

2. 在SQL脚本中加入TRY...CATCH块 #

直接在SQL层面捕获错误，并用THROW抛出，这样JayDeBeApi就能捕获到异常，同时还能终止后续语句的执行（避免临时表被误删）：

BEGIN TRY
    SELECT ... INTO #a-temp-table;
    DELETE FROM a-table;
    INSERT INTO a-table SELECT * FROM #a-temp-table;
    DROP TABLE #a-temp-table; -- 修正：删除临时表用DROP而非DELETE
END TRY
BEGIN CATCH
    -- 抛出捕获到的错误，让Python端能捕获
    THROW;
    -- 如果需要保留临时表用于排查，可以注释掉下面的语句
    IF OBJECT_ID('tempdb..#a-temp-table') IS NOT NULL
        DROP TABLE #a-temp-table;
END CATCH

这样一旦步骤3出错，THROW会立即终止批处理，后续的DROP TABLE不会执行，也能让Python捕获到明确的错误信息。

3. 拆分语句单独执行 #

把原来的批处理拆分成多个独立的execute()调用，这样每个步骤的错误都会立即触发Python的异常捕获，还能精准定位出错的步骤：

try:
    localCursor = dbConnection.cursor()
    
    # 步骤1：创建临时表
    localCursor.execute("SELECT ... INTO #a-temp-table")
    # 步骤2：清空原表
    localCursor.execute("DELETE FROM a-table")
    # 步骤3：插入数据
    localCursor.execute("INSERT INTO a-table SELECT * FROM #a-temp-table")
    # 步骤4：删除临时表
    localCursor.execute("DROP TABLE #a-temp-table")
    
    logInfo("Run script %s... done" % (scriptNameAndPath), "run script", diagnosticLog)
except Exception as e:
    logError("Error running sql statement " + scriptNameAndPath + ". Skipping rest of row.", "run script", e, diagnosticLog)
    # 可选：出错时手动清理临时表，或者保留用于排查
    # try:
    #     localCursor.execute("DROP TABLE #a-temp-table")
    # except:
    #     pass
    myrow = skipRowAndLogRecord(startRowTime, cursor, recordLog)
    continue

这种方式的优势是逻辑清晰，出错时能立刻知道是哪一步出了问题，排查也更方便。

为什么原来的代码没捕获到错误？ #

这是因为SQL Server的JDBC驱动在执行多语句批处理时，默认会继续执行后续语句，即使前面的语句出错。而JayDeBeApi的execute()方法只有在整个批处理无法启动（比如语法错误）时才会抛出异常，批处理中间的运行时错误不会主动触发Python的异常，必须我们主动去检查或者通过SQL层面的捕获来主动抛出。

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