在 Azure Synapse Analytics 中将事务与专用 SQL 池配合使用

在 Azure Synapse Analytics 中使用专用 SQL 池实现事务以开发解决方案的技巧。

期望

如你所料，专用 SQL 池支持将事务作为数据仓库工作负载的一部分。 但是，为了确保大规模保持专用 SQL 池的性能，与 SQL Server 相比，某些功能受到限制。 本文将突出两者的差异，并列出其他信息。

事务隔离级别

专用 SQL 池实现了 ACID 事务。 事务支持的隔离级别默认为 READ UNCOMMITTED。 你可以通过在连接到主数据库时为用户数据库打开 READ_COMMITTED_SNAPSHOT 数据库选项，将默认的隔离级别更改为 READ COMMITTED SNAPSHOT ISOLATION。

启用后，此数据库中的所有事务都将在 READ COMMITTED SNAPSHOT ISOLATION 下执行，并且将不接受在会话级别设置 READ UNCOMMITTED。 有关详细信息，请查看 ALTER DATABASE SET 选项 (Transact-SQL)。

事务大小

单个数据修改事务有大小限制。 限制按每个分发进行应用。 这样，通过将限制乘以分发数，可得总分配额。

要预计事务中的最大行数，请将分发上限除以每一行的总大小。 对于可变长度列，考虑采用平均的列长度而不使用最大大小。

下表中进行了以下假设：

• 出现平均数据分布
• 平均行长度为 250 个字节

Gen2

Gen1

事务大小限制按每个事务或操作进行应用。 不会跨所有当前事务进行应用。 因此，允许每个事务向日志写入此数量的数据。

为优化并最大程度地减少写入到日志中的数据量，请参阅事务最佳做法一文。

事务状态

专用 SQL 池使用 XACT_STATE() 函数（采用值 -2）来报告失败的事务。 此值表示事务已失败并标记为仅可回滚。

例如，在 SQL Server 中，可能会看到如下所示的事务：

SET NOCOUNT ON;
DECLARE @xact_state smallint = 0;

BEGIN TRAN
    BEGIN TRY
        DECLARE @i INT;
        SET     @i = CONVERT(INT,'ABC');
    END TRY
    BEGIN CATCH
        SET @xact_state = XACT_STATE();

        SELECT  ERROR_NUMBER()    AS ErrNumber
        ,       ERROR_SEVERITY()  AS ErrSeverity
        ,       ERROR_STATE()     AS ErrState
        ,       ERROR_PROCEDURE() AS ErrProcedure
        ,       ERROR_MESSAGE()   AS ErrMessage
        ;

        IF @@TRANCOUNT > 0
        BEGIN
            ROLLBACK TRAN;
            PRINT 'ROLLBACK';
        END

    END CATCH;

IF @@TRANCOUNT >0
BEGIN
    PRINT 'COMMIT';
    COMMIT TRAN;
END

SELECT @xact_state AS TransactionState;

前面的代码提供以下错误消息：

Msg 111233, Level 16, State 1, Line 1 111233；当前事务已中止，所有挂起的更改都已回退。 原因：仅回退状态的事务未在 DDL、DML 或 SELECT 语句之前显式回退。

不会获得 ERROR_* 函数的输出值。

在专用 SQL 池中，该代码需要稍做更改：

SET NOCOUNT ON;
DECLARE @xact_state smallint = 0;

BEGIN TRAN
    BEGIN TRY
        DECLARE @i INT;
        SET     @i = CONVERT(INT,'ABC');
    END TRY
    BEGIN CATCH
        SET @xact_state = XACT_STATE();

        IF @@TRANCOUNT > 0
        BEGIN
            ROLLBACK TRAN;
            PRINT 'ROLLBACK';
        END

        SELECT  ERROR_NUMBER()    AS ErrNumber
        ,       ERROR_SEVERITY()  AS ErrSeverity
        ,       ERROR_STATE()     AS ErrState
        ,       ERROR_PROCEDURE() AS ErrProcedure
        ,       ERROR_MESSAGE()   AS ErrMessage
        ;
    END CATCH;

IF @@TRANCOUNT >0
BEGIN
    PRINT 'COMMIT';
    COMMIT TRAN;
END

SELECT @xact_state AS TransactionState;

现在观察到了预期行为。 事务中的错误得到了管理，并且 ERROR_* 函数提供了预期值。

所做的一切改变是事务的 ROLLBACK 必须发生于在 CATCH 块中读取错误信息之前。

Error_Line() 函数

另外值得注意的是，专用 SQL 池未实现或不支持 ERROR_LINE() 函数。 如果代码中包含此函数，则需要将它删除才能符合专用 SQL 池的要求。 请在代码中使用查询标签，而不是实现等效的功能。 有关详细信息，请参阅 LABEL 一文。

THROW 和 RAISERROR 的使用

THROW 是在专用 SQL 池中引发异常的新式做法，但也支持 RAISERROR。 不过，有些值得注意的差异。

• 对于 THROW，用户定义的错误消息数目不能在 100,000 - 150,000 范围内
• RAISERROR 错误消息固定为 50,000
• 不支持 sys.messages

限制

专用 SQL 池有一些与事务相关的其他限制。 这些限制如下：

• 无分布式事务
• 不允许嵌套事务
• 不允许保存点
• 无已命名事务
• 无已标记事务
• 不支持 DDL，例如用户定义的事务内的 CREATE TABLE

后续步骤

若要了解有关优化事务的详细信息，请参阅事务最佳做法。 还为专用 SQL 池和无服务器 SQL 池提供了其他最佳做法指南。