超级代码工厂(强大实用的代码生成工具)

/************************************************************************************ * ${CopyRight} * File: * Base${DAOClassPostFix}.cs * Description: * 基于泛型数据访问抽象基类 * Author: * ${Author} * ${AuthorEmail} * ${Online} * Finish DateTime: * ${Date} * History: * ***********************************************************************************/ using System; using System.Collections.Generic; using System.Text; using System.Reflection; using System.Data; using System.Data.SqlClient; namespace ${DAONameSpace} { using ${ComponentNameSpace}; /// <summary> /// 基于泛型数据访问抽象基类，封装了基本数据访问操作CRUD /// </summary> /// <typeparam name="T"></typeparam> public abstract class Base${DAOClassPostFix}<T> : IBase${DAOClassPostFix}<T> { #region 私有字段 private XmlClassMap classMap; //实体类的映射信息 private Dictionary<string, PropertyInfo> properties = new Dictionary<string, PropertyInfo>(); //实体类的属性信息 private string procedureName = "MesnacPaging"; //分页存储过程名 #endregion #region 构造方法 public Base${DAOClassPostFix}() { //获取实体类T的映射信息 this.classMap = EntityMapperHandler.GetInstance().GetMapDictionary()[typeof(T).Name]; //获取实体类的属性信息 PropertyInfo[] pis = typeof(T).GetProperties(); foreach (PropertyInfo pi in pis) { if (this.classMap.Properties.ContainsKey(pi.Name)) { this.properties.Add(this.classMap.Properties[pi.Name].ColumnName, pi); } } } #endregion #region 受保护方法 /// <summary> /// 封装数据表数据到实体集合的方法 /// </summary> /// <param name="cmdType">命令类型</param> /// <param name="cmdText">要执行的SQL语句或存储过程名称</param> /// <param name="values">SQL语句或存储过程的参数列表</param> /// <returns>返回实体类的集合</returns> protected List<T> GetBySql(CommandType cmdType, string cmdText, SqlParameter[] values) { using (SqlDataReader reader = DBHelper.GetReader(DBHelper.CONSTR, cmdType, cmdText, values)) { List<T> lst = new List<T>(); Type entityType = typeof(T); PropertyInfo[] properties = entityType.GetProperties(); Dictionary<string, XmlClassMap> dic = EntityMapperHandler.GetInstance().GetMapDictionary(); XmlClassMap classMap = dic[entityType.Name]; while (reader.Read()) { T entity = (T)entityType.Assembly.CreateInstance(entityType.FullName); foreach (PropertyInfo property in properties) { if (property.CanWrite && classMap.Properties.ContainsKey(property.Name)) { object value = reader[classMap.Properties[property.Name].ColumnName]; if (value != null && value != DBNull.Value) { property.SetValue(entity, value, null); } } } lst.Add(entity); } reader.Close(); return lst; } } #endregion #region IBase${DAOClassPostFix}<T> 成员 /// <summary> /// 按住键或标识列查找，只有是单字段主键（非组合键）时才按主键查找 /// </summary> /// <param name="id">对应查找记录的主键值或标识值</param> /// <returns>返回对应记录的实体信息</returns> public T GetById(object id) { string cmdText = "select * from {0} where {1}"; string where = String.Empty; List<SqlParameter> parameters = new List<SqlParameter>(); if (this.classMap.Ids.Keys.Count == 1) { //如果主键字段是一个字段则按主键字段查询 foreach (XmlPropertyMap pm in this.classMap.Ids.Values) { where = pm.ColumnName + "=@" + pm.ColumnName; parameters.Add(new SqlParameter("@" + pm.ColumnName, id)); break; } } else if (this.classMap.Identity != null) { //如果没有主键，或者主键字段不止一个，则按标识列查询 where = this.classMap.Identity.ColumnName + "=@" + this.classMap.Identity.ColumnName; parameters.Add(new SqlParameter("@" + this.classMap.Identity.ColumnName, id)); } else { //如果没有标识列，或者没有主键，或者主键字段不只一个则按表中的第一个字段查询 foreach (XmlPropertyMap pm in this.classMap.Properties.Values) { where = pm.ColumnName + "=@" + pm.ColumnName; parameters.Add(new SqlParameter("@" + pm.ColumnName, id)); break; } } cmdText = String.Format(cmdText, this.classMap.TableName, where); T entity = default(T); List<T> lst = this.GetBySql(CommandType.Text, cmdText, parameters.ToArray()); if (lst != null && lst.Count > 0) entity = lst[0]; return entity; } /// <summary> /// 指定参数的查询 /// </summary> /// <param name="values">查询参数列表，KeyValuePair的Key是字段名,KeyValuePair的Value是字段值</param> /// <returns>返回实体类的集合</returns> public List<T> GetListByParam(params KeyValuePair<string, object>[] values) { string cmdText = "select * from {0} {1}"; string where = String.Empty; List<SqlParameter> parameters = new List<SqlParameter>(); foreach (KeyValuePair<string, object> kvp in values) { where = String.IsNullOrEmpty(where) ? "where " + kvp.Key + "=@" + kvp.Key : where + " and " + kvp.Key + "=@" + kvp.Key; parameters.Add(new SqlParameter("@" + kvp.Key, kvp.Value)); } cmdText = String.Format(cmdText, this.classMap.TableName, where); List<T> lst = this.GetBySql(CommandType.Text, cmdText, parameters.ToArray()); return lst; } /// <summary> /// 指定参数的查询 /// </summary> /// <param name="values">查询参数列表</param> /// <returns>返回实体类的集合</returns> public List<T> GetListByParam(Dictionary<string, object> values) { string cmdText = "select * from {0} {1}"; string where = String.Empty; List<SqlParameter> parameters = new List<SqlParameter>(); foreach (KeyValuePair<string, object> kvp in values) { where = String.IsNullOrEmpty(where) ? "where " + kvp.Key + "=@" + kvp.Key : where + " and " + kvp.Key + "=@" + kvp.Key; parameters.Add(new SqlParameter("@" + kvp.Key, kvp.Value)); } cmdText = String.Format(cmdText, this.classMap.TableName, where); List<T> lst = this.GetBySql(CommandType.Text, cmdText, parameters.ToArray()); return lst; } /// <summary> /// 指定参数查询并排序 /// </summary> /// <param name="order">排序条件</param> /// <param name="values">查询参数列表</param> /// <returns>返回实体类的集合</returns> public List<T> GetListOrderByParam(string order, params KeyValuePair<string, object>[] values) { s