日期:2014-05-17 浏览次数:20442 次
using(TransactionScope scope = new TransactionScope())
{
string strSQL = "数据库连接字符串";
using(SqlConnection con = new SqlConnection(strSQL))
{
try
{
con.Open();
string sql_1 = "语句一";
SqlCommand cmd = new SqlCommand(con,sql_1);
cmd.ExecuteNonQuery();
string sql_2 = "语句二";
SqlCommand cmd2 = new SqlCommand(con,sql_2);
cmd2.ExecuteNonQuery();
}
catch(Exception ex)
{
Response.Write(ex.Message);
}
}
scope.Complete();
}
//执行事务处理
public void DoTran()
{ //建立连接并打开
SqlConnection myConn=GetConn();
myConn.Open();
SqlCommand myComm=new SqlCommand();
//SqlTransaction myTran=new SqlTransaction();
//注意,SqlTransaction类无公开的构造函数
SqlTransaction myTran;
//创建一个事务
myTran=myConn.BeginTransaction();
try
{
//从此开始,基于该连接的数据操作都被认为是事务的一部分
//下面绑定连接和事务对象
myComm.Connection=myConn;
myComm.Transaction=myTran; //定位到pubs数据库
myComm.CommandText="USE pubs";
myComm.ExecuteNonQuery();//操作1
myComm.CommandText=""; //操作2
myComm.ExecuteNonQuery();
//提交事务
myTran.Commit();
}
catch(Exception err)
{
myTran.Roback();
throw new ApplicationException("事务操作出错,系统信息:"+err.Message);
}
finally
{
myConn.Close();
}
}
using(SqlConnection conn=new SqlConnection(ConfigurationManager.ConnectionStrings["connstr"].ConnectionString) )
{
SqlTransaction transaction=null;
try
{
conn.Open();