using System;
using System.Data;
using System.Data.SqlClient;
namespace Aspcn
{
public class DbTran
{
//执行事务处理
public void DoTran()
{
//建立连接并打开
SqlConnection myConn=GetConn();
myConn.Open();
SqlCommand myComm=new SqlCommand();
SqlTransaction myTran;
myTran=myConn.BeginTransaction();
//下面绑定连接和事务对象
myComm.Connection=myConn;
myComm.Transaction=myTran;
//试图创建数据库TestDB
myComm.CommandText="CREATE database TestDB";
myComm.ExecuteNonQuery();
//提交事务
myTran.Commit();
}
//获取数据连接
private SqlConnection GetConn()
{
string strSql="Data Source=localhost;Integrated Security=SSPI;user id=sa;password=";
SqlConnection myConn=new SqlConnection(strSql);
return myConn;
}
}
public class Test
{
public static void Main()
{
DbTran tranTest=new DbTran();
tranTest.DoTran();
Console.WriteLine("事务处理已经成功完成。");
Console.ReadLine();
}
}
}
