SqlConnection con = new SqlConnection();
con.Open();
SqlTransaction tran = con.BeginTransaction();
SqlCommand cmd = new SqlCommand("use test;",con,tran);
cmd.Connection = con;
try
{
// SqlConnection con1 = new SqlConnection("server=.;database=Test;user=sa;password=123456;Max Pool Size=5000;Min Pool Size=5");
cmd.Transaction = tran;
dm.AddA(con);
dm.AddB(con);
tran.Commit();
}
catch (Exception)
{
tran.Rollback();
throw;
}
finally
{
con.Close();
}
Console.Read();
}
}
public class DalMan
{
public void AddA(SqlConnection con)
{
string sql = "insert A(id) values('1')";
SqlCommand cmd = new SqlCommand(sql,con);
try
{
if (con.State == ConnectionState.Closed)
{
con.Open();
}
cmd.ExecuteNonQuery();
Console.WriteLine("A ADd!");
}
catch (Exception)
{
throw;
}
finally
{
con.Close();
}
}
public void AddB(SqlConnection con)
{
string sql = "insert B(id) values('2‘)";
SqlCommand cmd = new SqlCommand(sql, con);
try
{
if (con.State == ConnectionState.Closed)
{
con.Open();
}
cmd.ExecuteNonQuery();
Console.WriteLine("B ADd!");
}
catch (Exception)
{
throw;
}
finally
{
con.Close();
}
}
}
有两个插入方法。想把这两个插入方法调用到一个事务处理中。在保留这两个方法的同时，怎么保证事务进行顺利啊？大神们！
