需要一些帮助来解决我的 DAL 中主要的抽象模式问题

Question

我的数据访问层给自己带来了一些问题。在这个特定的实例中，我有一个表，其中可能包含 5 种类型的“实体”。这些基本上是公司、客户、站点等。类型由表中的 PositionTypeId 指定。它们都在同一个表中，因为它们都具有相同的数据结构； 位置 ID、描述和代码。

我有一个主要抽象类，如下所示：

public abstract class PositionProvider<T> : DalProvider<T>, IDalProvider where T : IPositionEntity
{
    public static PositionProvider<T> Instance
    {
        get
        {
            if (_instance == null)
            {
                // Create an instance based on the current database type
            }
            return _instance;
        }
    }
    private static PositionProvider<T> _instance;

    public PositionType PositionType
    {
        get
        {
            return _positionType;
        }
    }
    private PositionType _positionType;

    // Gets a list of entities based on the PositionType enum's value.
    public abstract List<T> GetList();

    internal void SetPositionType(RP_PositionType positionType)
    {
        _positionType = positionType;
    }

}

我希望能够将所有通用代码放在基于 SQL 或 Oracle 的继承类中。这是我的 SQL 实现：

public class SqlPositionProvider<T> : PositionProvider<T> where T : IPositionEntity
{
        public override List<T> GetList()
        {
            int positionTypeId = (int)this.PositionType;
            using (SqlConnection cn = new SqlConnection(Globals.Instance.ConnectionString))
            {
                SqlCommand cmd = new SqlCommand("Get_PositionListByPositionTypeId", cn);
                cmd.Parameters.Add("@PositionTypeId", SqlDbType.Int).Value = positionTypeId;
                cmd.CommandType = CommandType.StoredProcedure;
                cn.Open();
                return this.GetCollectionFromReader(this.ExecuteReader(cmd));
            }
        }
}

然后，我为每种类型创建一个类，如下所示（以 CustomerProvider 为例）：

public class CustomerProvider
{
    public static PositionProvider<CustomerEntity> Instance
    {
        get
        {
            if ((int)PositionProvider<CustomerEntity>.Instance.PositionType == 0)
            {
                PositionProvider<CustomerEntity>.Instance.SetPositionType(PositionType.Customer);
            }
            return PositionProvider<CustomerEntity>.Instance;
        }
    }
}

这一切都运行得非常好......直到我意识到我有某些与特定位置特定相关的函数类型。即我需要能够根据用户权限获取所有客户（这是一个 IPositionType）。

所以我需要添加另一个抽象方法：

public abstract List<CustomerEntity> GetCustomersByUserPermission(Guid userId);

现在，显然我不希望在我的 PositionProvider 抽象类中使用它，因为这意味着在处理站点/公司提供商时会出现该方法。

如何添加此方法以及其他附加方法，而无需在 SqlPositionProvider 中复制代码？

编辑：

我想到的唯一想法是将 PositionProvider 分离到 CustomerProvider、SiteProvider 等Provider 的公共属性中：

public abstract class CustomerProvider
{

    public CustomerProvider()
    {
        this.Common.SetPositionType(PositionType.Customer);
    }

    public PositionProvider<CustomerEntity> Common
    {
        get
        {
            if (_common == null)
            {
                DalHelper.CreateInstance<PositionProvider<CustomerEntity>>(out _common);
            }
            return _common;
        }
    }
    private PositionProvider<CustomerEntity> _common;

    public static CustomerProvider Instance
    {
        get
        {
            if (_instance == null)
            {
                DalHelper.CreateInstance<CustomerProvider>(out _instance);
            }
            return _instance;
        }
    }
    private static CustomerProvider _instance;

    public abstract List<CustomerEntity> GetCustomersByUserPermission(Guid userId);

}

这将允许我将特定代码放在 CustomerProvider 中.Instance.MyNonGenericMethod()，然后访问 PositionProvider 我可以做 CustomerProvider.Instance.Common.GetList()... 这看起来确实像不过有点黑客行为。

Answer 1

如果我理解正确的话，你需要一种方法来在子类中包含一些方法，但不是全部。

如果您可以对所需的额外方法进行分组，您可以使用一个接口，实现它，并在您的子级（组合）中使用这个新类的实例。

对此的简化是所有子类的存储库模式（此示例不使用接口）。

[注意：代码无法编译，仅用于演示建议]

public class PositionProviderRepository
{
    public List<T> GetList()
        {
            int positionTypeId = (int)this.PositionType;
            using (SqlConnection cn = new SqlConnection(Globals.Instance.ConnectionString))
            {
                SqlCommand cmd = new SqlCommand("Get_PositionListByPositionTypeId", cn);
                cmd.Parameters.Add("@PositionTypeId", SqlDbType.Int).Value = positionTypeId;
                cmd.CommandType = CommandType.StoredProcedure;
                cn.Open();
                return this.GetCollectionFromReader(this.ExecuteReader(cmd));
            }
        }
    public List<CustomerEntity> GetCustomersByUserPermission(Guid userId) {
      //TODO: implementation
    }
}

然后您在所有实体（例如 CustomerEntity）中使用此类。

这可以有效地替换您的类 SqlPositionProvider 但我不确定我是否正确理解您的架构，您有一个非常复杂的层次结构。

Answer 2

这种查找方法的“正确”位置是 Repository 类。在那里，您可以从域对象中收集所有此类查询函数。

这是一个小例子：

public static class Repository {
    public static List<CustomerEntity> GetCustomersByUserPermission(
        PositionProvider<CustomerEntity> source, Guid userId)
    {
        // query source and return results
    }
}

将所有“特殊”查询添加到此类中。

Answer 3

如何将这样的内容添加到您的抽象类中：

public IEnumerable<T> GetItems(Predicate<T> match)
{
    foreach (T item in GetList())
    {
        if (match(item))
           yield return item;  
    }
}

然后您应该删除 SetPositionType(...) 方法，因为它的用法似乎有点尴尬（您应该设置位置类型，然后调用 GetList()？）

因此，使用该方法您可以简单地编写：（

customerProvider.GetItems(customer => customer.Id == someId);

或者，使用 .Net 2.0 语法）

customerProvider.GetItems(delegate(Customer c)
{
     return c.Id == someId;
});

Answer 4

首先，.NET BCL 对于 System.Data.Common 中定义的不同 DBMS 有一个很好的抽象级别。通过使用 DbConnection 而不是 SqlConnection/OracleConnection、DbCommand 而不是 SqlCommand/< code>OracleCommand 等，您将能够稍微减少代码重复（会有一些陷阱，例如参数命名的差异，但它们是可以克服的）。

其次，恕我直言，围绕单例构建所有代码是一个坏主意。为什么不编写

public class CustomerProvider
{
    PositionProvider<CustomerEntity> _provider;
    PositionProvider<CustomerEntity> Instance // we don't need it public really.
    {
        get
        {
            if ((int)PositionProvider<CustomerEntity>.Instance.PositionType == 0)
            {
                _provider = new PositionProvider<CustomerEntity>(); // PositionType is set in .ctor
                // we can also use a factory to abstract away DB differences
            }
            return _provider;
        }
    }
    // one way of implementing custom query
    public List<CustomerEntity> GetCustomersByUserPermission(Guid userId){
        return _provider.GetListWithCriteria(Criteria.Argument("UserId", userId));
    }
}

方法 GetListWithCriteria 可以实现为：

public List<CustomerEntity> GetListWithCriteria(params ICriterion[] criterias){
        int positionTypeId = (int)this.PositionType;
        using (DbConnection cn = OpenConnection()) // creates DbConnection and opens it
        using (DbCommand cmd = cn.CreateCommand())
        {
            // ... setting command text ...
            foreach(ICriterion c in criterias){
                DbParameter p = cmd.CreateParameter();
                p.DbType = c.DbType;
                p.Name = Encode(c.Name); // add '@' for MS SQL, ':' for Oracle
                p.Value = c.Value;
                cmd.AddParameter(p);
            }
            return this.GetCollectionFromReader(this.ExecuteReader(cmd));
        }        
}

以这种方式，PositionProvider 仍然是一种抽象 DBMS 差异的方法，而 CustomerProviders 可以构建任意新查询。

Answer 5

我已经破解了。我的 Inheriting 类现已变为以下内容：

public abstract class CustomerProvider : PositionProvider<CustomerEntity>
{

        public CustomerProvider() { }

        public new static CustomerProvider Instance
        {
            get
            {
                if (_instance == null)
                {
                    DalHelper.CreateInstance<CustomerProvider>(out _instance);
                }
                return _instance;
            }
        }
        private static CustomerProvider _instance;

        public override List<CustomerEntity> GetList()
        {
            return PositionProvider<CustomerEntity>.Instance.GetList();
        }

        public abstract List<CustomerEntity> GetCustomersByUserPermission(Guid userId);

}

它具有如下具体实现：

public class SqlCustomerProvider : CustomerProvider
{
    public override List<CustomerEntity> GetCustomersByUserPermission(Guid userId)
    {
        using (SqlConnection cn = new SqlConnection(Globals.Instance.ConnectionString))
        {
            SqlCommand cmd = new SqlCommand("GetRP_CustomersByUser", cn);
            cmd.Parameters.Add("@UserId", SqlDbType.UniqueIdentifier).Value = userId;
            cmd.CommandType = CommandType.StoredProcedure;
            cn.Open();
            return this.GetCollectionFromReader(this.ExecuteReader(cmd));
        }
    }
}

我的 PositionProvider 保持不变，但通过在扩展 CustomerProvider 的重写中调用它，然后它使用 SqlPositionProvider 作为提供程序特定的代码。

我现在可以实现我想要的了。

// Returns a list of customers still using the PositionProvider
CustomerProvider.Instance.GetList(); 

// Returns my specific customer data
CustomerProvider.Instance.GetCustomersByUserPermission();

// Returns a list of sites still using the PositionProvider
SiteProvider.Instance.GetList(); 

// Not part of the SiteProvider!
SiteProvider.Instance.GetCustomersByUserPermission();