.NET ORM框架（一）

最近作項目本身整理了一個ORM框架，分享給你們看看，有不少不足望你們指出。

下面是使用方法

BLL 主要方法

邏輯層：子類繼承父類， 直接用BASE調用 ManagerBLL 中的方法。

 public class TestBLL : ManagerBLL
    {
        public static TestBLL __instance = null;
        //原先有打算採用單列模式，結果悲劇啦！，後面只有總體修改下面這個方法。
        public static TestBLL GetInstance()
        {
            if (__instance == null) __instance = new TestBLL();
            return new TestBLL();
        }

        public void test() 
        {
            Admin_User admin=new Admin_User();
            admin.User_Name="";
            admin.User_NikeName="";         
            //條件
            WhereClip<Admin_User> where = new WhereClip<Admin_User>(a => a.User_Name=="x" && a.User_ID == 1 || a.User_RegIP=="dd");
            where.And(a=>a.User_Status==1);
            where.Or(a=>a.User_TrueName=="");
            //模糊條件
            where.And(a=>a.User_Password.Like(String.Format("%{0}%",1)));
            //列名
            ColumnsClip<Admin_User> columnsClip=new ColumnsClip<Admin_User>(a=>a.Columns(a.User_ID,a.User_LastIP,a.User_LoginNumber));
            //排序
            OrderByClip<Admin_User> orderByClip=new OrderByClip<Admin_User>(a=>a.OrderBy(a.User_ID.Desc(),a.User_LastIP.Asc()));
            //查詢第一行第一列
            base.GetCount(where);
            //查詢一行
            base.Get(columnsClip, where, orderByClip);
            //查詢成List
            base.GetList(0, columnsClip, where, orderByClip);
            //分頁查詢
            base.GetList(columnsClip, where, orderByClip, 10, 1, 0);
            //添加
            base.Add(admin);
            //批量添加-事物
            List<BaseEntity> list = new List<BaseEntity>();
            Admin_User admins = (Admin_User)admin.Clone();//深度複製
            list.Add(admin);
            list.Add(admins);
            base.AddList(list);
            //修改
            base.Edit(admin, where);
            //批量修改-事物
            Dictionary<BaseEntity, object> dic = new Dictionary<BaseEntity, object>();
            dic.Add(admin, where);
            dic.Add(admins, where);
            base.EditList(dic);
            //刪除
            base.Remove(admin);
            //批量刪除-事物
            base.RemoveList(dic);
        }
    }

實體類：codesmith 腳本寫好既能夠自動生成實體，很是方便快捷。

 /// <summary>
    /// Modal class: Admin_User.
    /// </summary>
    [Serializable]
    [Table(Name = "Admin_User", PrimaryKey = "user_ID")]
    public class Admin_User : BaseEntity
    {
        #region Private Properties

        private int? user_ID;//ID
        private string user_Name;//用戶名
        private string user_Password;//密碼
        private string user_NikeName;//用戶暱稱
        private string user_TrueName;//用戶真實姓名
        private string user_Email;//Email
        private string user_RegIP;//註冊IP
        private DateTime? user_CreateTime;//註冊時間
        private int? user_LoginNumber;//登陸次數
        private DateTime? user_LastTime;//最後登陸時間
        private string user_LastIP;//最後登陸IP
        private int? user_Status;//狀態

        #endregion

        #region Public Properties

        /// <summary>
        /// ID.
        /// </summary>
        [Column(Name = "user_ID", PrimaryKey = true, Strategy = GenerationType.INDENTITY)]
        public int? User_ID
        {
            get
            {
                return user_ID;
            }
            set
            {

                user_ID = value;
            }
        }

        /// <summary>
        /// 用戶名.
        /// </summary>
        [Column(Name = "user_Name")]
        public string User_Name
        {
            get
            {
                return user_Name;
            }
            set
            {
                user_Name = value.SubStr(50);
            }
        }


        /// <summary>
        /// 密碼.
        /// </summary>
        [Column(Name = "user_Password")]
        public string User_Password
        {
            get
            {
                return user_Password;
            }
            set
            {
                user_Password = value.SubStr(50);
            }
        }


        /// <summary>
        /// 用戶暱稱.
        /// </summary>
        [Column(Name = "user_NikeName")]
        public string User_NikeName
        {
            get
            {
                return user_NikeName;
            }
            set
            {
                user_NikeName = value.SubStr(50);
            }
        }


        /// <summary>
        /// 用戶真實姓名.
        /// </summary>
        [Column(Name = "user_TrueName")]
        public string User_TrueName
        {
            get
            {
                return user_TrueName;
            }
            set
            {
                user_TrueName = value.SubStr(50);
            }
        }


        /// <summary>
        /// Email.
        /// </summary>
        [Column(Name = "user_Email")]
        public string User_Email
        {
            get
            {
                return user_Email;
            }
            set
            {
                user_Email = value.SubStr(50);
            }
        }


        /// <summary>
        /// 註冊IP.
        /// </summary>
        [Column(Name = "user_RegIP")]
        public string User_RegIP
        {
            get
            {
                return user_RegIP;
            }
            set
            {
                user_RegIP = value.SubStr(50);
            }
        }


        /// <summary>
        /// 註冊時間.
        /// </summary>
        [Column(Name = "user_CreateTime")]
        public DateTime? User_CreateTime
        {
            get
            {
                return user_CreateTime;
            }
            set
            {
                user_CreateTime = value;
            }
        }


        /// <summary>
        /// 登陸次數.
        /// </summary>
        [Column(Name = "user_LoginNumber")]
        public int? User_LoginNumber
        {
            get
            {
                return user_LoginNumber;
            }
            set
            {
                user_LoginNumber = value;
            }
        }


        /// <summary>
        /// 最後登陸時間.
        /// </summary>
        [Column(Name = "user_LastTime")]
        public DateTime? User_LastTime
        {
            get
            {
                return user_LastTime;
            }
            set
            {
                user_LastTime = value;
            }
        }


        /// <summary>
        /// 最後登陸IP.
        /// </summary>
        [Column(Name = "user_LastIP")]
        public string User_LastIP
        {
            get
            {
                return user_LastIP;
            }
            set
            {
                user_LastIP = value.SubStr(50);
            }
        }


        /// <summary>
        /// 狀態.
        /// </summary>
        [Column(Name = "user_Status")]
        public int? User_Status
        {
            get
            {
                return user_Status;
            }
            set
            {
                user_Status = value;
            }
        }



        #endregion


    }

　EntityManager 接口

public interface EntityManager
    {

        T Get<T>(WhereClip<T> whereClip) where T : BaseEntity, new();

        T Get<T>(ColumnsClip<T> columnsClip, WhereClip<T> whereClip, OrderByClip<T> orderByClip) where T : BaseEntity, new();

        List<T> GetList<T>(int top, ColumnsClip<T> columnsClip, WhereClip<T> whereClip, OrderByClip<T> orderByClip) where T : BaseEntity, new();

        int GetCount<T>(WhereClip<T> whereClip) where T : BaseEntity, new();

        //分頁查詢
        ConditionResult<T> GetList<T>(ColumnsClip<T> columnsClip, WhereClip<T> whereClip, OrderByClip<T> orderByClip, int nPageSize, int nPageIndex, int nTotalCount) where T : BaseEntity, new();

        //新增
        int Add<T>(T entity);

        //批量新增，採用事務
        bool AddList<T>(List<T> entityList);

        //修改
        int Edit<T>(T entity);

        //多條件修改
        int Edit<T>(T entity, WhereClip<T> whereClip) where T : BaseEntity, new();

        //批量修改，採用事物
        bool EditList<T>(Dictionary<T, object> dicList) where T : BaseEntity, new();

        //刪除
        int Remove<T>(T entity);

        //根據ID刪除數據
        int Remove<T>(WhereClip<T> whereClip) where T : BaseEntity, new();

        //批量刪除，採用事物
        bool RemoveList<T>(Dictionary<T, object> dicList) where T : BaseEntity, new();
    }

　　ManagerBLL 核心

        /// <summary>
        /// 獲取一行數據
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="whereClip"></param>
        /// <returns></returns>
        /// 
        public T Get<T>(WhereClip<T> whereClip) where T : BaseEntity, new()
        {
            //說明 性能問題還還沒有考慮。
            T _T = new T();

            PropertyInfo[] properties = ReflectionUtils.GetProperties(_T.GetType());

            string whereString = string.Empty;

            if (whereClip != null)
                whereString = whereClip.WhereString;

            TableInfo tableInfo = DbEntityUtils.GetTableInfo(_T, DbOperateType.SELECT);

            string commandText = BuildSql.GetFristSql(0, tableInfo, whereString, string.Empty);

            IDataReader sdr = null;
            if (whereClip != null)
            {
                DbParameter[] parms = SqlOpera.MakeInParams(whereClip.Table);
                sdr = SqlOpera.ExecuteReader(CommandType.Text, commandText, parms);
            }
            else
                sdr = SqlOpera.ExecuteReader(CommandType.Text, commandText);

            while (sdr.Read())
            {
                foreach (PropertyInfo property in properties)
                {
                    //經過實體類屬性名稱獲取Column自定義屬性配置的映射列名
                    string name = tableInfo.PropToColumn[property.Name].ToString();


                    //經過獲取的列名從dataReader中檢索值，並賦給實體對象屬性
                    ReflectionUtils.SetPropertyValue(_T, property, sdr[name]);
                }
                break;
            }
            sdr.Close();
            return _T;
        }

        /// <summary>
        /// 獲取一行數據
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="columnsClip"></param>
        /// <param name="whereClip"></param>
        /// <param name="orderByClip"></param>
        /// <returns></returns>
        public T Get<T>(ColumnsClip<T> columnsClip, WhereClip<T> whereClip, OrderByClip<T> orderByClip) where T : BaseEntity, new()
        {
            //說明 性能問題還還沒有考慮。
            T _T = new T();
            string orderByWhere = string.Empty;
            string columnsWhere = string.Empty;
            string whereString = string.Empty;
            PropertyInfo[] properties = ReflectionUtils.GetProperties(_T.GetType());

            if (orderByClip != null)
                orderByWhere = orderByClip.OrderByWhere;

            if (columnsClip != null)
                columnsWhere = columnsClip.ColumnsWhere;

            if (whereClip != null)
                whereString = whereClip.WhereString;


            TableInfo tableInfo = null;
            if (columnsClip == null)
                tableInfo = DbEntityUtils.GetTableInfo(_T, DbOperateType.SELECT);

            string tableName = DbEntityUtils.GetTableName(_T.GetType());//獲取表名

            string commandText = null;

            if (columnsClip != null)
                commandText = BuildSql.GetFristSqlByWhere(tableName, columnsWhere, whereString, orderByWhere);
            else
                commandText = BuildSql.GetFristSql(0, tableInfo, whereString, orderByWhere);

            IDataReader sdr = null;
            if (whereClip != null)
            {
                DbParameter[] parms = SqlOpera.MakeInParams(whereClip.Table);
                sdr = SqlOpera.ExecuteReader(CommandType.Text, commandText, parms);
            }
            else
            {
                sdr = SqlOpera.ExecuteReader(CommandType.Text, commandText);
            }

            while (sdr.Read())
            {
                foreach (PropertyInfo property in properties)
                {
                    //經過實體類屬性名稱獲取Column自定義屬性配置的映射列名
                    string name = DbEntityUtils.GetColumnAttributeName(property);

                    //經過獲取的列名從dataReader中檢索值，並賦給實體對象屬性
                    for (int i = 0; i < sdr.FieldCount; i++)
                    {
                        if (sdr.GetName(i) == name)
                        {
                            ReflectionUtils.SetPropertyValue(_T, property, sdr[name]);
                            break;
                        }
                    }
                }
                break;
            }
            sdr.Close();
            return _T;
        }

        /// <summary>
        /// 獲取List集合
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="top"></param>
        /// <param name="columnsClip"></param>
        /// <param name="whereClip"></param>
        /// <param name="orderByClip"></param>
        /// <returns></returns>
        public List<T> GetList<T>(int top, ColumnsClip<T> columnsClip, WhereClip<T> whereClip, OrderByClip<T> orderByClip) where T : BaseEntity, new()
        {

            //說明 性能問題還還沒有考慮。
            T _T = new T();
            List<T> listT = new List<T>();
            string orderByWhere = string.Empty;
            string columnsWhere = string.Empty;
            string whereString = string.Empty;
            PropertyInfo[] properties = ReflectionUtils.GetProperties(_T.GetType());

            if (orderByClip != null)
                orderByWhere = orderByClip.OrderByWhere;

            if (columnsClip != null)
                columnsWhere = columnsClip.ColumnsWhere;

            if (whereClip != null)
                whereString = whereClip.WhereString;

            string commandText = null;
            DataSet ds = null;

            if (columnsClip != null)
            {
                string tableName = DbEntityUtils.GetTableName(_T.GetType());//獲取表名
                commandText = BuildSql.GetListSql(top, tableName, columnsWhere, whereString, orderByWhere);
            }
            else
            {
                TableInfo tableInfo = DbEntityUtils.GetTableInfo(_T, DbOperateType.SELECT);
                commandText = BuildSql.GetFristSql(top, tableInfo, whereString, orderByWhere);
            }

            if (whereClip != null)
            {
                DbParameter[] parms = SqlOpera.MakeInParams(whereClip.Table);
                ds = SqlOpera.ExecuteDataset(CommandType.Text, commandText, parms);
            }
            else
            {
                ds = SqlOpera.ExecuteDataset(CommandType.Text, commandText);
            }

            if (ds.Tables.Count == 0) return listT;
            foreach (DataRow dr in ds.Tables[0].Rows)
            {
                T entityT = new T();
                foreach (PropertyInfo property in properties)
                {
                    //經過實體類屬性名稱獲取Column自定義屬性配置的映射列名
                    string name = DbEntityUtils.GetColumnAttributeName(property);

                    //經過獲取的列名從datatable中檢索值，並賦給實體對象屬性

                    if (dr.Table.Columns.Contains(name))
                        ReflectionUtils.SetPropertyValue(entityT, property, dr[name]);

                }
                listT.Add(entityT);
            }


            return listT;
        }

        /// <summary>
        /// 分頁
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="columnsClip"></param>
        /// <param name="whereClip"></param>
        /// <param name="orderByClip"></param>
        /// <param name="nPageSize"></param>
        /// <param name="nPageIndex"></param>
        /// <param name="nTotalCount"></param>
        /// <returns></returns>
        public ConditionResult<T> GetList<T>(ColumnsClip<T> columnsClip, WhereClip<T> whereClip, OrderByClip<T> orderByClip, int nPageSize, int nPageIndex, int nTotalCount) where T : BaseEntity, new()
        {

            T _T = new T();
            List<T> listT = new List<T>();
            ConditionResult<T> conditionResult = new ConditionResult<T>();
            string orderByWhere = string.Empty;
            string columnsWhere = string.Empty;
            string whereString = string.Empty;
            int totalCount = 0;
            PropertyInfo[] properties = ReflectionUtils.GetProperties(_T.GetType());

            if (orderByClip != null)
                orderByWhere = orderByClip.OrderByWhere;

            if (columnsClip != null)
                columnsWhere = columnsClip.ColumnsWhere;

            if (whereClip != null)
                whereString = whereClip.WhereString;

            totalCount = GetCount(whereClip);

            string commandText = null;

            DataSet ds = null;

            TableInfo tableInfo = DbEntityUtils.GetTableInfo(_T, DbOperateType.SELECT);
            string tableName = DbEntityUtils.GetTableName(_T.GetType());//獲取表名
            commandText = BuildSql.GetPageSql(tableName, columnsWhere, whereString, orderByWhere, nPageSize, nPageIndex, tableInfo);

            if (whereClip != null)
            {
                DbParameter[] parms = SqlOpera.MakeInParams(whereClip.Table);
                ds = SqlOpera.ExecuteDataset(CommandType.Text, commandText, parms);
            }
            else
            {
                ds = SqlOpera.ExecuteDataset(CommandType.Text, commandText);
            }

            if (ds.Tables.Count == 0) return conditionResult;

            foreach (DataRow dr in ds.Tables[0].Rows)
            {
                T entityT = new T();
                foreach (PropertyInfo property in properties)
                {
                    //經過實體類屬性名稱獲取Column自定義屬性配置的映射列名
                    string name = DbEntityUtils.GetColumnAttributeName(property);

                    //經過獲取的列名從datatable中檢索值，並賦給實體對象屬性

                    if (dr.Table.Columns.Contains(name))
                        ReflectionUtils.SetPropertyValue(entityT, property, dr[name]);

                }
                listT.Add(entityT);
            }

            conditionResult.ResultList = listT;
            conditionResult.PageSize = nPageSize;
            conditionResult.TotalCount = totalCount;
            conditionResult.TotalPage = (int)Math.Ceiling((double)totalCount / nPageSize);
            conditionResult.PageIndex = nPageIndex;
            return conditionResult;
        }

        /// <summary>
        /// 獲取第一行第一列
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="whereClip"></param>
        /// <returns></returns>
        public int GetCount<T>(WhereClip<T> whereClip) where T : BaseEntity, new()
        {
            Type type = new T().GetType();

            string whereString = string.Empty;

            if (whereClip != null)
                whereString = whereClip.WhereString;

            string tableName = DbEntityUtils.GetTableName(type);//獲取表名

            string commandText = BuildSql.GetCountSql(tableName, whereString);

            ////執行SQL命令  
            object val = null;
            if (whereClip != null)
            {
                DbParameter[] parms = SqlOpera.MakeInParams(whereClip.Table);
                val = SqlOpera.ExecuteScalar(CommandType.Text, commandText, parms);
            }
            else
                val = SqlOpera.ExecuteScalar(CommandType.Text, commandText);

            //返回所影響的行數
            return Utils.StrToInt(val, 0);
        }

ManagerBLL 必須實現 EntityManager 接口，部分代碼還未貼。

------------------------------------------------------------------

整理中。。。。。