调用command.ExecuteNonQueryAsync()报错：BeginExecuteNonQuery需命令关联事务

这个报错的核心逻辑是：你的数据库连接当前处于未提交/回滚的本地事务状态，但执行SqlCommand时没有将其绑定到该事务上。哪怕存储过程内部没显式声明事务，外部代码的操作也可能让连接遗留了未处理的事务上下文。

具体解决方案 #

• 显式绑定事务到Command（如果需要外部事务）
  如果业务需要在消息处理流程中保证数据一致性（比如和Service Bus消息的事务性接收联动），必须将命令关联到当前开启的事务：

  using (var connection = new SqlConnection(yourConnectionString))
  {
      await connection.OpenAsync();
      using (var transaction = await connection.BeginTransactionAsync())
      {
          try
          {
              using (var command = new SqlCommand("sp_FinanceSummaryAggregation", connection))
              {
                  command.CommandType = CommandType.StoredProcedure;
                  // 关键步骤：将命令绑定到当前事务
                  command.Transaction = transaction;
                  
                  await command.ExecuteNonQueryAsync();
                  await transaction.CommitAsync();
              }
          }
          catch (Exception)
          {
              await transaction.RollbackAsync();
              throw;
          }
      }
  }
  

• 使用全新连接避免事务残留
  如果业务不需要外部事务，检查是否之前的代码对同一个连接执行了事务操作但未完成提交/回滚。这种情况下，直接使用全新的数据库连接执行存储过程即可：

  using (var connection = new SqlConnection(yourConnectionString))
  {
      await connection.OpenAsync();
      using (var command = new SqlCommand("sp_FinanceSummaryAggregation", connection))
      {
          command.CommandType = CommandType.StoredProcedure;
          await command.ExecuteNonQueryAsync();
      }
  }
  

• 检查Service Bus处理器的事务配置
  由于函数由Azure Service Bus消息处理器触发，确认处理器是否开启了事务性消息接收。如果是，数据库连接会被自动纳入分布式事务上下文，此时必须将SqlCommand绑定到该事务，或者根据业务需求关闭处理器的事务性接收配置。

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