using System;
using System.Collections;
using System.Configuration;
using System.Data;
using System.Linq;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.HtmlControls;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Xml.Linq;
using System.Data.SqlClient;
using System.Transactions; (참조추가 통해서 추가)
public partial class Category_FrmTransaction : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
}
protected void btnUpdateDelete_Click(object sender, EventArgs e)
{
//수정과 삭제를 동시에 하기 위해서
string UpdateQuery =
"Update Categories Set CategoryName =
'컴퓨터' Where CategoryID = 10";
string DeleteQuery =
"Delete Categories Where CategoryID >= 16";
using (SqlConnection con = new SqlConnection
(ConfigurationManager.ConnectionStrings
["ConnectionString"].ConnectionString))
{
con.Open();
//[1] sqlTransaction클래스의 인스턴스 생성
SqlTransaction tran = con.BeginTransaction(""); //트랜잭션 초기화
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
//[2] 현재 명령어에서 사용한 트랜잭션 지정
cmd.Transaction = tran;
try
{
cmd.CommandText = UpdateQuery;
cmd.ExecuteNonQuery(); //수정
cmd.CommandText = DeleteQuery;
cmd.ExecuteNonQuery(); //삭제
tran.Commit(); //에러가 발생하지 않으면 실행
lblError.Text = "정상처리";
}
catch (Exception ex)
{
lblError.Text = ex.Message; //에러가 메시지 출력
//에러가 발생하면 롤백
tran.Rollback();
}
}
}
//삭제 + 삭제
protected void btnCommand_Click(object sender, EventArgs e)
{
string UpdateQuery =
"Delete Categories Where CategoryID = 8";
string DeleteQuery =
"Delete Categories Where CategoryID2 = 9";
//참조추가 -> .NET - > System.Transactions 추가
using (TransactionScope scope = new TransactionScope())
{
using (SqlConnection con = new SqlConnection
(ConfigurationManager.ConnectionStrings
["ConnectionString"].ConnectionString))
{
con.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
try{
cmd.CommandText = UpdateQuery;
cmd.ExecuteNonQuery(); //수정
cmd.CommandText = DeleteQuery;
cmd.ExecuteNonQuery(); //삭제
lblError.Text = "정상처리";
}
catch (Exception ex) {
lblError.Text = ex.Message; //에러가 메시지 출력
}
//scope.Complete(); //완료
}
}
}
} |