1

在 Martin Fowler 的“企业应用程序架构模式”中，描述了用于组织 DAL 的方法，例如一组实体映射器。每个都有自己的 IdentityMap 存储特定实体。

例如在我的 ASP.NET WebApplication 中：

//AbstractMapper - superclass for all mappers in DAL
public abstract class AbstractMapper
{
    private readonly string _connectionString;
    protected string ConnectionString
    {
      get { return _connectionString; }  
    }

    private readonly DbProviderFactory _dbFactory;
    protected DbProviderFactory DBFactory
    {
        get { return _dbFactory; }
    } 

    #region LoadedObjects (IdentityMap)
    protected Hashtable LoadedObjects = new Hashtable();

    public void RegisterObject(long id, DomainObject obj)
    {
        LoadedObjects[id] = obj;            
    }

    public void UnregisterObject(long id)
    {
        LoadedObjects.Remove(id);
    }
    #endregion

    public AbstractMapper(string connectionString, DbProviderFactory dbFactory)
    {
        _connectionString = connectionString;
        _dbFactory = dbFactory;
    }

    protected virtual string DBTable
    {
        get
        {
            throw new NotImplementedException("database table is not defined in class " + this.GetType()); 
        }
    }

    protected virtual T Find<T>(long id, IDbTransaction tr = null) where T : DomainObject
    {
        if (id == 0)
            return null;
        T result = (T)LoadedObjects[id];
        if (result != null)
            return result;
        IDbConnection cn = GetConnection(tr);
        IDbCommand cmd = CreateCommand(GetFindStatement(id), cn, tr);
        IDataReader rs = null;
        try
        {
            OpenConnection(cn, tr);
            rs = cmd.ExecuteReader(CommandBehavior.SingleRow);
            result = (rs.Read()) ? Load<T>(rs) : null;                  
        }
        catch (DbException ex)
        {
            throw new DALException("Error while loading an object by id in class " + this.GetType(), ex);
        }
        finally
        {
            CleanUpDBResources(cmd, cn, tr, rs);
        }
        return result;
    }

    protected virtual T Load<T>(IDataReader rs) where T : DomainObject
    {
        long id = GetReaderLong(rs["ID"]);
        T result = (T)LoadedObjects[id];
        if (result != null) 
            return result;

        result = (T)DoLoad(id, rs);
        RegisterObject(id, result);
        return result;
    }

    // another CRUD here ...
}

// Specific Mapper for entity Account
public class AccountMapper : AbstractMapper
{
internal override string DBTable
{
    get { return "Account"; }
}

public AccountMapper(string connectionString, DbProviderFactory dbFactory) : base(connectionString, dbFactory) { }

public Account Find(long id)
{
    return Find<Account>(id);
}

public override DomainObject DoLoad(long id, IDataReader rs)
{
    Account account = new Account(id);
    account.Name = GetReaderString(rs["Name"]);
    account.Value = GetReaderDecimal(rs["Value"]);
    account.CurrencyID = GetReaderLong(rs["CurrencyID"]);
    return account;
}

// ...

}

问题是：在哪里存储这些映射器？系统服务（实体）应该如何调用映射器？

我决定创建包含所有映射器的 MapperRegistry。因此服务可以调用映射器，例如：

    public class AccountService : DomainService
{
    public static Account FindAccount(long accountID)
    {
        if (accountID > 0)
            return MapperRegistry.AccountMapper.Find(accountID);
        return null;
    }
    ...
}

但是我可以在哪里存储 MapperRegistry 实例？我看到以下变体，但不喜欢其中任何一个：

  1. MapperRegistry 是全局应用程序（单例）

    • 不适用，因为在多线程 ASP.NET 应用程序中需要同步（至少 Martin 说只有 mad 可以选择此变体）

  2. 每个会话的 MapperRegistry

    • 好像也不太好。所有 ORM（NHibernate、LINQ to SQL、EntityFramework）大师都建议对每个请求使用 DataContext（NHibernateSession、ObjectContext），而不是在 Session 中存储上下文。
    • 同样在我的 WebApp 中，几乎所有请求都是对 EntityController.asmx（具有属性 ScriptService）返回 JSON 的 AJAX 请求。并且不允许会话。

  3. 每个请求的 MapperRegistry

    • 有很多单独的 AJAX 调用。在这种情况下 MapperRegistry 的生命周期将太小。因此，数据几乎总是会从数据库中检索出来，因此性能低下。

亲爱的专家，请帮助我解决架构问题。

4

0 回答 0