復制代碼 代碼如下:

private static SqlConnection Cnn = new SqlConnection(DbConfig.ConnectionString);
#region 判讀SqlConnection 是否開啟連接 并開啟
/// <summary>
/// 判讀SqlConnection 是否開啟連接 并開啟
/// </summary>
/// <returns>返回SqlConnection</returns>
private static SqlConnection GetCnn()
{
if (Cnn.State == ConnectionState.Closed)
{
Cnn.Open();
}
return Cnn;
}
#endregion
#region 關閉數據庫連接
/// <summary>
/// 關閉數據庫連接
/// </summary>
public static void CloseCnn()
{
Cnn.Close();
}
#endregion
#region 產生一個事務并開始
/// <summary>
/// 產生一個事務并開始
/// </summary>
/// <returns>返回此事務</returns>
public static SqlTransaction BeginTransaction()
{
SqlTransaction tran = GetCnn().BeginTransaction();
return tran;
}
#endregion

復制代碼 代碼如下:

public bool test(int i,SqlTransaction tran)
{
string sql = "insert into [test]([item]) values(@i)";
SqlParameter[] paras=new SqlParameter[]{new SqlParameter("@i",i)};
return sqlhelper.ExecutenQuery(sql, paras, CommandType.Text, tran)>0;
}

復制代碼 代碼如下:

UserDAO userdao = new UserDAO();
public bool test()
{
using (SqlTransaction tran = SQLHelper.BeginTransaction())
{
try
{
userdao.test(2, tran);
userdao.test(3, tran);
tran.Commit(); return true;
}
catch
{
tran.Rollback();
return false;
}
finally
{
SQLHelper.CloseCnn();//關閉數據庫連接
}
}
}