我正在使用SqlDataAdapter.Update与DataTables更新一个事务中的两个SQL表。如果插入失败,我想回滚所有数据。这是我的代码:TransactionScope不回滚与SqlDataAdapter.Update
using (var conn = new SqlConnection(_connectionString))
{
conn.Open();
using (var scope = new TransactionScope())
{
// Insert first table
using (var command = conn.CreateCommand())
{
command.CommandText =
@"INSERT INTO TableA(Id, Data)
VALUES(@id, @data)";
command.CommandType = CommandType.Text;
command.Parameters.Add(new SqlParameter("@id", SqlDbType.Int) { SourceColumn = "Id" });
command.Parameters.Add(new SqlParameter("@data", SqlDbType.Char) { SourceColumn = "Data" });
var adapter = new SqlDataAdapter();
adapter.InsertCommand = command;
adapter.Update(tableADataTable);
}
// Insert second table
using (var command = conn.CreateCommand())
{
command.CommandText =
@"INSERT INTO TableB(Id, Data)
VALUES(@id, @data)";
command.CommandType = CommandType.Text;
command.Parameters.Add(new SqlParameter("@id", SqlDbType.Int) { SourceColumn = "Id" });
command.Parameters.Add(new SqlParameter("@data", SqlDbType.Char) { SourceColumn = "Data" });
var adapter = new SqlDataAdapter();
adapter.InsertCommand = command;
adapter.Update(tableBDataTable);
}
scope.Complete();
}
}
我遇到的问题是,如果一个例外是第二个命令执行过程中引发的,从第一个命令数据仍COMMITED。我是否需要明确回滚?或者当使用SqlDataAdapter.Update时,TransactionScope应该如何表现?
需要注意的是,最初我在TransactionScope using语句中创建了SqlConnection,但是当我收到错误时,我的数据库服务器没有正确配置分布式事务。是否我的SqlConnection创建与TransactionScope相关?