.Net自己写个简单的ORM（练手）

        PRivate static string ConnectionString = "**";                 /// <summary>        ///  更新数据   没有sql参数就直接执行          /// </summary>        /// <param name="sql"> 需要执行的 sql </param>        /// <param name="o">传递的实体类对象 要求该类中字段必须和 sql参数名称一致 不区分大小写 </param>        /// <returns></returns>        public static int UpdateModel(string sql, object o)        {            var s = sql.Split('@');            return Update(sql, s.Length == 1 ? null : GetSqlParameters(o, s));        }        /// <summary>        ///  查询数据        /// </summary>        /// <typeparam name="T">映射的实体类</typeparam>        /// <param name="sql">执行的SQL语句</param>        /// <param name="o">传递的实体类对象 要求该类中字段必须和 sql参数名称一致 不区分大小写 </param>        /// <returns></returns>        public static List<T> SeleteModel<T>(string sql, object o) where T : class, new()        {            var s = sql.Split('@');            return Select<T>(sql, s.Length == 1 ? null : GetSqlParameters(o, s));        }        /// <summary>        /// 动态创建SqlParameter 对象        /// </summary>        /// <param name="o">传递的实体类对象 要求该类中字段必须和 sql参数名称一致 不区分大小写 </param>        /// <param name="s">切割后的SQL 语句</param>        /// <returns></returns>        private static SqlParameter[] GetSqlParameters(object o, string[] s)        {            s = s.Select(c => c.Split(' ')[0].Trim()).ToArray();             Type t = o.GetType();            if (t == typeof(object))                throw new Exception("UpdateModel  传递的类型是OBJECT 类型");            // 反射 读取字段 验证是否是 SQL 中的参数            var tlist =                t.GetFields(BindingFlags.Public | BindingFlags.Instance)                    .Where(c => c.GetValue(o) != null & s.FirstOrDefault(a => a.ToLower() == c.Name.ToLower()) != null)                    .ToList();            // 判断得到的数据 是否和 需要的数据 数量一致            if (tlist.Count() != s.Count() - 1)                throw new Exception("传递的实体中有值参数 和 sql 中需要的 数量不相等");            SqlParameter[] sp = new SqlParameter[tlist.Count()];            for (int i = 0; i < s.Length - 1; i++)            {                sp[i] = new SqlParameter(s[i + 1].Trim(), tlist.FirstOrDefault(c => c.Name.ToLower() == s[i + 1].ToLower()).GetValue(o));            }            return sp;        }        private static List<T> SeleteModel<T>(SqlDataReader data) where T : class, new()        {            // 获取列 个数            int iFieldCount = data.FieldCount;            List<T> list = new List<T>();            while (data.Read())            {                T tType = new T();                for (int i = 0; i < iFieldCount; i++)                {                    // 反射注入字段值                    string dataName = data.GetName(i);                    FieldInfo fie = tType.GetType().GetField(dataName);                    if (fie == null)                        continue;                    fie.SetValue(tType, data[dataName]);                }                list.Add(tType);            }            return list;        }        private static List<T> Select<T>(string sql, SqlParameter[] sp) where T : class, new()        {            using (SqlConnection conn = new SqlConnection(ConnectionString))            {                using (SqlCommand com = new SqlCommand(sql, conn))                {                    conn.Open();                    if (sp != null)                        com.Parameters.AddRange(sp);                    return SeleteModel<T>(com.ExecuteReader());                }            }        }        private static int Update(string sql, SqlParameter[] sp)        {            using (SqlConnection conn = new SqlConnection(ConnectionString))            {                using (SqlCommand com = new SqlCommand(sql, conn))                {                    conn.Open();                    if (sp != null)                         com.Parameters.AddRange(sp);                     return com.ExecuteNonQuery();                }            }        }