0

我创建了一个服务数据访问层，其中有多个数据需要来自的数据库。

我对一个数据库做得很好，我在其中定义了memberRepository包含成员详细信息的数据库。但是，现在我必须获取存储在另一个数据库中的与会话相关的详细信息。

运营合同：

  • IMemberServices包含GetLoggedInBuddies(int profileID);
  • ISessionServices包含GetProfileIDFromSessionID(string sessionID);

我的服务等级：

public class MemberService : IMemberService, ISessionServices
{
    #region Strategy pattern configuration

    //
    // Member repo
    // 
    private MemberRepository memberRepository;
    public MemberService()
        : this(new MemberRepository())
    { }
    public MemberService(MemberRepository memberRepository)
    {
        this.memberRepository = memberRepository;
    }


    //
    // Session repo
    //
    private SessionRepository sessionRepository;
    public MemberService() : this(new SessionRepository()){}
    public MemberService(SessionRepository sessionRepository)
    {
        this.sessionRepository = sessionRepository;
    }

    #endregion



    /// <summary>
    /// Session-related details are maintained in the Secondary database
    /// </summary>
    /// <param name="sessionID"></param>
    /// <returns></returns>
    public int GetProfileIDFromSessionID(string sessionID)
    {
        int sessionProfileID = sessionRepository.GetProfileDetailsFromSessionID(sessionRepository);

        return sessionProfileID;
    }

    /// <summary>
    /// Try profileID = 1150526
    /// </summary>
    /// <param name="profileID"></param>
    public void  GetLoggedInBuddies(int profileID)
    {
        memberRepository.GetLoggedInBuddies(profileID);
        //return memberRepository.GetLoggedInBuddies(profileID);
    }

问题是在该// Session Repo部分中，因为我已经定义了一个构造函数。我明白了。

所以基本上在每种方法中我都想做类似的事情

MemberService useSessionRepo = new MemberService(SessionRepository);
useSessionRepo.GetProfileDetailsFromSessionID(...);

MemberService useMemberRepo = new MemberService(MemberRepository);
useMemberRepo.GetLoggedInBuddies(...);

只需要一只手把它放在一起。

谢谢。

4

2 回答 2

0

我不确定您的问题，但是您可以使用不带参数的 ctor，并为每个 repo 使用参数。

public MemberService()
{
   this.memberRepository = new MemberRepository();
   this.sessionRepository = new SessionRepository();
}
于 2012-04-09T17:36:49.163 回答
0

我创建了一个中央存储库，它接受我要连接的数据库的连接字符串的名称。

public abstract class DatabaseRepository : BaseRepository
{
    static IDbConnection connection;

    /// <summary>
    /// Handles db connectivity as Dapper assumes an existing connection for all functions
    /// Since this app uses three databases, pass in the connection string for the required db.
    /// </summary>
    /// <returns></returns>
    protected static IDbConnection OpenConnection(string connectionStringName)
    {
        try
        {
            connection = new SqlConnection(WebConfigurationManager.ConnectionStrings[connectionStringName].ConnectionString);
            //connection = SqlMapperUtil.GetOpenConnection(connectionStringName);       // if we want to use the Dapper utility methods
            connection.Open();
            return connection;
        }
        catch (Exception ex)
        {
            ErrorLogging.Instance.Fatal(ex);        // uses singleton for logging
            return null;
        }
    }
.
.
.

然后在我的服务库中，我连接到适当的数据库并执行我需要的任何查询：

using (IDbConnection connection = OpenConnection("FirstDBConnectionString")) { ...
于 2012-04-18T20:55:23.997 回答