C#ASP.NET完善的DBHelper，配套Model生成器

支持Oracle、MSsql、MysqL、sqlite四种数据库，支持事务，支持对象关系映射；已在多个项目中实际使用。

没有语法糖，学习成本几乎为0，拿来即用。

DBHelper类完整代码：

using System; System.Collections.Generic; System.ComponentModel; System.Configuration; System.Data; System.Data.Common; System.Data.Objects.DataClasses; System.Data.OracleClIEnt; System.Data.sqlClIEnt; System.Data.sqlite; System.Reflection; System.Text; System.Text.RegularExpressions; mysql.data.MysqLClIEnt; System.Data.oleDb; Models;/* ---------------------------------------------------------------------- * 作    者：suxiang * 创建日期：2016年11月23日 * 更新日期：2020年06月16日 *  * 支持Oracle、MSsql、MysqL、sqlite、Access数据库 *  * 注意引用的mysql.data.dll、System.Data.sqlite.dll的版本，32位还是64位 * 有的System.Data.sqlite.dll版本需要依赖sqlite.Interop.dll *  * 需要配套的PagerModel、IsDBFIEldAttribute、IsIDAttribute类 *  * 为方便使用，需要配套的Model生成器 * ---------------------------------------------------------------------- */namespace DBUtil{    /// <summary>    /// 数据库 *** 作类    </summary>    public static class DBHelper    {        #region 变量        <summary>         数据库类型        </summary>        private string m_DBType = ConfigurationManager.AppSettings["DBType"];        bool m_autoIncrement = ConfigurationManager.AppSettings[autoIncrement"].Tolower() == true" ? true : false;         数据库连接字符串        string m_ConnectionString = ConfigurationManager.ConnectionStrings[DefaultConnection].ToString();         事务        </summary>        [ThreadStatic]        static DbTransaction m_Tran;         带参数的sql插入和修改语句中，参数前面的符号        string m_ParameterMark = GetParameterMark();         sql过滤正则        static Dictionary<string,Regex> m_sqlFilteRegexList = new Dictionary<();        #endregion        #region 静态构造函数         静态构造函数         DBHelper()        {            m_sqlFilteRegexList.Add(net localgroup ",new Regex(net[\s]+localgroup[\s]+,RegexOptions.IgnoreCase));            m_sqlFilteRegexList.Add(net user net[\s]+user[\s]+xp_cmdshell xp_cmdshell[\s]+exec exec[\s]+execute execute[\s]+truncate truncate[\s]+drop drop[\s]+restore restore[\s]+create create[\s]+alter alter[\s]+rename rename[\s]+insert insert[\s]+update update[\s]+delete delete[\s]+select select[\s]+#region 生成变量        #region 生成 IDbCommand         生成 IDbCommand         DbCommand GetCommand()        {            DbCommand command = null;            switch (m_DBType)            {                case oracle:                    command = new OracleCommand();                    break;                mssql sqlCommand();                    MysqL MysqLCommand();                    sqlite sqliteCommand();                    access oleDbCommand();                    ;            }            return command;        }        static DbCommand GetCommand(string sql,DbConnection conn)        {            DbCommand command =  OracleCommand(sql);                    command.Connection = conn;                     sqlCommand(sql);                    command.Connection = MysqLCommand(sql);                    command.Connection = sqliteCommand(sql);                    command.Connection = oleDbCommand(sql);                    command.Connection = command;        }        #region 生成 IDbConnection         生成 IDbConnection         DbConnection GetConnection()        {            DbConnection conn = :                    conn =  OracleConnection(m_ConnectionString);                     sqlConnection(m_ConnectionString);                     MysqLConnection(m_ConnectionString);                     sqliteConnection(m_ConnectionString);                     oleDbConnection(m_ConnectionString);                     conn;        }        #region 生成 IDbDataAdapter         生成 IDbDataAdapter         DbDataAdapter GetDataAdapter(DbCommand cmd)        {            DbDataAdapter dataAdapter = :                    dataAdapter =  OracleDataAdapter();                    dataAdapter.SelectCommand = cmd;                     sqlDataAdapter();                    dataAdapter.SelectCommand = MysqLDataAdapter();                    dataAdapter.SelectCommand = sqliteDataAdapter();                    dataAdapter.SelectCommand = oleDbDataAdapter();                    dataAdapter.SelectCommand = dataAdapter;        }        #region 生成 m_ParameterMark         生成 m_ParameterMark         GetParameterMark()        {            :                    return :@;            }            ;        }        #region 生成 DbParameter         生成 DbParameter        static DbParameter GetDbParameter(string name,1)">object vallue)        {            DbParameter dbParameter = :                    dbParameter =  OracleParameter(name,vallue);                     sqlParameter(name,1)"> MysqLParameter(name,1)"> sqliteParameter(name,1)"> oleDbParameter(name,1)"> dbParameter;        }        #endregion        #region 基础方法        #region  执行简单SQL语句        #region Exists        bool Exists( sqlString)        {            sqlFilter(ref sqlString);            using (DbConnection conn = GetConnection())            {                using (DbCommand cmd = GetCommand(sqlString,conn))                {                    try                    {                        conn.open();                        object obj = cmd.ExecuteScalar();                        if ((Object.Equals(obj,1)">null)) || (Object.Equals(obj,System.dbnull.Value)))                        {                            return ;                        }                        else                        {                            true;                        }                    }                    catch (Exception ex)                    {                        throw ex;                    }                    finally                    {                        cmd.dispose();                        conn.Close();                    }                }            }        }        #region 执行SQL语句，返回影响的记录数         执行SQL语句，返回影响的记录数        </summary>        <param name="sqlString">SQL语句</param>        <returns>影响的记录数</returns>        int Executesql( sqlString);            DbConnection conn = m_Tran == null ? GetConnection() : m_Tran.Connection;                            {                    if (conn.State != ConnectionState.Open) conn.open();                    if (m_Tran != null) cmd.Transaction = m_Tran;                    int rows = cmd.ExecuteNonquery();                     rows;                }                 (Exception ex)                {                    throw  Exception(ex.Message);                }                                {                    cmd.dispose();                    if (m_Tran == ) conn.Close();                }            }        }        #region 执行一条计算查询结果语句，返回查询结果         执行一条计算查询结果语句，返回查询结果（object）        计算查询结果语句查询结果（object）object GetSingle(                    {                         ConnectionState.Open) conn.open();                         obj;                        }                    }                                        {                        cmd.dispose();                    }                }            }        }        #region 执行查询语句，返回IDataReader         执行查询语句，返回IDataReader ( 注意：调用该方法后，一定要对IDataReader进行Close )        查询语句IDataReaderstatic DbDataReader ExecuteReader( sqlString);            DbConnection conn = GetConnection();            DbCommand cmd =            {                 ConnectionState.Open) conn.open();                DbDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);                 myReader;            }             (Exception ex)            {                 ex;            }        }        #region 执行查询语句，返回DataSet         执行查询语句，返回DataSet        DataSetstatic DataSet query( GetConnection())            {                DataSet ds =  DataSet();                                {                    conn.open();                     GetDataAdapter(cmd);                        adapter.Fill(ds,ds);                    }                }                 ex;                }                                {                    conn.Close();                }                 ds;            }        }        #region sql过滤，防注入         sql过滤，防注入        <param name="sql">sql</param>        voID sqlFilter(ref  sql)        {            sql = sql.Trim();            string ignore = .Empty;            string uppersql = sql.toupper();            foreach (string keyword in m_sqlFilteRegexList.Keys)            {                if (uppersql.IndexOf(keyword.toupper()) == 0)                {                    ignore = keyword;                }            }            if (ignore == " && ignore == keyword) continue;                Regex regex = m_sqlFilteRegexList[keyword];                sql = sql.Substring(0,ignore.Length) + regex.Replace(sql.Substring(ignore.Length),1)">.Empty);            }        }        #region 执行带参数的SQL语句        <param name="sqlString">string sqlString,1)">params DbParameter[] cmdParms)        {            DbConnection conn = m_Tran ==  GetCommand())            {                                {                    PrepareCommand(cmd,conn,m_Tran,sqlString,cmdParms);                     cmd.ExecuteNonquery();                    cmd.Parameters.Clear();                    <param name="strsql">string sqlString,1)"> DbParameter[] cmdParms)        {            DbConnection conn = GetCommand();                        {                PrepareCommand(cmd, cmd.ExecuteReader(CommandBehavior.CloseConnection);                cmd.Parameters.Clear();                 ex;            }        }         GetCommand();            PrepareCommand(cmd,cmdParms);            using (DbDataAdapter da = GetDataAdapter(cmd))            {                DataSet ds =                 {                    da.Fill(ds,1)">);                    cmd.Parameters.Clear();                }                                {                    cmd.dispose();                    conn.Close();                }                #region PrepareCommand        voID PrepareCommand(DbCommand cmd,DbConnection conn,DbTransaction trans,1)"> cmdText,DbParameter[] cmdParms)        {             ConnectionState.Open) conn.open();            cmd.Connection = conn;            cmd.CommandText = cmdText;            if (trans !=  trans;            cmd.CommandType = CommandType.Text;            if (cmdParms != )            {                foreach (DbParameter parm  cmdParms)                {                    cmd.Parameters.Add(parm);                }            }        }        #region 增删改查        #region 获取最大编号         获取最大编号        <typeparam name="T">实体Model</typeparam>        <param name="key">主键int GetMaxID<T>( key)        {            Type type = typeof(T);            string sql = ;            :                    sql = string.Format(SELECT Max({0}) FROM {1}SELECT Max(cast({0} as int)) FROM {1}using (IDbCommand cmd = GetCommand(sql,1)">1int.Parse(obj.ToString()) + #region 添加         添加        voID Insert( obj)        {            Insert(obj,m_autoIncrement);        }        object obj,1)">bool autoIncrement)        {            StringBuilder strsql =  StringBuilder();            Type type = obj.GetType();            strsql.Append(insert into {0}( GetEntityPropertIEs(type);            List<string> propertynameList = new List<string>();            int savedCount = foreach (PropertyInfo propertyInfo  propertyInfoList)            {                if (propertyInfo.GetCustomAttributes(typeof(IsIDAttribute),1)">false).Length > 0 && type.GetCustomAttributes(typeof(autoIncrementAttribute),1)">0) 0 && propertyInfo.GetCustomAttributes(0 && autoIncrement) ;                typeof(IsDBFIEldAttribute),1)">)                {                    propertynameList.Add(propertyInfo.name);                    savedCount++;                }            }            strsql.Append({0})string.Join( values ({0})string>(a => m_ParameterMark + a).ToArray())));            DbParameter[] parameters =  DbParameter[savedCount];            int k = for (int i = 0; i < propertyInfoList.Length && savedCount > 0; i++)            {                PropertyInfo propertyInfo = propertyInfoList[i];                )                {                    object val = propertyInfo.GetValue(obj,1)">);                    DbParameter param = GetDbParameter(m_ParameterMark + propertyInfo.name,val ==  dbnull.Value : val);                    parameters[k++] = param;                }            }            Executesql(strsql.ToString(),parameters);        }        #region 修改         修改        voID Update( obj)        {            object oldobj = Find(obj,1)">);            if (oldobj == null) new Exception(无法获取到旧数据);            StringBuilder strsql = update {0} object oldVal = propertyInfo.GetValue(oldobj,1)">);                    if (!.Equals(oldVal,val))                    {                        propertynameList.Add(propertyInfo.name);                        savedCount++;                    }                }            }            strsql.Append( set ));            DbParameter[] parameters =  DbParameter[savedCount];            StringBuilder sbPros =  StringBuilder();             {0}={1}{0},propertyInfo.name,m_ParameterMark));                        DbParameter param = GetDbParameter(m_ParameterMark + propertyInfo.name,1)"> dbnull.Value : val);                        parameters[k++] = param;                    }                }            }            if (sbPros.Length > )            {                strsql.Append(sbPros.ToString());            }            strsql.Append( where {0}='{1}'if (savedCount > )            {                Executesql(strsql.ToString(),parameters);            }        }        #region 删除         根据ID删除        voID Delete<T>(int ID)        {            Type type = (T);            StringBuilder sbsql =  StringBuilder();            DbParameter[] cmdParms = new DbParameter[];            cmdParms[0] = GetDbParameter(m_ParameterMark + GetIDname(type),ID);            sbsql.Append(delete from {0} where {2}={1}{2} 根据ID集合删除        voID BatchDelete<T>( IDs)        {            if (string.IsNullOrWhiteSpace(IDs)) ;            Type type = string[] IDArr = IDs.Split('');            DbParameter[] cmdParms =  DbParameter[IDArr.Length];            sbsql.AppendFormat(delete from {0} where {1} in (0; i < IDArr.Length; i++)            {                cmdParms[i] = GetDbParameter(m_ParameterMark + GetIDname(type) + i,IDArr[i]);                sbsql.AppendFormat({1}{2}{3},GetIDname(type),i);            }            sbsql.Remove(sbsql.Length - 1,);            sbsql.Append());            Executesql(sbsql.ToString(),1)"> 根据条件删除         conditions)        {            string.IsNullOrWhiteSpace(conditions))  StringBuilder();            sqlFilter( conditions);            sbsql.Append(delete from {0} where {1}#region 获取实体        #region 根据实体获取实体         根据实体获取实体        object Find(bool readCache = )        {            Type type = obj.GetType();            object result = Activator.CreateInstance(type);            bool hasValue = ;            IDataReader rd = select * from {0} where {2}='{1}'            {                rd = ExecuteReader(sql);                PropertyInfo[] propertyInfoList = GetEntityPropertIEs(type);                int fcnt = rd.FIEldCount;                List<string> fileds = ();                0; i < fcnt; i++)                {                    fileds.Add(rd.Getname(i).toupper());                }                while (rd.Read())                {                    hasValue = ;                    IDataRecord record = rd;                    foreach (PropertyInfo pro  propertyInfoList)                    {                        if (!fileds.Contains(pro.name.toupper()) || record[pro.name] == dbnull.Value)                        {                            ;                        }                        pro.SetValue(result,record[pro.name] == dbnull.Value ? null : getReaderValue(record[pro.name],pro.PropertyType),1)">);                    }                }            }             ex;            }            if (rd != null && !rd.IsClosed)                {                    rd.Close();                    rd.dispose();                }            }            if (hasValue)            {                 result;            }            ;            }        }        #region 根据ID获取实体         根据ID获取实体        object FindByID(Type type,1)"> ID)        {             Activator.CreateInstance(type);            IDataReader rd = static T FindByID<T>(string ID) where T : ()        {            Type type = (T);            T result = (T)Activator.CreateInstance(type);            IDataReader rd = default(T);            }        }        #region 根据sql获取实体         根据sql获取实体        static T FindBysql<T>(string sql) string sql,1)">params DbParameter[] args)  ExecuteReader(sql,args);                PropertyInfo[] propertyInfoList =#region 获取列表         获取列表        static List<T> FindListBysql<T>(()        {            List<T> List = new List<T> obj;            IDataReader rd =  ExecuteReader(sql);                typeof(T) == typeof())                {                     (rd.Read())                    {                        List.Add((T)rd[]);                    }                }                else                 {                    PropertyInfo[] propertyInfoList = ((T)).GetPropertIEs();                     rd.FIEldCount;                    List<();                    )                    {                        fileds.Add(rd.Getname(i).toupper());                    }                     (rd.Read())                    {                        IDataRecord record = rd;                        obj =  T();                         propertyInfoList)                        {                             dbnull.Value)                            {                                ;                            }                            pro.SetValue(obj,1)">);                        }                        List.Add((T)obj);                    }                }            }             List;        }        params DbParameter[] cmdParms) #region 分页获取列表         分页(任意entity，尽量少的字段)        static PagerModel FindPageBysql<T>(string orderby,1)">int pageSize,1)">int currentPage) ()        {            PagerModel pagerModel =  PagerModel(currentPage,pageSize);            using (DbConnection connection = GetConnection())            {                connection.open();                IDbCommand cmd = ;                StringBuilder sb =  StringBuilder();                string commandText = int startRow = int endRow =  (m_DBType)                {                    :                        #region 分页查询语句                        commandText = select count(*) from ({0}) T GetCommand(commandText,connection);                        pagerModel.totalRows = .Parse(cmd.ExecuteScalar().ToString());                        startRow = pageSize * (currentPage - );                        endRow = startRow + pageSize;                        sb.Append(select * from ( select row_limit.*,rownum rownum_ from ();                        sb.Append(sql);                        string.IsNullOrWhiteSpace(orderby))                        {                            sb.Append(" );                            sb.Append();                        }                        sb.Append( ) row_limit where rownum <= );                        sb.Append(endRow);                        sb.Append( ) where rownum_ >);                        sb.Append(startRow);                        #endregion                        ;                    1) + ;                        endRow = startRow + pageSize - ;                        sb.Append(@"                            select * from                             (select ROW_NUMBER() over({1}) as rowNumber,t.* from ({0}) t) temptable                            where rowNumber between {2} and {3} );                        sb.Append(select * from ();                        }                        sb.AppendFormat( ) row_limit limit {0},{1});                        sb.Append(sql);                         limit {0} offset {1}.Parse(cmd.ExecuteScalar().ToString());                        endRow = pageSize * currentPage;                        startRow = pageSize * currentPage > pagerModel.totalRows ? pagerModel.totalRows - pageSize * (currentPage - ) : pageSize;                        if (startRow <= 0) { pagerModel.result = new List<T>();  pagerModel; }                        string[] orderbyArr = {0} ascorderby.Trim()).Split(' );                        sb.AppendFormat(                            select * from(                            select top {4} * from                             (select top {3} * from ({0}) order by {1} asc)                            order by {1} desc                            ) order by {1} {2}0],1)">],endRow,1)">;                }                List<T> List = FindListBysql<T>(sb.ToString());                pagerModel.result = List;            }             pagerModel;        }        <typeparam name="T"></typeparam>        <param name="sql"></param>        <returns></returns>        int currentPage,connection);                         cmdParms) cmd.Parameters.Add(parm);                        pagerModel.totalRows = .Parse(cmd.ExecuteScalar().ToString());                        cmd.Parameters.Clear();                        endRow = pageSize *(sb.ToString(),cmdParms);                pagerModel.result = pagerModel;        }        static DataSet FindPageBysql(out int totalCount,1)"> DbParameter[] cmdParms)        {            DataSet ds = ;                totalCount =  cmdParms) cmd.Parameters.Add(parm);                        totalCount =  currentPage;                        startRow = pageSize * currentPage > totalCount ? totalCount - pageSize * (currentPage - 0) { ; }                        ;                }                ds = query(sql,cmdParms);            }             ds;        }        #region getReaderValue 转换数据         转换数据         Object getReaderValue(Object rdValue,Type ptype)        {            if (ptype == double))                 Convert.Todouble(rdValue);            decimal Convert.ToDecimal(rdValue);             Convert.ToInt32(rdValue);            long Convert.ToInt64(rdValue);            (DateTime))                 Convert.ToDateTime(rdValue);            typeof(Nullable<double>decimal>int>long>typeof(Nullable<DateTime> rdValue;        }        #region 获取主键名称         获取主键名称         GetIDname(Type type)        {            PropertyInfo[] propertyInfoList = GetEntityPropertIEs(type);             propertyInfo.name;                }            }            ID#region 获取主键值        object GetIDVal( val)        {            string IDname = GetIDname(val.GetType());            .IsNullOrWhiteSpace(IDname))            {                return val.GetType().GetProperty(IDname).GetValue(val,1)">);            }            #region 获取实体类属性         获取实体类属性         PropertyInfo[] GetEntityPropertIEs(Type type)        {            List<PropertyInfo> result = new List<PropertyInfo>();            PropertyInfo[] propertyInfoList = type.GetPropertIEs();            typeof(EdmRelationshipNavigationPropertyAttribute),1)">false).Length == 0                    && propertyInfo.GetCustomAttributes(typeof(browsableAttribute),1)">)                {                    result.Add(propertyInfo);                }            }             result.ToArray();        }        #region 获取基类         获取基类         Type GetBaseType(Type type)        {            while (type.BaseType != null && type.BaseType.name != (Object).name)            {                type = type.BaseType;            }             type;        }        #region 事务        #region 开始事务         开始事务        voID BeginTransaction()        {            DbConnection conn = GetConnection();             ConnectionState.Open) conn.open();            m_Tran = conn.BeginTransaction();        }        #region 提交事务         提交事务         CommitTransaction()        {            return; //防止重复提交            DbConnection conn = m_Tran.Connection;                        {                m_Tran.Commit();            }             (Exception ex)            {                m_Tran.Rollback();            }            if (conn.State == ConnectionState.Open) conn.Close();                m_Tran.dispose();                m_Tran = #region 回滚事务(出错时调用该方法回滚)         回滚事务(出错时调用该方法回滚)         RollbackTransaction()        {            防止重复回滚            DbConnection conn = m_Tran.Connection;            m_Tran.Rollback();             ConnectionState.Open) conn.Close();        }        #endregion    }}

sqlString类代码(更方便的参数化查询)：

 System.linq; System.Threading.Tasks; System.Configuration; 参数化查询sql字符串     sqlString    {        #region 变量属性        ];        private StringBuilder _sql =  StringBuilder();        private List<DbParameter> _paramList = new List<DbParameter>();        private Regex _regex = [@|:]([\w]+) 参数化查询的参数        public DbParameter[] Params { get {  _paramList.ToArray(); } }         参数化查询的sql        string sql {  _sql.ToString(); } }        #region 构造函数        public sqlString(params [] args)        {            Appendsql(sql,args);        }        #region Appendsql         追加参数化sql        sql<param name="args">参数voID Appendsql([] args)        {            Dictionary<object> dict = object>();            MatchCollection mc = _regex.Matches(sql);            foreach (Match m  mc)            {                string val1 = m.Groups[].Value;                dict.ContainsKey(val1))                {                    dict.Add(val1,1)">);                    sql = Replacesql(sql,m.Value,val1);                }            }            if (args.Length < dict.Keys.Count) sqlString.AppendFormat参数不够);            List<string> keyList = dict.Keys.ToList();            0; i < keyList.Count; i++)            {                _paramList.Add(DBHelper.GetDbParameter(keyList[i],args[i]));            }            _sql.Append(sql);        }        #region AppendFormat         封装StringBuilder AppendFormat 追加非参数化sql        voID AppendFormat([] args)        {            if (_regex.IsMatch(sql)) 追加参数化sql请使用Appendsql);            _sql.AppendFormat(sql,1)">#region ToString        overrIDe  ToString()        {             _sql.ToString();        }        #region Replacesql        string Replacesql(string oldStr,1)"> name)        {            string newStr = DBHelper.GetParameterMark() + name;             sql.Replace(oldStr,newStr);        }            }}

说明：DBHelper中对事务变量private static DbTransaction m_Tran使用了[ThreadStatic]标签，以支持多用户并发；但是如果是单个用户使用多线程并发请求服务器，可能这种方式的数据库事务是不支持的，不过一般项目没有这种需求，如果有请使用httpContext.Current.Items改写或者其它方法改写。

Web.config配置：

<connectionStrings>  add name="DefaultConnection"  connectionString="server=localhost;database=netCMS3.0;user ID=root;password=root;character set=gbk;" /></>appSettings<!--数据库类型-->  key="DBType" value="MysqL"/>  数据库自增="autoIncrement"="false">

说明：对于sql Server数据库，通过<add key="autoIncrement" value="false"/>来设置是否使用数据库自增。

DBHelper类库需要引用的程序集：

除VS2012自带的DLL外需要的DLL：

mysql.data.dll

System.Data.sqlite.dll

其中Models类库如下：

说明：Models目录中的类及其属性和数据库中的表和字段是完全对应的，Models全部由生成器生成，并且不允许手动修改。ExtModels目录中的类是扩展类，主要用于查询与显示，比如表中存的是code，但你需要关联查询另一张表中的name，就可以在这个扩展类中扩展一个用于显示的name字段。Models和ExtModels目录的中类都是partial修饰。

PagerModel类：

 System.Collections; System.Web; Models{     分页     PagerModel    {        #region 字段         当前页数        int page { get; set; }         每页记录数        int rows {  排序字段        string sort {  排序的方式asc，desc        string order {  记录        object result {  记录数        int totalRows { ; }        public PagerModel()        {        }        ///         <param name="page">当前页数<param name="rows">每页记录数public PagerModel(int page,1)"> rows)        {            this.page = page;            this.rows = rows;        }        #region 扩展字段         总页数         pageCount        {            getreturn (totalRows - 1) / rows + ;            }        }         上一页         prePage        {            if (page - 1 > return page - ;                }                 下一页         nextPage        {            if (page + 1 < pageCount)                {                    return page +  pageCount;            }        }            }}

IsIDAttribute类：

@H_419_1861@

 System.Text; 标识该属性是主健    </summary>    [Serializable,AttributeUsage(AttributeTargets.Property | AttributeTargets.Class)]     IsIDAttribute : Attribute    {    }}

IsDBFIEldAttribute类：

 标识该属性是数据库字段     IsDBFIEldAttribute : Attribute    {    }}

autoIncrementAttribute类(可以加在主键字段上，也可以加在类上)：

 System.Threading.Tasks; 标识该属性是自增字段 或 标识该类的主键是自增字段     autoIncrementAttribute : Attribute    {    }}

Models示例：

 System.linq; 内容详情        [Serializable]    partial  CMS_content    {         编号                [IsID]        [IsDBFIEld]        int ID {  所属栏目ID                [IsDBFIEld]        int? channelID {  标题        string Title {  内容        string contents {  作者        string author {  阅读次数        int? readCount {  发布时间        public DateTime? publishTime {  发布者        int? publishUserID {  审核(0待审1通过2不通过)        int? audit {  审核人        int? auditUserID {  审核时间        public DateTime? auditTime {  页面关键词        string keywords {  页面描述        string description {  页面链接        string pageUrl {  内容封面        string imgurl {  是否链接(0否1是)        int? isPageUrl {  模板(模板文件名，例：content.HTML)        string template {  推荐(1推荐0不推荐)        int? recommend { ; }    }}

ExtModels示例：

 栏目名称        string channelname {  用户显示名        string showname {  审核状态         dispAudit        {            switch (this.audit ?? 待审核审核通过2审核不通过error { }        }         在当前页中的索引        int curPageSort {  是否为空，模板使用，0不为空1为空        int isNull { ; }    }}

如何使用：

说明：支持参数化的增删改查，推荐使用参数化的增删改查；非参数化的增删改查过滤了部分数据库关键字以防止sql注入，但可能仍然不安全。下面例子中的添加、修改、根据ID删除、根据ID集合批量删除都是参数化的，示例中的查询和其它方式的删除不是参数化的，DBHelper提供了相关的参数化查询和执行sql。

添加：

<summary> 添加 obj){    DBHelper.Insert(obj);}

说明：sql Server数据库可以使用自增，Oracle数据库可以使用Sequence，小系统可以使用DBHelper自带的GetMaxID方法。

获取最大ID(当然，ID一般采用自增，对于并发量极少的系统，或单机系统，为了省事，可以这样做)：

 GetMaxID GetMaxID(){    return DBHelper.GetMaxID<BS_Template>(ID);}

修改：

 修改 obj){    DBHelper.Update(obj);}

删除：

根据ID删除：

 删除voID Del( ID){    DBHelper.Delete<BS_Template>(ID);}

根据ID集合批量删除：

voID BatchDelete( IDs){    DBHelper.BatchDelete<BS_Template>(IDs);}

根据条件删除：

voID Delete( conditions){    DBHelper.Delete<BS_Template>(conditions);}

其它方式的删除请使用：

public static int Executesql(string sqlString)

根据ID查询实体：

public CMS_content Get( ID){    return DBHelper.FindByID<CMS_content>(ID.ToString());}

查询：

public List<CMS_content> GetListAll(){    StringBuilder sql = new StringBuilder(        select content.*,channel.Title as channelname,user.showname        from CMS_content content        left join CMS_channel channel on channel.ID=content.channelID        left join CMS_sys_user user on user.ID=content.publishUserID        where content.audit=1         order by publishTime desc,ID desc));    return DBHelper.FindListBysql<CMS_content>(sql.ToString());}

说明：ExtModels下的扩展Model，可以支持查询数据库中不存在的字段，并映射填充到实体类。

分页查询：

public List<CMS_content> GetList(ref PagerModel pager,1)">int channelID,1)">string Title,1)"> audit){    StringBuilder sql = if (channelID != -)    {        sql.AppendFormat( and content.channelID = {0}.IsNullOrWhiteSpace(Title))    {        sql.AppendFormat( and content.Title like '%{0}%'if (audit != - and content.audit = {0}orderby = order by content.publishTime desc,1)">);    pager = DBHelper.FindPageBysql<CMS_content>(sql.ToString(),pager.rows,pager.page);    return pager.result as List<CMS_content>;}

数据库事务：

{    DBHelper.BeginTransaction(); 开启数据库事务    在这里写增删改 *** 作    DBHelper.CommitTransaction(); 提交数据库事务}(Exception ex){    DBHelper.RollbackTransaction(); 回滚数据库事务}

DAL层增删改查示例：

@H_419_2416@

@H_694_2419@

 DBUtil; DAL{     内容详情管理     ContentDal    {         audit)        {            StringBuilder sql =                 select content.*,user.showname                from CMS_content content                left join CMS_channel channel on channel.ID=content.channelID                left join CMS_sys_user user on user.ID=content.publishUserID                where 1=1 ));            )            {                sql.AppendFormat(.IsNullOrWhiteSpace(Title))            {                sql.AppendFormat();            pager = DBHelper.FindPageBysql<CMS_content>(sql.ToString(),pager.page);            <param name="pager">分页<param name="channel">栏目，可以是栏目ID或栏目名称<param name="where">where语句string channel,1)">where)        {            StringBuilder sql = ))            {                sql.AppendFormat( and {0});            }            .IsNullOrWhiteSpace(channel))            {                ChannelDal channelDal =  ChannelDal();                if (Regex.IsMatch(channel,1)">^\d+$")) 数字，即栏目ID                {                    string channelIDs = channelDal.GetChildIDs(Convert.ToInt32(channel));                    sql.AppendFormat( and channelID in ({0})非数字，即栏目名称 channelDal.GetChildIDs(channel);                    sql.AppendFormat(order by publishTime desc,1)">if (pager.rows > )            {                PagerModel pagerModel = DBHelper.FindPageBysql<CMS_content>(sql.ToString(),pager.page);                pager.totalRows = pagerModel.totalRows;                pager.result = pagerModel.result;                List<CMS_content> List = pagerModel.result ;                List.ForEach(a =>                {                    a.curPageSort = i++;                });                return pagerModel.result return DBHelper.FindListBysql<CMS_content>(sql.ToString() + );            }        }         GetListAll()        {            StringBuilder sql = (sql.ToString());        }        #region 获取总数         获取总数         GetAllCount()        {            StringBuilder sql =                 select count(*)                from CMS_content content                where content.audit=1 Convert.ToInt32(DBHelper.GetSingle(sql.ToString()));        }        #region 获取         获取        (ID.ToString());        }         根据channelID获取一条内容详情        public CMS_content GetByChannelID( channelID)        {            return DBHelper.FindBysql<CMS_content>(select * from CMS_content where channelID={0} and audit=1public CMS_content GetNext( ID)        {            CMS_content current = Get(ID);            select * from CMS_content where ID<{0} and channelID={1} and audit=1 order by ID desc limit 0,1public CMS_content GetPre(select * from CMS_content where ID>{0} and channelID={1} and audit=1 order by ID asc limit 0,current.channelID));        }         Insert(CMS_content model)        {            model.ID = DBHelper.GetMaxID<CMS_content>();            DBHelper.Insert(model);        }         Update(CMS_content model)        {            DBHelper.Update(model);        }         删除         IDs)        {            DBHelper.BatchDelete<CMS_content>(IDs);        }            }}

 Models; DAL{     TestMysqLDal    {        #region 获取集合 (参数化查询)         获取集合        public List<utils_test> GetList3( name,DateTime startTime,DateTime endTime)        {            sqlString sql = new sqlString(                select *                from utils_test t                where 1=1 );            sql.Appendsql( and name like @name%" + name +  and (add_time between @startTime and @endTime)yyyy-MM-dd HH:mm:ss"),endTime.ToString());            List<utils_test> result = DBHelper.FindListBysql<utils_test>(sql.sql,sql.Params);             result;        }        #region 获取集合 (参数化非参数化混合查询)        public List<TWO_ORDER> GetList(int? status)        {            sqlString sql =                 select *                from two_order t                where 1=1                 and DEL_FLAG=@delFlag0                 and (                    ORDER_TIME>=STR_TO_DATE(@startTime,'%Y-%m-%d %H:%i:%s')                     and ORDER_TIME<=STR_TO_DATE(@endTime,'%Y-%m-%d %H:%i:%s')                ).IsNullOrWhiteSpace(name))            {                sql.Appendsql( and PRISONER_name like @nameif (status != )            {                sql.Appendsql( and T_STATUS = @status and 1=1"); 测试没有参数            sql.Appendsql( order by ORDER_TIME desc,ID asc测试排序            List<TWO_ORDER> result = DBHelper.FindListBysql<TWO_ORDER>#region 分页获取集合 (参数化非参数化混合查询)         分页获取集合         public List<TWO_ORDER> GetListPage(new sqlString(                select *                from two_order t                where 1=1                 and DEL_FLAG='{0}'));            sql.Appendsql( and T_STATUS = '{0}'测试追加非参数化sql            }            sql.Appendsql(测试没有参数            orderby = order by ORDER_TIME desc,1)">"; 测试排序            pager = DBHelper.FindPageBysql<TWO_ORDER>(sql.sql,pager.page,1)">as List<TWO_ORDER> obj)        {            DBHelper.Insert(obj);        }        #region 查询单个记录 (参数化查询)         查询单个记录        public utils_test Get( name)        {            sqlString sql =                 select *                from utils_test t                where 1=1                 and name=@name    }}

 统计sqlstring GetReportsql( formData){    ProductInvoiceModel search = JsonConvert.DeserializeObject<ProductInvoiceModel>(formData);    StringBuilder sql =         select * from         (select distinct         '出库单' as '报表类型',pos.billNo as '单据编号',pos.projectCode as '项目编号',pro.projectname as '项目名称',ma.subProject as '项目子项',case when cs.conMemberCode is not NulL then cs.conMemberCode else mat.materialCode end as '构件编码',case when cmd.membername is not NulL then cmd.membername else mat.materialname end as '材料名称',case when cs.conMemberCode is not NulL then '构件' else '物料' end as '类型',mad.model as '规格型号',dic1.dicItem as '单位',posd.qty as '数量',CONVERT(varchar(100),pos.billDate,23) as '日期'                        from Pro_ProductOutStorageDet posd        left join Pro_ProductOutStorage pos on pos.ID=posd.parentID        left join Pro_MatAllotDet mad on posd.matAllotDetID=mad.ID        left join Pro_MatAllot ma on ma.ID=mad.parentID and ma.status=2        left join Pro_MatStock ms on ms.ID=mad.matStockID and mad.memberType=1        left join Pro_ConStock cs on cs.ID=mad.matStockID and mad.memberType=0        left join sys_material mat on mat.materialCode=ms.materailCode        left join Pro_ProductInstorage pi on pi.billNo=cs.billNo        left join Pro_ProductInstorageDet pID on pID.parentID=pi.ID        left join Pro_ConMember cm on cm.billCode=pi.conMemberBillNo        left join Pro_ConMemberDet cmd on cmd.ID=pID.conMemberDetID        left join Pro_Info pro on pos.projectCode=pro.projectNum        left join sys_dicDetail dic1 on dic1.dicItemcode=mad.unitCode          union all        select distinct         'XXX出库单' as '报表类型','' as '项目子项',case when cmd.model is not NulL then cmd.model else mat.model end as '规格型号',case when dic1.dicItem  is not NulL then dic1.dicItem  else dic2.dicItem  end as '单位',23) as '日期'                        from Pro_ProductOut2StorageDet posd        left join Pro_ProductOut2Storage pos on pos.ID=posd.parentID        left join Pro_MatStock ms on ms.ID=posd.matStockID        left join Pro_ConStock cs on cs.ID=posd.conInventoryDetID        left join sys_material mat on mat.materialCode=ms.materailCode        left join Pro_ProductInstorage pi on pi.billNo=cs.billNo        left join Pro_ProductInstorageDet pID on pID.parentID=pi.ID        left join Pro_ConMember cm on cm.billCode=pi.conMemberBillNo        left join Pro_ConMemberDet cmd on cmd.ID=pID.conMemberDetID        left join Pro_Info pro on pos.projectCode=pro.projectNum        left join sys_dicDetail dic1 on dic1.dicItemcode=mat.unitCode          left join sys_dicDetail dic2 on dic2.dicItemcode=cmd.qtyUnit          union all        select distinct         '生产消耗单' as '报表类型',pc.billCode as '单据编号',pro.projectNum as '项目编号',ll.subProject as '项目子项',pcd.consumeQty as '数量',pc.billDate,23) as '日期'                        from Pro_ProductConsume pc        left join Pro_ProductConsumeDet pcd on pcd.parentID=pc.ID        left join Pro_lingliaoDet lld on lld.ID=pcd.lingliaoDetID        left join Pro_lingliao ll on ll.ID=lld.parentID        left join Pro_MatStock ms on ms.ID=lld.matStockID and lld.memberType=1        left join Pro_ConStock cs on cs.ID=lld.matStockID and lld.memberType=0        left join sys_material mat on mat.materialCode=ms.materailCode        left join Pro_ProductInstorage pi on pi.billNo=cs.billNo        left join Pro_ProductInstorageDet pID on pID.parentID=pi.ID        left join Pro_ConMember cm on cm.billCode=pi.conMemberBillNo        left join Pro_ConMemberDet cmd on cmd.ID=pID.conMemberDetID        left join Pro_ProTask pt on pt.billCode=ll.proTaskCode        left join Pro_Info pro on pt.proInfCode=pro.billCode        left join sys_dicDetail dic1 on dic1.dicItemcode=mat.unitCode          left join sys_dicDetail dic2 on dic2.dicItemcode=cmd.qtyUnit          ) T where 1=1 .IsNullOrEmpty(search.projectname))    {        sql.AppendFormat(  and T.项目名称 like '%{0}%' .IsNullOrEmpty(search.projectCode))    {        sql.AppendFormat(  and T.项目编号 like '%{0}%' string.IsNullOrEmpty(search.btime) && !.IsNullOrEmpty(search.etime))    {        sql.AppendFormat( and  T.日期  >=  '{0}' and  T.日期  <=  '{0}' sql.ToString();}

        public List<MatAllotModel> GeProMatAllotList(string billCode,1)">string projectNum,1)">string projectname,1)">string remarks,1)"> status)        {            string sql = select v.*,ISNulL(v.IsFinish,(case when ISNulL(v.pqty,0)= ISNulL(v.mqty,0) then 1 else 0 end)) as IsEnd from (select ma.*,e.name + '('+isnull(e.mobilephone,'')+')' as billCreatorname,i.projectname,s.storeHousename as inStorename,(select stuff((select distinct ','+s.storeHousename from Pro_MatAllotDet madjoin sys_storehouse s on mad.outStorageCode=s.storeHouseCodewhere parentID =ma.ID for xml path('')),1,'')) as outStorename,I.projectSim,D.dicItem AS typename,ppi.ID as InvoiceID,i.projectNum,(select sum(md.qty) from Pro_MatAllotDet md  where md.parentID =ma.ID) as mqty,(select sum(qty) from Pro_ProductOutStorageDet pod left join Pro_ProductOutStorage po on po.ID = pod.parentIDwhere po.matAllotBillCode = ma.billCode) as pqtyfrom Pro_MatAllot majoin sys_storehouse s on ma.inStoreCode=s.storeHouseCodejoin sys_employee e on ma.billCreator=e.employeeCodeleft join Pro_ProductInvoice ppi on ppi.MatAllotBillCode=ma.billCodeleft join Pro_Info i on ma.projectCode = i.projectNumleft JOIN sys_dicDetail D ON D.dicItemcode = I.projectType) as v where 1=1 .IsNullOrEmpty(billCode))            {                sql +=  and v.billCode like '%" + billCode.Trim() + %'.IsNullOrEmpty(projectname))            {                sql +=  and v.projectname like '%" + projectname.Trim() + .IsNullOrEmpty(projectNum))            {                sql +=  and v.projectNum like '%" + projectNum.Trim() + .IsNullOrEmpty(remarks))            {                sql +=  and v.remarks like '%" + remarks.Trim() + ;            }            sql +=  and v.status=" + status + "";            List<MatAllotModel> matAllot = EntityHelper.Default.GetPageEntitIEs<MatAllotModel>(pager.page,pager.sort,pager.order);            pager.totalRows = DBHelper.Default.Count(sql);            pager.result = matAllot;             matAllot;        }

static List<ConStockDialogMod> GetMaterialData(string membername,1)">string storeCode,1)">string parentID,1)"> store){    StringBuilder where = new StringBuilder( and 1=1 );    string.IsNullOrEmpty(membername))              当物料为空时，查询出所有的结果集，否则查询出此种相似物料的结果集        where.AppendFormat(  and t3.membername like '%{0}%' string.IsNullOrEmpty(storeCode))                and SSH.storeHouseCode='{0}' string.IsNullOrEmpty(parentID))                and t3.parentID = {0} .IsNullOrEmpty(store))          and SSH.storeHousename like '%{0}%'  SELECT PM.ID,PM.conMemberCode as conMemberCode,PM.price,(PM.qty-PM.lockQty-PM.usedQty) AS stockNum,PM.instoreTime,PM.billNo,PM.storeCode,PM.lockQty,PM.usedQty,SSH.storeHousename AS storename,t3.allWeight,t3.qtyUnit,t3.weight as weights,t3.membername,t3.model,t3.qulity,d1.dicItem as allWeightUnitname,d2.dicItem as qtyUnitname,d3.dicItem as qulityname,d4.dicItem as weightUnitname,(select SUM(pt.qty) from Pro_ProductOutstorageDet pt where pt.conInventoryDetID=PM.ID)as outQty          from Pro_ConStock PM        join Pro_ConPurInstore cpd on PM.billNo=cpd.billCode        join Pro_ConPurInstoreDet cp on cpd.ID=cp.parentID and PM.billID=cp.ID        join dbo.Pro_ConGoodsDet t on t.ID=cp.conGoodsDetID        join dbo.Pro_ConPurchaseContractDet t1 on t1.ID=t.conContractDetID        join dbo.Pro_ConPurchasePlanDet t2 on t2.ID=t1.conPlanDetID        join dbo.Pro_ConMemberDet t3 on t3.ID=t2.conMemberDetID        left join sys_storehouse SSH on SSH.storeHouseCode=PM.storeCode        left join sys_dicDetail d1 on d1.dicItemcode=t3.allWeightUnit        left join sys_dicDetail d2 on d2.dicItemcode=t3.qtyUnit        left join sys_dicDetail d3 on d3.dicItemcode=t3.qulity        left join sys_dicDetail d4 on d4.dicItemcode=t3.weightUnit         WHERE  PM.qty-PM.lockQty-PM.usedQty > 0  " + where +     union         SELECT PM.ID,(select SUM(pt.qty) from Pro_ProductOutstorageDet pt where pt.conInventoryDetID=PM.ID)as outQty          from Pro_ConStock PM        join Pro_ProductInstorage cpd on PM.billNo=cpd.billNo        join Pro_ProductInstorageDet cp on cpd.ID=cp.parentID and PM.billID=cp.ID        join dbo.Pro_ConMemberDet t3 on t3.ID=cp.conMemberDetID        left join sys_storehouse SSH on SSH.storeHouseCode=PM.storeCode        left join sys_dicDetail d1 on d1.dicItemcode=t3.allWeightUnit        left join sys_dicDetail d2 on d2.dicItemcode=t3.qtyUnit        left join sys_dicDetail d3 on d3.dicItemcode=t3.qulity        left join sys_dicDetail d4 on d4.dicItemcode=t3.weightUnit          WHERE  PM.qty-PM.lockQty-PM.usedQty > 0 ;    List<ConStockDialogMod> model = EntityHelper.Default.GetPageEntitIEs<ConStockDialogMod>(pager.page,sql.ToString(),pager.order);    pager.totalRows = DBHelper.Default.Count(sql.ToString());    pager.result = model;     model;}

         sql        <param name="formData"></param>         formData)        {            TaskAllocationModel search = JsonConvert.DeserializeObject<TaskAllocationModel>(formData);            StringBuilder  where 1=1 .IsNullOrEmpty(search.projectCode))            {                  and ta.projectCode like '%{0}%' .IsNullOrEmpty(search.projectname))            {                  and pro.projectname like '%{0}%' select ta.billCode as '单号',ta.desingBillCode as '项目设计任务单',CASE ta.violent WHEN '1' THEN '是' ELSE '否' END as '是否加急',CASE ta.taskType WHEN '0' THEN '载荷图' WHEN '1' THEN '方案图' WHEN '2' THEN '工程量统计' ELSE '载荷图与工程量统计' END as '任务类型',ta.desingContent as '设计内容',ta.auditorscore as '审核人打分',(select e.Realnamefrom Wf2Operate oper left join Wf2Node n on n.ID = oper.Wf2NoteID left join employee e on e.employeecode = oper.Operator where Wf2InstanceID = ta.LastWf2InstanceID and n.name='设计' and oper.OperationID != -3) as '设计者',(select e.Realnamefrom Wf2Operate oper left join Wf2Node n on n.ID = oper.Wf2NoteID left join employee e on e.employeecode = oper.Operator where Wf2InstanceID = ta.LastWf2InstanceID and n.name='校对' and oper.OperationID != -3) as '校对者',(select e.Realnamefrom Wf2Operate oper left join Wf2Node n on n.ID = oper.Wf2NoteID left join employee e on e.employeecode = oper.Operator where Wf2InstanceID = ta.LastWf2InstanceID and n.name='审核' and oper.OperationID != -3) as '审核者',(select e.Realnamefrom Wf2Operate oper left join Wf2Node n on n.ID = oper.Wf2NoteID left join employee e on e.employeecode = oper.Operator where Wf2InstanceID = ta.LastWf2InstanceID and n.name='审定' and oper.OperationID != -3) as '审定者',e.name as '创建人',ta.creatTime as '创建时间'from Pro_TaskAllocation taleft join Pro_Info pro on ta.projectCode=pro.projectNumleft join sys_employee e on ta.creator=e.employeeCode                   sql.ToString();        }

            select t.*,t.haveQty as weichukuNum,(t.qty - t.chukuNum) as shenyuNum  from (SELECT o.*,( case memberType when 1 then (SELECT (qty- lockQty- usedQty)  FROM Pro_MatStock s where s.ID=o.matStockID ) when 0 then ((SELECT (qty- lockQty- usedQty)  FROM Pro_ConStock s where s.ID=o.matStockID )) else 0 end) as haveQty,(case memberType when 1 then (SELECT materialname from sys_material where materialCode = o.code ) when 0 then (select disTINCT membername from Pro_ConMemberDet v left join Pro_ConMember g on g.ID=v.parentID where v.memberCode=o.code and g.billCode=ma.conMemberBillNo) else '' end) as materialname,sh.storeHousename as outStoragename,isnull((case memberType when 1 then (select SUM(pt.qty) from Pro_ProductOutstorageDet pt left join Pro_ProductOutstorage p on p.ID=pt.parentID where pt.matStockID=o.matStockID and p.status in (1,2)) when 0 then (select SUM(pt.qty) from Pro_ProductOutstorageDet pt left join Pro_ProductOutstorage p on p.ID=pt.parentID where pt.conInventoryDetID=o.matStockID and p.status in (1,2)) else 0 end),0) as chukuNum,(case memberType when 1 then (select SUM(ms.qty-ms.lockQty-ms.usedQty) from Pro_MatStock ms where ms.storeCode=ma.inStoreCode AND ms.materailCode =o.code) when 0 then (select SUM(cs.qty-cs.lockQty-cs.usedQty) from Pro_ConStock cs where cs.storeCode=ma.inStoreCode AND cs.conMemberCode =o.code) else 0 end) as xiangmukuNum from  Pro_MatAllotDet o  JOIN Pro_MatAllot ma on o.parentID = ma.ID join sys_storehouse sh on o.outStorageCode=sh.storeHouseCode   where o.parentID in ({0})) t where t.chukuNum < t.qtyVIEw Code
 
          总结       
以上是内存溢出为你收集整理的C#/ASP.NET完善的DBHelper，配套Model生成器全部内容，希望文章能够帮你解决C#/ASP.NET完善的DBHelper，配套Model生成器所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。
					
										


					

						
欢迎分享，转载请注明来源：内存溢出
原文地址: http://outofmemory.cn/langs/1212624.html