0

我是一个具有统一和工作单元模式的新手，我正在尝试编写一个代码，它连接到我的网络服务并完成所有工作。在我使用数据库之前一切都很顺利，但是当我尝试使用网络服务时我迷路了。

我浪费了我宝贵的 2 天，搜索与它相关的每一篇可能的文章并将其应用到我的代码中，但到目前为止还没有运气。

我知道，通过将连接字符串写入 web.config 并在 dbcontext 类控制器中调用它，将连接到所需的数据库，但我没有连接到任何数据库，所以我需要在 web/app.config 中进行哪些更改。此外，即使我在 dbcontext 构造函数中编写连接逻辑，它仍然会搜索并使用 sql server 详细信息填充 dbcontext。我认为这是因为我正在使用 DBSet。

伙计们，请你看一下我的代码，我已经完成了，并向我展示了一些我能做到的希望。如果您想了解与您想查看的代码相关的任何其他信息，请告诉我。

谢谢

 DBCONTEXT

 public class CVSContext :  DbContext
 {
    public DbSet<CVSViewModel> CVS { get; set; }
    public DbSet<Contact> Contacts { get; set; }
    public DbSet<Account> Accounts { get; set; }

    public CVSContext()
    {
        //CRM Start
            var clientCredentials = new System.ServiceModel.Description.ClientCredentials();
            clientCredentials.UserName.UserName = "";
            clientCredentials.UserName.Password = "";
            var serviceProxy = new Microsoft.Xrm.Sdk.Client.OrganizationServiceProxy(new Uri("http://Organization.svc"), null, clientCredentials, null);
            serviceProxy.ServiceConfiguration.CurrentServiceEndpoint.Behaviors.Add(new ProxyTypesBehavior());
            HttpContext.Current.Session.Add("ServiceProxy", serviceProxy);
          //CRM End
    }
 }

通用存储库

   public class GenericRepository<TEntity> where TEntity : class
   {
    internal CVSContext context;
    internal DbSet<TEntity> dbSet;

    public GenericRepository(CVSContext context)
    {
        this.context = context;
        this.dbSet = context.Set<TEntity>();
    }
   }

工作单位

   public interface IUnitOfWork : IDisposable
{
    int SaveChanges();
}

public interface IDALContext : IUnitOfWork
{
    ICVSRepository CVS { get; set; }

    IContactRepository Contacts { get; set; }

    //IAccountRepository Accounts { get; set; }
}

public class DALContext : IDALContext
{
    private CVSContext dbContext;
    private ICVSRepository cvs;
    private IContactRepository contacts;
   // private IAccountRepository accounts;

    public DALContext()
    {
        dbContext = new CVSContext();
    }

    public ICVSRepository CVS
    {
        get
        {
            if (cvs == null)
                cvs = new CVSRepository(dbContext);
            return cvs;
        }

        set
        {
            if (cvs == value)
                cvs = value;
        }
    }

    public IContactRepository Contacts
    {
        get
        {
            if (contacts == null)
                contacts = new ContactRepository(dbContext);
            return contacts;
        }

        set
        {
            if (contacts == value)
                contacts = value;
        }
    }

    public int SaveChanges()
    {
        return this.SaveChanges();
    }

    public void Dispose()
    {
        if(contacts != null)
            contacts.Dispose();
        //if(accounts != null)
        //    accounts.Dispose();
        if(dbContext != null)
            dbContext.Dispose();

        GC.SuppressFinalize(this);
    }
  }

服务

 public interface ICVSService
{
    Contact CreateContact(Guid contactName, string productName, int price);

    List<CVSViewModel> GetCVS();
    List<Contact> GetContacts();
    List<Account> GetAccounts();
}

public class CVSService : ICVSService, IDisposable
{
    private IDALContext context;

    public CVSService(IDALContext dal)
    {
        context = dal;
    }

    public List<CVSViewModel> GetCVS()
    {
        return context.CVS.All().ToList();
    }

    public List<Contact> GetContacts()
    {
        return context.Contacts.All().ToList();
    }

    public List<Account> GetAccounts()
    {
        return context.Accounts.All().ToList();
    }

    public Contact CreateContact(Guid contactName, string accountName, int price)
    {
        var contact = new Contact() { ContactId = contactName };

        var account = new Account() { ContactName = accountName,  Rent  = price, Contact = contact };

        //context.Contacts.Create(contact);
        context.SaveChanges();

        return contact;
    }

    public void Dispose()
    {
        if (context != null)
            context.Dispose();
    }
}

控制器

  public ActionResult Index()
    {         
        ViewData.Model = service.GetContacts();
        return View();
    }
4

1 回答 1

0

这都是关于适当的抽象。在某些数据源（可能是 db 或 ws）之间使用的通用抽象是存储库模式，或者更高级别的工作单元模式。事实上，实体框架DbContext是工作单元模式的一种实现，但它是为数据库量身定制的。您不能用于与 Web 服务进行通信。

在这种情况下，您将不得不编写自己的IRepository<T>抽象，并拥有一个使用幕后的数据库特定实现DbContext和一个在幕后包装 Web 服务客户端代理的 Web 服务特定实现。

但是，当您的应用程序变得更加复杂时，您经常会发现自己想要某种类似事务的行为。这就是工作单元模式的用途：它呈现一个业务事务。然而，使用工作单元模式来包装多个 WS 调用很快就会变得很痛苦。要做到正确需要做很多工作，在这种情况下，使用基于消息的架构会更好。

使用基于消息的架构，您可以将单个原子操作（业务事务或用例）定义为特定消息，例如：

public class MoveCustomerCommand
{
    public int CustomerId { get; set; }

    public Address NewAddress { get; set; }
}

这只是一个具有一组属性但没有行为的对象 (DTO)。很好的是，您可以使用 WCF 或任何其他技术通过网络传递这些类型的对象，或者在本地处理它们，而无需消费者知道。

看看这篇详细描述它的文章。本文建立在该模型之上，并描述了如何使用该模型编写高度可维护的 WCF 服务。

于 2013-04-22T08:10:39.563 回答