c#中SqlTransaction——事务详解

private static void ExecuteSqlTransaction(string connectionString)

    {

      using (SqlConnection cOnnection= new SqlConnection(connectionString))

      {

        connection.Open();

        SqlCommand command = connection.CreateCommand();

        SqlTransaction transaction; 

        transaction = connection.BeginTransaction("SampleTransaction");

        command.COnnection= connection;

        command.Transaction = transaction;

        try

        {

          command.CommandText =

            "Insert into Department (ID, Name) VALUES (1, '工程部')";

          command.ExecuteNonQuery();

          command.CommandText =

            "Insert into Users(ID, Name,DepartmentID) VALUES (1, 'xyz',1)";

          command.ExecuteNonQuery();

          transaction.Commit();

        }

        catch (Exception ex)

        {

          transaction.Rollback();

        }

      }

    }

public class TestTransaction
  {
    /// 

    /// 插入新用户
    /// 
    /// 
    /// 
    private static bool InsertIntoUser(SqlTransaction tran)
    {
      string strSql = @"INSERT INTO [T_User]
                      ([F_Name])
                   VALUES
                      (@F_Name)";
      SqlParameter[] Params ={ new SqlParameter("@F_Name", SqlDbType.VarChar, 20) };
      Params[0].Value="Test1001";
      int count= SqlHelper.ExecuteNonQuery(strSql,Params,tran);
      if (count > 0)
      {
        return true;
      }
      else
      {
        return false;
      }
    }
    /// 

    /// 插入title
    /// 
    /// 
    private static bool InsertIntoTitle(SqlTransaction tran)
    {
      string strSql = @"INSERT INTO [T_User_Title]
                    ([F_TitleName],
                    [F_Remark],
                    [F_Status],
                    [F_EditTime])
                 VALUES
                    (@F_TitleName,
                    @F_Remark,
                    @F_Status,
                    @F_EditTime)";
      SqlParameter[] Params = { 
        new SqlParameter("@F_TitleName",SqlDbType.VarChar, 50), 
        new SqlParameter("@F_Remark", SqlDbType.VarChar, 200), 
        new SqlParameter("@F_Status", SqlDbType.Int, 1), 
        new SqlParameter("@F_EditTime", SqlDbType.DateTime, 8) };
      Params[0].Value = "TestUser1001";
      Params[1].Value = "这是第一次测试";
      Params[2].Value = 1;
      Params[3].Value = DateTime.Now;
      int count = SqlHelper.ExecuteNonQuery(strSql,Params,tran);
      if (count > 0)
      {
        return true;
      }
      else
      {
        return false;
      }
    }
    /// 

    /// 检测Transaction
    /// 
    /// 
    public static bool InsertWithTran()
    {
      bool success = false;
      string cOnnectionString=System.Configuration.ConfigurationSettings.AppSettings["SqlConStr"].ToString();
      using (SqlConnection con = new SqlConnection(connectionString))
      {
        con.Open();
        SqlTransaction tran = con.BeginTransaction();
        try
        { 
          if (tran == null)
          {
            throw new Exception("Transaction is null");
          }
          if (InsertIntoUser(tran))
          {
            if (InsertIntoTitle(tran))
            {
              tran.Commit();
              success = true;
            }
          }
        }
        catch
        {
          tran.Rollback();
          success = false;
        }
        finally
        {
          tran.Dispose();
          con.Close();
        }
      }
      return success;

    }
  }

 protected void Button1_Click(object sender, EventArgs e)
  {
    bool success = TestTransaction.InsertWithTran();
    if (success)
    {
      Bmc.CLUtility.ShowMessage(this.Page, "插入成功");      
    }
    else
    {
      Bmc.CLUtility.ShowMessage(this.Page, "插入失败");
    }
  }