通达信日线数据接口-C EF Core 简单工厂模式接口多继承实例三

说明

本实例是基于.NetCore1,EFCore1的代码实例，仅供参考

当前版本的EFCore好像还没有提供模型验证，异常跟踪等

实体层，自动生成

接口层

基础接口

/// 
/// 基础访问接口，使用泛型
/// 
public interface IBaseAbstract where T : class
{
    #region 基础访问
    /// 
    /// 获取表达树
    /// 
    /// 
    DbSet GetDbSet();
    /// 
    /// 根据主键 获取对象
    /// 
    /// 
    /// 
    T GetModel(object id);
    /// 
    /// 添加对象
    /// 
    /// 实例对象
    /// 
    bool Add(T model);
    /// 
    /// 修改对象
    /// 
    /// 实例对象
    /// 
    bool Modify(T model);
    /// 
    /// 删除对象
    /// 
    /// 实例对象
    /// 
    bool Delete(T model);
    /// 
    /// 删除 对象
    /// 
    /// 主键ID
    /// 
    bool Delete(object id);
    #endregion
}

namespace NotifyBird.Abstract
{
    /// 
    /// 消息内容，接口
    /// 
    public interface IMessage : IBaseAbstract
    {
    }
}

C EF Core 通达信日线数据接口,简单工厂模式接口多继承实例三

接口实现，实例工厂层

基础操作

/// 
/// 基础类型操作
/// 重点实现基础接口中的操作
/// 
internal class BaseOperate where T : class
{
    public NotifyBirdContext Context = null;
    public BaseOperate()
    {
        Context = new NotifyBirdContext();
    }

    #region 其他操作 
    ///   
    /// 保存数据  
    ///   
    ///   
    public int Save()
    {
        return Context.SaveChanges();
    }
    ///   
    /// 标间对象为修改状态，并保存  
    ///   
    public bool SetModify(T model) where T : class
    {
        Context.Entry(model).State = EntityState.Modified;
        return Save() > 0;
    }
    #endregion

    #region 基础访问
    /// 
    /// 获取表达树
    /// 
    /// 
    public DbSet GetDbSet()
    {
        return Context.Set();
    }
    /// 
    /// 根据主键 获取对象
    /// 
    /// 
    /// 
    public T GetModel(object id)
    {
        return GetDbSet().Find(id);
    }
    /// 
    /// 添加对象
    /// 
    /// 实例对象
    /// 
    public bool Add(T model)
    {
        try
        {
            GetDbSet().Add(model);
            return Save() > 0;
        }
        catch (Exception ex)
        {
            return Error_Add(ex);
        }
    }
    /// 
    /// 修改对象
    /// 
    /// 实例对象
    /// 
    public bool Modify(T model)
    {
        try
        {
            return SetModify(model);
        }
        catch (Exception ex)
        {
            return Error_Modify(ex);
        }
    }
    /// 
    /// 删除对象
    /// 
    /// 实例对象
    /// 
    public bool Delete(T model)
    {
        try
        {
            GetDbSet().Remove(model);
            return Save() > 0;
        }
        catch (Exception ex)
        {
            return Error_Delete(ex);
        }
    }
    /// 
    /// 删除 对象
    /// 
    /// 主键ID
    /// 
    public bool Delete(object id)
    {
        try
        {
            T model = GetModel(id);
            if (model == null)
                throw new Exception($'获取id={id}的对象失败,当前类型:{model.GetType().Name}');
            return Delete(model);
        }
        catch (Exception ex)
        {
            return Error_Delete(ex);
        }
    }
    #endregion

    #region 异常处理  
    private string GetErrorMsg(Exception ex)
    {
        StringBuilder builder = new StringBuilder();
        Exception inner = ex;
        int i = 0;
        while (inner != null)
        {
            i++;
            builder.AppendFormat('内部原因{0}:{1}', i, ex.Message);
            builder.AppendLine();
            inner = inner.InnerException;
        }
        return builder.ToString();
    }
    ///   
    /// 添加数据异常  
    ///   
    ///   
    ///   
    public bool Error_Add(Exception ex)
    {
        throw new Exception('添加数据失败，' + GetErrorMsg(ex));
    }
    ///   
    /// 修改数据异常  
    ///   
    ///   
    public bool Error_Modify(Exception ex)
    {
        throw new Exception('修改数据失败，' + GetErrorMsg(ex));
    }
    ///   
    /// 删除数据异常  
    ///   
    public bool Error_Delete(Exception ex)
    {
        throw new Exception('删除数据失败，' + GetErrorMsg(ex));
    }
    #endregion
}

业务操作

    /// 
    /// 消息内容，数据访问操作
    /// 
    internal class MessageOperate : BaseOperate, IMessage
    {
    }

实例工厂

注：此处命名空间和接口相同，则在使用的时候不需要单独引用Factory

namespace NotifyBird.Abstract
{
    /// 
    /// 工厂类 ，用于生产接口实例
    /// 
    public class ConcreteFactory
    {
        public static IProject GetProject()
        {
            return new ProjectOpeate();
        }

        public static IMessage GetMessage()
        {
            return new MessageOperate();
        }
    }
}

C#EFCodeFirst通达信日线数据接口,简单工厂模式，接口多继承实例

C#EFCodeFirst简单工厂模式，接口多继承实例

文章为作者独立观点，不代表股票交易接口观点