Asp.net 在三层架构中事务的使用实例代码
程序员文章站
2024-03-06 19:59:26
接触3层也有一段时间了,了解水平一般,前段时间在想在三层中怎么使用事务呢,放在哪呢?sqlherper ? dal? bll?。然后我就疯狂的百度,好几次都是未果(因为做的...
接触3层也有一段时间了,了解水平一般,前段时间在想在三层中怎么使用事务呢,放在哪呢?sqlherper ? dal? bll?。然后我就疯狂的百度,好几次都是未果(因为做的都是小项目,不用事务也关系不大),今天我再次查时,好好的看了csdn上的以讨论,,结合前辈和高手们的意见,自己改了一个出来。我的想法是将事务逻辑写在业务逻辑层,数据库的处理还都是在sqlhelper,bll层通过事务sqltransaction传值访问dal,再访问sqlhelper。接下来是分块的代码。
sqlhelper:
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
dal:
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;
}
bll:
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();//关闭数据库连接
}
}
}
上述代码在此次测试中通过,若要用于真实项目中,请修改后再使用,还有本人水平一般,写的不到之处请大家见谅。欢迎大家指导指正。
sqlhelper:
复制代码 代码如下:
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
dal:
复制代码 代码如下:
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;
}
bll:
复制代码 代码如下:
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();//关闭数据库连接
}
}
}
上述代码在此次测试中通过,若要用于真实项目中,请修改后再使用,还有本人水平一般,写的不到之处请大家见谅。欢迎大家指导指正。