dbobject_oledb.cs

一个由VB开发的。NET实体生成器` 提高.net代码质量及开发效率

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

namespace {namespace}.DataAS.Base
{
	/// <summary>
	/// 数据库操作基类
	/// </summary>
	public class DbObject : System.IDisposable
	{
		protected OleDbConnection Conn;
		protected string ConnString;

        public OleDbConnection Connection
        {
        	get
        	{
            	return Conn;
        	}
        }

        /// <summary>
        /// 无参数构造函数
        /// </summary>
        protected DbObject()
        {
            ConnString = System.Configuration.ConfigurationManager.ConnectionStrings["DLConnectionString"].ConnectionString;
            Conn = new OleDbConnection(ConnString);
            Conn.Open();
        }

		/// <summary>
		/// 构造函数
		/// </summary>
		/// <param name="ConnectionString">连接数据源字符串</param>
		protected DbObject(string ConnectionString)
		{
			ConnString = ConnectionString;
			Conn = new OleDbConnection(ConnectionString);
            Conn.Open();
		}

    	/// <summary>
    	/// 构造函数
    	/// </summary>
        /// <param name="Connection">连接数据源字符串</param>
    	protected DbObject(OleDbConnection Connection)
    	{
    		ConnString = Connection.ConnectionString;
    		Conn = Connection;
            if (Conn.State == ConnectionState.Closed)
            {
                Conn.Open();
            }
    	}

		/// <summary>
		/// 执行存储过程
		/// </summary>
		/// <param name="ProcName">存储过程名称</param>
		/// <param name="Parameters">存储过程参数组</param>
		/// <returns>所响应的行数</returns>
		protected int RunProc(string ProcName,OleDbParameter[] Parameters)
		{
			OleDbCommand Cmd = new OleDbCommand(ProcName);
			Cmd.CommandType = CommandType.StoredProcedure;
			Cmd.Connection = this.Conn;
			foreach ( OleDbParameter param in Parameters)
			{
				Cmd.Parameters.Add(param);
			}
			return Cmd.ExecuteNonQuery();
		}

		protected OleDbCommand BuildCommand(string sql,OleDbParameter[] Parameters)
		{
			OleDbCommand Cmd = new OleDbCommand(sql,this.Conn);
			foreach (OleDbParameter param in Parameters)
			{
				Cmd.Parameters.Add(param);
			}
			return Cmd;
		}
		
		protected OleDbCommand BuildCommand(string sql)
		{
			OleDbCommand Cmd = new OleDbCommand(sql,this.Conn);
			return Cmd;
		}
		
		/// <summary>
		/// 检索一张表
		/// </summary>
		/// <param name="SQL">SQL 查询语句</param>
		/// <returns>被查询的表</returns>
		protected DataTable SelectTable(string SQL)
		{
			DataSet ds = new DataSet();
			OleDbDataAdapter da = new OleDbDataAdapter(SQL,this.Conn);
			da.Fill(ds);
			return ds.Tables[0];
		}

        protected object GetResult(string sql)
        {
            OleDbCommand cmd = BuildCommand(sql);
            return cmd.ExecuteScalar();
        }
		#region IDisposable Members

		public void Dispose()
		{
			if ( Conn.State != ConnectionState.Closed )
				Conn.Close();
		}

		#endregion
	}
}