事务计数与分层事务不匹配

Question

我有一组需要作为事务运行的存储过程（它们每个都是独立的事务）。我正在使用事务范围对象作为它的全部或全部任务。在第一个 ExecuteNonQuery 运行后，虽然我得到 SQLException “EXECUTE 后的事务计数表明 BEGIN 和 COMMIT 语句的数量不匹配。以前的计数 = 1，当前计数 = 0”。在不包含在事务范围内的情况下运行该过程可以正常工作，并且我没有收到上述错误，但我需要确保所有这些都运行完成而没有错误，或者所有这些都需要回滚。

public static void ImportHedges(DataTable hedges, string fileName, string importedBy)
    {
        try
        {
            using (TransactionScope ts = new TransactionScope())
            {

                using (SqlConnection connection = new SqlConnection(ConfigurationManager.ConnectionStrings["Energy"].ConnectionString))
                {
                    connection.Open();

                    SqlCommand newContractsCommand = new SqlCommand("SP_ImportNewContracts", connection);
                    newContractsCommand.CommandType = CommandType.StoredProcedure;
                    newContractsCommand.Parameters.Add("@ImportedBy", SqlDbType.NVarChar).Value = importedBy;
                    newContractsCommand.Parameters.Add("@FileName", SqlDbType.NVarChar).Value = fileName;

                    DataTable newContracts = hedges.AsEnumerable().Where(i => i["ContractStatus"].ToString() == "New").CopyToDataTable();
                    SqlParameter newContractsParameter = newContractsCommand.Parameters.AddWithValue("@Hedges", newContracts);
                    newContractsParameter.SqlDbType = SqlDbType.Structured;
                    newContractsParameter.TypeName = "dbo.Hedges";

                    SqlCommand renewContractsCommand = new SqlCommand("SP_ImportRenewContracts", connection);
                    renewContractsCommand.CommandType = CommandType.StoredProcedure;
                    renewContractsCommand.Parameters.Add("@ImportedBy", SqlDbType.NVarChar).Value = importedBy;
                    renewContractsCommand.Parameters.Add("@FileName", SqlDbType.NVarChar).Value = fileName;

                    DataTable renewContracts = hedges.AsEnumerable().Where(i => i["ContractStatus"].ToString() == "Renew").CopyToDataTable();
                    SqlParameter renewContractsParameter = newContractsCommand.Parameters.AddWithValue("@Hedges", renewContracts);
                    renewContractsParameter.SqlDbType = SqlDbType.Structured;
                    renewContractsParameter.TypeName = "dbo.Hedges";

                    SqlCommand amendContractsCommand = new SqlCommand("SP_ImportAmendContracts", connection);
                    amendContractsCommand.CommandType = CommandType.StoredProcedure;
                    amendContractsCommand.Parameters.Add("@ImportedBy", SqlDbType.NVarChar).Value = importedBy;
                    amendContractsCommand.Parameters.Add("@FileName", SqlDbType.NVarChar).Value = fileName;

                    DataTable amendContracts = hedges.AsEnumerable().Where(i => i["ContractStatus"].ToString() == "Amend").CopyToDataTable();
                    SqlParameter amendContractsParameter = newContractsCommand.Parameters.AddWithValue("@Hedges", amendContracts);
                    amendContractsParameter.SqlDbType = SqlDbType.Structured;
                    amendContractsParameter.TypeName = "dbo.Hedges";

                    SqlCommand fixedContractsCommand = new SqlCommand("SP_ImportFixedContracts", connection);
                    fixedContractsCommand.CommandType = CommandType.StoredProcedure;
                    fixedContractsCommand.Parameters.Add("@ImportedBy", SqlDbType.NVarChar).Value = importedBy;
                    fixedContractsCommand.Parameters.Add("@FileName", SqlDbType.NVarChar).Value = fileName;

                    DataTable fixedContracts = hedges.AsEnumerable().Where(i => i["ContractStatus"].ToString() == "Fixed").CopyToDataTable();
                    SqlParameter fixedContractsParameter = newContractsCommand.Parameters.AddWithValue("@Hedges", fixedContracts);
                    fixedContractsParameter.SqlDbType = SqlDbType.Structured;
                    fixedContractsParameter.TypeName = "dbo.Hedges";

                    newContractsCommand.ExecuteNonQuery();
                    renewContractsCommand.ExecuteNonQuery();
                    amendContractsCommand.ExecuteNonQuery();
                    fixedContractsCommand.ExecuteNonQuery();

                    connection.Close();
                }

                ts.Complete();
            }
        }

        catch (Exception Ex)
        {
            Email.SendEmail("Error in: Energy at " + DateTime.Now.ToString() + " - " + Thread.CurrentPrincipal.Identity.Name, Ex.Message + Environment.NewLine + Ex.StackTrace);
        }


    }





ALTER PROCEDURE [dbo].[SP_ImportNewContracts]
@FileName       NVARCHAR(100),
@ImportedBy     NVARCHAR(20),
@Hedges         dbo.Hedges READONLY
AS

BEGIN TRY

INSERT INTO ClientRetailers (ClientID, RetailerID, StartDate, EndDate, EnergyType,        ContractStatus)
SELECT DISTINCT (SELECT ClientID FROM Clients WHERE CustomerNumber = H.CustomerNumber),(SELECT RetailerID FROM Retailers WHERE RetailerName = H.Retailer),
RetailerStartDate, RetailerEndDate, EnergyType, ContractStatus
FROM @Hedges H
WHERE NOT EXISTS (SELECT ClientRetailersID FROM ClientRetailers WHERE ClientID = (SELECT ClientID FROM Clients WHERE CustomerNumber = H.CustomerNumber) AND
RetailerID = (SELECT RetailerID FROM Retailers WHERE RetailerName = H.Retailer) AND EnergyType = H.EnergyType) 

INSERT INTO ClientRetailerProducts (ClientRetailersID, ProductID, StartDate, EndDate,     ProductPercentage)
SELECT DISTINCT (SELECT TOP(1) ClientRetailersID FROM ClientRetailers WHERE ClientID =     (SELECT TOP(1) ClientID FROM Clients WHERE CustomerNumber = H.CustomerNumber) AND
RetailerID = (SELECT TOP(1) RetailerID FROM Retailers WHERE RetailerName = H.Retailer)     AND EnergyType = H.EnergyType),
(SELECT ProductID FROM Products WHERE ProductName = H.HedgeType), ProductStartDate,     ProductEndDate, ProductPercentage
FROM @Hedges H
WHERE NOT EXISTS (SELECT TOP(1) ClientRetailersID FROM ClientRetailerProducts WHERE     ProductID = (SELECT TOP(1) ProductID FROM Products WHERE ProductName = H.HedgeType)
AND ClientRetailersID = (SELECT TOP(1) ClientRetailersID FROM ClientRetailers WHERE     ClientID = (SELECT TOP(1) ClientID FROM Clients WHERE CustomerNumber = H.CustomerNumber)     AND
RetailerID = (SELECT TOP(1) RetailerID FROM Retailers WHERE RetailerName = H.Retailer)     AND EnergyType = H.EnergyType))

INSERT INTO Files (FileName, ImportDate, ImportedBy)
VALUES (@FileName, GETDATE(), @ImportedBy)


DECLARE @FileID INT = SCOPE_IDENTITY()

INSERT INTO Hedge (ClientRetailersID, ProductID, FixedPricePerUnit, Year, January, February, March, April,
                May, June, July, August, September, October, November, December, FileID)
SELECT  (SELECT TOP(1) ClientRetailersID FROM ClientRetailers WHERE ClientID = (SELECT TOP(1) ClientID FROM Clients WHERE CustomerNumber = H.CustomerNumber) AND
        RetailerID = (SELECT TOP(1) RetailerID FROM Retailers WHERE RetailerName = H.Retailer) AND EnergyType = H.EnergyType), 
    (SELECT TOP(1) ProductID FROM Products WHERE ProductName = H.HedgeType), FixedPricePerUnit, Year, Jan, Feb, Mar, Apr, May, Jun, Jul, Aug, Sep, Oct, Nov, Dec, @FileID
FROM @Hedges H


COMMIT TRANSACTION

END TRY

BEGIN CATCH

IF @@TRANCOUNT > 0
    ROLLBACK TRANSACTION

END CATCH

其他三个存储过程遵循相同的事务结构。

Answer 1

您的存储过程中缺少BEGIN TRANSACTION