0

我需要将数据从外部源导入到我的数据库。因为要下载的数据很多，导入执行的时间很长，我需要将当前导入状态的定期更新持久化到数据库中（供用户关注）。

假设我有 2 个表：（Import导入数据的存储）和Status（导入状态监控表）。

数据导入代码：

public class Importer
{
    public delegate void ImportHandler(string item);
    public event ImportHandler ImportStarted;

    public void OnStart(string item)
    {            
        ImportStarted(item);
    }

    public void Execute(string[] items)
    {
        foreach (var item  in items)
        {
            OnStart(item);                    
            PersistImportedData(Download(item));
        }
    }

    private void PersistImportedData(object data)
    {
        using (var connection = new SqlConnection()){ /*saving imported data*/ }
    }
}

启动代码 - 用于调用导入任务并更新其状态：

public class Starter
{
    public void Process(string[] items)
    {
       var importer = new Importer();
       importer.ImportStarted += UpdateImportState;
       importer.Execute(items);
    }

    private void UpdateImportState(string item)
    {
        using (var connection = new SqlConnection()){ /*status updates*/ }
    }
}

现在一切正常。随着导入的进行，导入正在执行，用户正在获取状态更新（从Status表中）。

出现问题是因为这样的逻辑不安全。我必须确定，导入是一个原子操作。我不想部分下载和保存数据。我已经使用事务方法作为解决方案（我已经用 包裹importer.Execute）TransactionScope：

importer.ImportStarted += UpdateImportState;
using (var scope = new TransactionScope())
{
    importer.Execute(items);
    scope.Complete();
}

现在我有了安全性——例如在进程中止的情况下会发生回滚。

我现在面临不同的问题 - 我想要解决的问题。我需要状态更新信息供用户显示，但Status表不受更新影响，而事务尚未完成。即使我尝试使用RequiresNew选项来创建单独的事务（不是环境事务），也没有任何变化。该Execute函数创建自己的数据库连接并UpdateImportState执行相同的操作。连接不共享。我不知道为什么Statetable 不会受到影响，即使TransactionScope只涵盖与Importtable 连接的逻辑。

如何保持一致的导入并允许定期状态更新？

4

1 回答 1

0

在 UpdateImportState 中使用 TransactionScopeOption.Suppress 而不是 TransactionScopeOption.RequiresNew

于 2013-01-12T14:01:11.263 回答