任务、TransactionScope 和 SQL Server 存储过程

Question

我必须更新一些以 XML 形式发送数据的 DataTable。我的存储过程有事务，可以在出现问题时中止操作。但我要更新的记录数量相当大，XML 达到 35 mb+。它正处于开发阶段，实时数据将会更大。

为了处理这个问题，我想通过分块发送数据来进行更新，也就是说，我将一次发送数百条记录的 XML。我尝试使用 Task 库像这样并行更新数据库。

var ret=0;
using(var ts = new TransactionScope(TransactionScopeOption.Required,
                                                      new TimeSpan(2,0,0))
{
    try
    {
        for(some condition)
        {
            get chunk of records
            generate xml
            create new task and call routing to push data to db
            var t = create new task and call routing to push data to db
            tasks.Add(t);
        }

        Task.WaitAll(tasks.ToArray());
        ts.Complete();
        foreach(var t in tasks)
            ret += t.Result;
    }
    catch(Exception ex)
    {
        //log exception and show user message
    }
}
return ret;

但我收到交易已被中止的异常。

我必须做些什么才能在单个事务中完成更新，因为如果任何块无法正确更新，我必须回滚任何更改。

编辑：- 我按照 Reed Copsey 的建议使用 new TransactionScope(TransactionScopeOption.Required,new TimeSpan(2,0,0)) 但仍然收到错误 System.Transactions。 TransactionAbortedException：事务已中止。 ---> System.TimeoutException：即使对数据库的一次调用在 2-3 秒内完成，事务也会超时。

仅用于一次通话

Answer 1

您需要等到任务完成后再调用ts.Complete()。这应该看起来更像：

using(var ts = new TransactionScope())
{
    try
    {
        List<Task> tasks = new List<Task>();

        for(some condition)
        {
            // get chunk of records
            // generate xml
            // create new task and call routing to push data to db
            var task = PushDataAsync(theData); // make the task
            tasks.Add(task); // Keep a reference in a collection
        }

        // Wait until all tasks are done, so you can complete the transaction...
        // If any task raises an exception, you'll get an AggregateException here
        Task.WaitAll(tasks.ToArray());

        ts.Complete();
    }
    catch(Exception ex)
    {
        //log exception and show user message
    }
}

Answer 2

您考虑过线程安全吗？我想知道 PushDataAsync 里面有什么。

TransactionScope 不能立即跨线程工作。它在内部使用线程本地存储。文档中明确指出了作用域属于单个线程的事实。

不确定您是否真的朝着正确的方向前进，但如果您想跨多个线程协调事务，请查看 DependentTransaction： http://msdn.microsoft.com/en-us/library/system.transactions.dependenttransaction.aspx