OrmBase.cs

using System;
using System.Collections.Generic;
using System.Text;
using CYQ.Data.Table;
using System.Reflection;

using CYQ.Data.Tool;
using CYQ.Data.Cache;
using CYQ.Data.SQL;
using System.Data;
using CYQ.Data.UI;
using CYQ.Data.Aop;


namespace CYQ.Data.Orm
{

    /// <summary>
    /// ORM扩展基类
    /// </summary>
    [AopAttribute]
    public abstract partial class OrmBase : ContextBoundObject, IDisposable
    {
        private SimpleOrmBase sob = new SimpleOrmBase();
        /// <summary>
        ///  字段来源（当字段变更时，可以设置此属性来切换更新）
        /// </summary>
        public static FieldSource FieldSource
        {
            get
            {
                return SimpleOrmBase.FieldSource;
            }
            set
            {
                SimpleOrmBase.FieldSource = value;
            }
        }


        //Object entity;//实体对象
        //Type typeInfo;//实体对象类型
        MAction action
        {
            get
            {
                return sob.Action;
            }
        }
        /// <summary>
        /// 构造函数
        /// </summary>
        public OrmBase()
        {
            sob.IsUseAop = true;
        }
        /// <summary>
        /// 设置Aop状态
        /// </summary>
        /// <param name="op"></param>
        public void SetAopState(AopOp op)
        {
            sob.SetAopState(op);
        }
        /// <summary>
        /// 初始化状态[继承此基类的实体在构造函数中需调用此方法]
        /// </summary>
        /// <param name="entityInstance">实体对象,一般写:this</param>
        protected void SetInit(Object entityInstance)
        {
            sob.SetInit2(entityInstance, null, AppConfig.DB.DefaultConn);
        }
        /// <summary>
        /// 初始化状态[继承此基类的实体在构造函数中需调用此方法]
        /// </summary>
        /// <param name="entityInstance">实体对象,一般写:this</param>
        /// <param name="tableName">表名,如:Users</param>
        protected void SetInit(Object entityInstance, string tableName)
        {
            sob.SetInit2(entityInstance, tableName, AppConfig.DB.DefaultConn);
        }
        /// <summary>
        /// 初始化状态[继承此基类的实体在构造函数中需调用此方法]
        /// </summary>
        /// <param name="entityInstance">实体对象,一般写:this</param>
        /// <param name="tableName">表名,如:Users</param>
        /// <param name="conn">数据链接,单数据库时可写Null,或写默认链接配置项:"Conn",或直接数据库链接字符串</param>
        protected void SetInit(Object entityInstance, string tableName, string conn)
        {
            sob.SetInit2(entityInstance, tableName, conn);
        }
        protected void SetInit(Object entityInstance, string tableName, string conn, AopOp op)
        {
            sob.SetInit2(entityInstance, tableName, conn, op);
        }
        /// <summary>
        /// 设置值,例如:[action.Set(TableName.ID,10);]
        /// </summary>
        /// <param name="key">字段名称,可用枚举如:[TableName.ID]</param>
        /// <param name="value">要设置给字段的值</param>
        /// <example><code>
        /// set示例：action.Set(Users.UserName,"路过秋天");
        /// get示例：int id=action.Get&lt;int&gt;(Users.ID);
        /// </code></example>
        protected void Set(object key, object value)
        {
            if (sob != null)
            {
                sob.Set(key, value);
            }
        }

        #region 基础增删改查 成员

        #region 插入
        /// <summary>
        /// 插入数据
        /// </summary>
        public bool Insert()
        {
            return Insert(false, InsertOp.ID);
        }
        /// <summary>
        ///  插入数据
        /// </summary>
        /// <param name="option">插入选项</param>
        public bool Insert(InsertOp option)
        {
            return Insert(false, option);
        }
        /// <summary>
        ///  插入数据
        /// </summary>
        /// <param name="autoSetValue">自动从控制获取值</param>
        public bool Insert(bool autoSetValue)
        {
            return Insert(autoSetValue, InsertOp.ID);
        }
        /// <summary>
        ///  插入数据
        /// </summary>
        /// <param name="autoSetValue">自动从控制获取值</param>
        /// <param name="option">插入选项</param>
        public bool Insert(bool autoSetValue, InsertOp option)
        {
            return sob.Insert(autoSetValue, option, AllowInsertID);
        }
        #endregion

        #region 更新
        /// <summary>
        ///  更新数据
        /// </summary>
        public bool Update()
        {
            return sob.Update();
        }
        /// <summary>
        ///  更新数据
        /// </summary>
        /// <param name="where">where条件,可直接传id的值如:[88],或传完整where条件如:[id=88 and name='路过秋天']</param>
        public bool Update(object where)
        {
            return sob.Update(where);
        }
        /// <summary>
        ///  更新数据
        /// </summary>
        /// <param name="where">where条件,可直接传id的值如:[88],或传完整where条件如:[id=88 and name='路过秋天']</param>
        /// <param name="autoSetValue">是否自动获取值[自动从控件获取值,需要先调用SetAutoPrefix或SetAutoParentControl方法设置控件前缀]</param>
        public bool Update(object where, bool autoSetValue)
        {
            return sob.Update(where, autoSetValue);
        }
        #endregion

        #region 删除
        /// <summary>
        ///  删除数据
        /// </summary>
        public bool Delete()
        {
            return sob.Delete();
        }
        /// <summary>
        ///  删除数据
        /// </summary>
        /// <param name="where">where条件,可直接传id的值如:[88],或传完整where条件如:[id=88 and name='路过秋天']</param>
        public bool Delete(object where)
        {
            return sob.Delete(where);
        }
        #endregion

        #region 查询

        /// <summary>
        /// 查询1条数据（自动取值）
        /// </summary>
        /// <returns></returns>
        public bool Fill()
        {
            return sob.Fill();
        }
        /// <summary>
        /// 查询1条数据
        /// </summary>
        public bool Fill(object where)
        {
            return sob.Fill(where);
        }

        /// <summary>
        /// 列表查询
        /// </summary>
        public MDataTable Select()
        {
            int count;
            return Select(0, 0, null, out count);
        }
        /// <summary>
        /// 列表查询
        /// </summary>
        /// <param name="where">查询条件[可附带 order by 语句]</param>
        /// <returns></returns>
        public MDataTable Select(string where)
        {
            int count;
            return Select(0, 0, where, out count);
        }
        /// <summary>
        /// 列表查询
        /// </summary>
        /// <param name="topN">查询几条</param>
        /// <param name="where">查询条件[可附带 order by 语句]</param>
        /// <returns></returns>
        public MDataTable Select(int topN, string where)
        {
            int count;
            return Select(0, topN, where, out count);
        }
        public MDataTable Select(int pageIndex, int pageSize)
        {
            int count;
            return Select(pageIndex, pageSize, null, out count);
        }
        public MDataTable Select(int pageIndex, int pageSize, string where)
        {
            int count;
            return Select(pageIndex, pageSize, where, out count);
        }
        /// <summary>
        /// 带分布功能的选择[多条件查询,选择所有时只需把PageIndex/PageSize设置为0]
        /// </summary>
        /// <param name="pageIndex">第几页</param>
        /// <param name="pageSize">每页数量[为0时默认选择所有]</param>
        /// <param name="where"> 查询条件[可附带 order by 语句]</param>
        /// <param name="count">返回的记录总数</param>
        public MDataTable Select(int pageIndex, int pageSize, string where, out int count)
        {
            return sob.Select(pageIndex, pageSize, where, out count);
        }

        /// <summary>
        /// 获取记录总数
        /// </summary>
        public int GetCount(object where)
        {
            return sob.GetCount(where);
        }
        /// <summary>
        /// 查询是否存在指定的条件的数据
        /// </summary>
        public bool Exists(object where)
        {
            return sob.Exists(where);
        }

        #endregion

        #endregion

        #region IDisposable 成员
        /// <summary>
        /// 释放资源
        /// </summary>
        public void Dispose()
        {
            if (sob != null)
            {
                sob.Dispose();
            }
        }

        #endregion

        /// <summary>
        /// 批量加载值（可从Json、实体对象、MDataRow、泛型字段等批量加载值）
        /// </summary>
        /// <param name="jsonOrEntity">json字符串或实体对象</param>
        public void LoadFrom(object jsonOrEntity)
        {
            action.Data.LoadFrom(jsonOrEntity);
            sob.SetValueToEntity();
        }
        /// <summary>
        /// 本方法可以在单表使用时查询指定的列[设置后可使用Fill与Select方法]
        /// 提示：分页查询时，排序条件的列必须指定选择。
        /// </summary>
        /// <param name="columnNames">可设置多个列名[调用Fill或Select后,本参数将被清除]</param>
        public void SetSelectColumns(params object[] columnNames)
        {
            action.SetSelectColumns(columnNames);
        }
        /// <summary>
        /// 参数化传参[当Where条件为参数化(如：name=@name)语句时使用]
        /// </summary>
        /// <param name="paraName">参数名称</param>
        /// <param name="value">参数值</param>
        /// <param name="dbType">参数类型</param>
        public void SetPara(object paraName, object value, DbType dbType)
        {
            action.SetPara(paraName, value, dbType);
        }
        /// <summary>
        /// 清除(SetPara设置的)自定义参数
        /// </summary>
        public void ClearPara()
        {
            action.ClearPara();
        }
        /// <summary>
        /// 更新操作的自定义表达式设置。
        /// </summary>
        /// <param name="updateExpression">例如a字段值自加1："a=a+1"</param>
        public void SetExpression(string updateExpression)
        {
            action.SetExpression(updateExpression);
        }

        /// <summary>
        /// 是否允许插入自增ID
        /// </summary>
        public bool AllowInsertID
        {
            get
            {
                return action.AllowInsertID;
            }
            set { action.AllowInsertID = value; }
        }

        /// <summary>
        /// 获取或设置表名
        /// </summary>
        public string TableName
        {
            get
            {
                if (action != null)
                {
                    return action.TableName;
                }
                return string.Empty;
            }
            set
            {
                if (action != null)
                {
                    action.TableName = value;
                }
            }
        }
        private MDataColumn _Columns = null;
        /// <summary>
        /// 获取表的结构。
        /// </summary>
        public MDataColumn Columns
        {
            get
            {
                return _Columns;
            }
        }
        /// <summary>
        /// 执行的调试语句输出
        /// </summary>
        public string DebugInfo
        {
            get
            {
                return action.DebugInfo;
            }
        }
        /// <summary>
        /// 当前的数据库类型
        /// </summary>
        public DalType DalType
        {
            get
            {
                return action.DalType;
            }
        }
        /// <summary>
        /// 原始行数据。
        /// </summary>
        public MDataRow RawData
        {
            get
            {
                return action.Data;
            }
        }
        /// <summary>
        /// UI操作
        /// </summary>
        public MActionUI UI
        {
            get
            {
                if (action.UI.IsOnAfterGetFromEventNull)
                {
                    action.UI.OnAfterGetFromEvent += new CYQ.Data.UI.MActionUI.OnAfterGetFrom(UI_OnAfterGetFromEvent);
                }
                return action.UI;
            }
        }

        void UI_OnAfterGetFromEvent(string propValue)
        {
            if (!string.IsNullOrEmpty(propValue))
            {
                sob.SetValueToEntity(propValue);
            }
        }


    }
}