3

更新基于接受的答案：

bool success = false;
using (var bulkCopy = new SqlBulkCopy(connection)) //using!
{
    connection.Open();

    //explicit isolation level is best-practice
    using (var tran = connection.BeginTransaction(IsolationLevel.ReadCommitted))
    {
        bulkCopy.DestinationTableName = "table";
        bulkCopy.ColumnMappings...

        using (var dataReader = new ObjectDataReader<SomeObject>(paths))
        {            
            bulkCopy.WriteToServer(dataReader);
            success = true;
        }

        tran.Commit(); //commit, will not be called if exception escapes
    }
}
return success;

我将BulkCopy类用于大型插入，它工作正常。
执行WriteToServer并将数据保存到数据库后，
我不知道是否所有数据都已成功保存，所以我可以返回true/false，因为我需要全部保存或什么都不保存？

    var bulkCopy = new SqlBulkCopy(connection);

    bulkCopy.DestinationTableName = "table";

    bulkCopy.ColumnMappings...

    using (var dataReader = new ObjectDataReader<SomeObject>(paths))
    {
        try
        {
        bulkCopy.WriteToServer(dataReader);
        }
        catch(Exception ex){ ... }    
}
4

3 回答 3

4

如果调用WriteToServer无例外地完成，则所有行都已保存并位于磁盘上。这只是 SQL Server DML 的标准语义。批量复制没什么特别的。

像所有其他 DML 一样，SqlBulkCopy也是全有或全无。除非您配置了未配置的批量大小。

using (var bulkCopy = new SqlBulkCopy(connection)) //using!
{
    connection.Open();

    //explicit isolation level is best-practice
    using (var tran = connection.BeginTransaction(IsolationLevel.ReadCommitted))
    {
        bulkCopy.DestinationTableName = "table";
        bulkCopy.ColumnMappings...

        using (var dataReader = new ObjectDataReader<SomeObject>(paths))
        {
            //try
            //{
            bulkCopy.WriteToServer(dataReader, /*here you set some options*/);
            //}
            //catch(Exception ex){ ... } //you need no explicit try-catch here
        }

        tran.Commit(); //commit, will not be called if exception escapes
    }
}

我已经为您添加了符合最佳实践的示例代码。

于 2013-10-01T11:37:49.123 回答
1

除了查找/捕获方法引发的任何异常之外，没有直接的方法可以确定该过程是否成功完成WriteToServer()。

另一种方法可能是检查数据库中的记录数，然后在过程完成后检查记录数 - 不同之处在于插入的数量。将此值与要插入的记录数进行比较可以得出失败或成功的想法。但是，这并不是万无一失的，特别是如果有其他进程插入/删除记录。

但是，这些技术结合TransactionScope- http://msdn.microsoft.com/en-us/library/system.transactions.transactionscope.aspx - 或类似的东西应该可以满足您的要求。

编辑

默认情况下，每个插入操作都作为批处理处理；如果操作在特定批次中失败，则回滚该批次，而不是在其之前插入任何批次。

但是，如果将内部事务应用于批量操作，则任何行中的失败都可以回滚整个结果集。例如;

using (SqlBulkCopy bulkCopy =
   new SqlBulkCopy(connectionString, SqlBulkCopyOptions.KeepIdentity
                   | SqlBulkCopyOptions.UseInternalTransaction))
{
   bulkCopy.BatchSize = 10;
   bulkCopy.DestinationTableName = "dbo.BulkCopyDemoMatchingColumns";

   try
   {
      bulkCopy.WriteToServer(reader);
   }
   catch (Exception ex)
   {
      Console.WriteLine(ex.Message);
   }
   finally
   {
      bulkCopy.Close();
   }
}

上述任何操作中的错误都会导致整个操作回滚。在http://msdn.microsoft.com/en-us/library/tchktcdk.aspx上查看更多详细信息。

于 2013-10-01T11:21:16.503 回答
0

从这个函数的文档中，下面的代码片段建议你应该捕获任何抛出的异常，否则你可以认为操作是成功的。

using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionString))
{
     bulkCopy.DestinationTableName = "dbo.BulkCopyDemoMatchingColumns";
     try
     {
         // Write from the source to the destination.
         bulkCopy.WriteToServer(reader);
     }
     catch (Exception ex)
     {
         Console.WriteLine(ex.Message);
     }
     finally
     {
         // Close the SqlDataReader. The SqlBulkCopy 
         // object is automatically closed at the end 
         // of the using block.
         reader.Close();
     }
}

如果您想非常确定，请在批量复制完成后对数据库执行查询以检查行是否存在。

于 2013-10-01T11:15:56.720 回答