我正在通过SqlBulkCopy插入数据,如下所示:
public void testBulkInsert(string connection, string table, DataTable dt)
{
using (SqlConnection con = new SqlConnection(connection))
{
con.Open();
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(con))
{
bulkCopy.DestinationTableName = table;
bulkCopy.WriteToServer(dt);
}
}
}这是否会自动包装在SQL事务中,以便如果在DB中发生了错误,那么它将保持与开始大容量插入之前相同的状态?或者一半的数据会被插入?
也就是说,我是否有必要显式地调用con.BeginTransaction
或者,如果我调用接受字符串的SqlBulkCopy构造函数,这是让它在事务中发生的更好方法吗?
public void testBulkInsert(string connection, string table, DataTable dt)
{
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
{
bulkCopy.DestinationTableName = table;
bulkCopy.WriteToServer(dt);
}
}我觉得文档在这个问题上有点不清楚,因为他们最初说
默认情况下,大容量复制操作作为隔离操作执行。大容量复制操作是以非事务方式进行的,没有回滚的机会。
但后来的状态
默认情况下,批量复制操作是它自己的事务。当您想要执行专门的批量复制操作时,使用连接字符串创建SqlBulkCopy的新实例,或者在没有活动事务的情况下使用现有的SqlConnection对象。在每个场景中,大容量复制操作都会创建,然后提交或回滚事务。
是否有必要这样做:
public void testBulkInsert(string connection, string table, DataTable dt)
{
using (SqlConnection con = new SqlConnection(connection))
{
con.Open();
using (SqlTransaction tr = con.BeginTransaction(IsolationLevel.Serializable))
{
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(con, SqlBulkCopyOptions.Default, tr))
{
bulkCopy.DestinationTableName = table;
bulkCopy.WriteToServer(dt);
}
tr.Commit();
}
}
}发布于 2014-10-27 08:25:48
不,这里是SqlBulkCopy文档在msdn中的文本
默认情况下,大容量复制操作作为隔离操作执行。大容量复制操作是以非事务方式进行的,没有回滚的机会。如果在发生错误时需要回滚批量复制的全部或部分,则可以使用SqlBulkCopy管理的事务,在现有事务中执行批量复制操作,或在System.Transactions事务中登记。
编辑:从我给您的链接中正确阅读文档:
默认情况下,批量复制操作是它自己的事务。当您想要执行专门的批量复制操作时,使用连接字符串创建SqlBulkCopy的新实例,或者使用 没有活动事务的现有SqlConnection对象。在每个场景中,大容量复制操作都会创建,然后提交或回滚事务。
这是为内部批量复制事务编写的,默认情况下不是!
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(
connectionString, SqlBulkCopyOptions.KeepIdentity |
SqlBulkCopyOptions.UseInternalTransaction))
{
....
}仔细查看SqlBulkCopyOptions.UseInternalTransaction!,您将在SqlBulkCopy类构造函数中显式指定UseInternalTransaction选项,以显式地导致大容量复制操作在其自己的事务中执行,导致每一批批量复制操作在单独的transaction.Since中执行不同的批处理,如果在大容量复制操作期间发生错误,则当前批处理中的所有行将被回滚,但以前批处理中的行将保留在中。
如果由于出现错误而需要回滚整个大容量复制操作,或者如果大容量副本应作为可以回滚的较大进程的一部分执行,则可以向SqlBulkCopy构造函数提供一个SqlTransaction对象。
外部事务情况。
using (SqlTransaction transaction =
destinationConnection.BeginTransaction())
{
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(
destinationConnection, SqlBulkCopyOptions.KeepIdentity,
transaction))
{
....
}
}正如我在乞求中所说的,答案是否定的,您应该使用现有事务或内部批量复制事务。有关更多信息,请阅读链接中的文档文件。
如果你想要交易,你应该使用我写的两种情况中的一种。
https://stackoverflow.com/questions/26583432
复制相似问题