dbtasktransaction.cs

来自「该项目中对 SQLHelper 类进行了简单封装」· CS 代码 · 共 101 行

/* 
 * DBTransaction.cs @Microsoft Visual Studio 2005 <.NET Framework 3.5>
 * AfritXia
 * 2007-01-21
 * 
 * Copyright(c) http://www.AfritXia.NET/
 * 
 */

using System;
using System.Data;
using System.Data.OleDb;

// 应用数据库任务接口类
using NET.AfritXia.MyHome.DBTask.Definition;

namespace NET.AfritXia.MyHome.DBTask.Access2000
{
	/// <summary>
	/// Access2000 数据库事务
	/// </summary>
	public class DBTaskTransaction : IDBTaskTransaction
	{
		// 数据库连接
		private OleDbConnection m_dbConn = null;
		// 数据库事务
		private OleDbTransaction m_dbTranx = null;

		#region 类构造器
		/// <summary>
		/// 类默认构造器
		/// </summary>
		public DBTaskTransaction()
		{
			// 创建数据库联接
			this.m_dbConn = ConnectionFactory.CreateConnection();

			if (this.m_dbConn.State != ConnectionState.Open)
				this.m_dbConn.Open();

			// 开始数据库事务
			this.m_dbTranx = this.m_dbConn.BeginTransaction();
		}
		#endregion

		/// <summary>
		/// 获取数据库连接
		/// </summary>
		public OleDbConnection DBConn
		{
			get
			{
				return this.m_dbConn;
			}
		}

		/// <summary>
		/// 获取数据库事务
		/// </summary>
		public OleDbTransaction DBTranx
		{
			get
			{
				return this.m_dbTranx;
			}
		}

		#region IDBTransaction 成员
		/// <summary>
		/// 提交该事务
		/// </summary>
		public void Commit()
		{
			this.m_dbTranx.Commit();
		}

		/// <summary>
		/// 回滚该事务
		/// </summary>
		public void Rollback()
		{
			this.m_dbTranx.Rollback();
		}
		#endregion

		#region IDisposable 成员
		/// <summary>
		/// 释放对象
		/// </summary>
		public void Dispose()
		{
			// 释放事务资源
			this.m_dbTranx.Dispose();

			// 关闭数据库联接并释放
			this.m_dbConn.Close();
			this.m_dbConn.Dispose();
		}
		#endregion
	}
}