dbobject_sql.cs

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

using System;
using System.Data;
using System.Data.SqlClient;

namespace {namespace}.DataAS.Base
{
    public enum DBBoolean
    {
        True,
        False,
        None
    }

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

        public SqlConnection Connection
        {
            get
            {
                return Conn;
            }
        }

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

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

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="ConnectionString">连接数据源字符串</param>
        protected DbObject(SqlConnection 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, SqlParameter[] Parameters)
        {
            SqlCommand Cmd = new SqlCommand(ProcName);
            Cmd.CommandType = CommandType.StoredProcedure;
            Cmd.Connection = this.Conn;
            foreach (SqlParameter param in Parameters)
            {
                Cmd.Parameters.Add(param);
            }
            return Cmd.ExecuteNonQuery();
        }

        protected SqlCommand BuildCommand(string sql, SqlParameter[] Parameters)
        {
            SqlCommand Cmd = new SqlCommand(sql, this.Conn);
            foreach (SqlParameter param in Parameters)
            {
                Cmd.Parameters.Add(param);
            }
            return Cmd;
        }

        protected SqlCommand BuildCommand(string sql)
        {
            SqlCommand Cmd = new SqlCommand(sql, this.Conn);
            return Cmd;
        }

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

        protected object GetResult(string sql)
        {
            SqlCommand cmd = BuildCommand(sql);
            return cmd.ExecuteScalar();
        }

        #region IDisposable Members

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

        #endregion
    }
}