C# Code:


/// <summary>
/// 当前启用的事务
/// </summary>
protected SqlTransaction _CurrentTrans = null;

/// <summary>
/// 当前事务的连接
/// </summary>
protected SqlConnection _CurrentConnection = null;

/// <summary>
/// 启用事务控制
/// </summary>
protected virtual void BeginTransaction()
{
   _CurrentConnection = DataProvider.Instance.CreateConnection(_DBName);
   _CurrentTrans = _CurrentConnection.BeginTransaction();
}

/// <summary>
/// 提交事务
/// </summary>
protected virtual void CommitTransaction()
{
   try
   {
      if (_CurrentTrans != null)
      {
         _CurrentTrans.Commit();
         _CurrentTrans = null;
         DataProvider.Instance.CloseConnection(_CurrentConnection);
      }
   }
   catch
   {
      DataProvider.Instance.CloseConnection(_CurrentConnection);
      throw;
   }
}

/// <summary>
/// 事务回滚
/// </summary>
protected virtual void RollbackTransaction()
{
   try
   {
      if (_CurrentTrans != null)
      {
         _CurrentTrans.Rollback();
         _CurrentTrans = null;
         DataProvider.Instance.CloseConnection(_CurrentConnection);
      }
   }
   catch
   {
      DataProvider.Instance.CloseConnection(_CurrentConnection);
      throw;
   }
}

//来源:C/S框架网(www.csframework.com) QQ:1980854898