在C#中,使用SqlDataAdapter進行事務管理需要遵循以下步驟:
SqlConnection connection = new SqlConnection("your_connection_string");
connection.Open();
SqlCommand command = new SqlCommand("your_sql_statement", connection);
SqlTransaction transaction = connection.BeginTransaction();
command.Transaction = transaction;
SqlDataAdapter adapter = new SqlDataAdapter();
adapter.SelectCommand = command;
DataTable dataTable = new DataTable();
adapter.Fill(dataTable);
transaction.Commit();
try
{
// 執行數據庫操作
transaction.Commit();
}
catch (Exception ex)
{
// 發生錯誤時回滾事務
transaction.Rollback();
throw ex;
}
finally
{
// 關閉連接
connection.Close();
}
將以上代碼整合在一起,可以創建一個使用SqlDataAdapter進行事務管理的示例:
using System;
using System.Data;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "your_connection_string";
string sqlStatement = "your_sql_statement";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
using (SqlCommand command = new SqlCommand(sqlStatement, connection))
{
SqlTransaction transaction = connection.BeginTransaction();
command.Transaction = transaction;
using (SqlDataAdapter adapter = new SqlDataAdapter())
{
adapter.SelectCommand = command;
DataTable dataTable = new DataTable();
adapter.Fill(dataTable);
try
{
transaction.Commit();
}
catch (Exception ex)
{
transaction.Rollback();
throw ex;
}
}
}
}
}
}
請注意替換your_connection_string
和your_sql_statement
為實際的連接字符串和SQL語句。