By

文章目录

       在我知道的.net中，执行事务有两种方法，一种是自动事物，使用起来相当简单，但是需要配置服务器，如果你用的是web共享主机，即没有权限配置自己的服务器，那就没必要用这种了，接下来我讲下.net中最普通的事务。
       接触3层也有一段时间了，了解水平一般，前段时间在想在三层中怎么使用事务呢，放在哪呢？Sqlherper ? AL?BLL?。然后我就疯狂的百度，好几次都是未果（因为做的都是小项目，不用事务也关系不大），今天我再次查时，
好好的看了csdn上的以讨论，http://topic.csdn.net/u/20091101/19/f21697d7-8f0c-4eb3-8e59-d0fe2f0b04b0.html，
结合前辈和高手们的意见，自己改了一个出来。我的想法是将事务逻辑写在业务逻辑层，数据库的处理还都是在SQLHELPER，
BLL层通过事务SqlTransaction传值访问DAL，再访问Sqlhelper。接下来是分块的代码。

Sqlhelper：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
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：

1
2
3
4
5
6
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:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
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();//关闭数据库连接
        }
    }
}

上述代码在此次测试中通过，若要用于真实项目中，请修改后再使用，还有本人水平一般，写的不到之处请大家见谅。欢迎大家指导指正。

注：此文来自我的博客园

本作品采用[知识共享署名-非商业性使用-相同方式共享 2.5]中国大陆许可协议进行许可，我的博客欢迎复制共享，但在同时，希望保留我的署名权kubiCode，并且，不得用于商业用途。如您有任何疑问或者授权方面的协商，请给我留言。

文章目录