C#WPF实体框架6同步数据库

Question

场景：

我有两个MySQL数据库：

1. 大型主数据库
2. 小型客户端数据库

示例表：

大数据库用户：

文本用户名

• int id
• varchar登录
• varchar密码
• ...更多的领域

客户端数据库用户

• 内部id
• int UNIQUE api\u id（来自master的id）
• varchar登录
• varchar密码

问题：我需要同步数据库，但我不知道如何以最佳方式进行同步。我读过这个问题，但它很老了，没有涵盖我的情况。我通过REST API与主数据库通信，直接连接不是选项。

我的同步算法

• 从REST API（例如/API/users/）下载数据并将其反序列化到ApiUser对象列表

    public class ApiUser {
      int id;
      string login;
      string password; 
    }

    public class User{
      int id;
      int api_id;
      string login;
      string password; 
    }

• 迭代Apiuser列表
  • 如果存在带有ApiUser.id实体，则覆盖所有字段
  • 否则创建新实体

  我的代码：

  public void syncUsers(List <ApiUser> ApiUsers)
  
      {
          using (var db = new dbEntities())
          {
              ApiUsers.ForEach(apiUser =>
              {
                  var dbUser = db.client
                      .Where(c => c.api_id == apiUser.id)
                      .SingleOrDefault();
  
                  if (dbUser == null)
                  {
                      var userObj = new user()
                      {
                          api_id = apiUser.id,
                          login = apiUser.login,
                          password = apiUser.password
                      };
                      db.client.Add(userObj);
                  }
                  else
                  {
                      dbUser.api_id = apiUser.id,
                      dbUser.login = apiUser.login,
                      dbUser.password = apiUser.password
                  }
  
              });
  
              db.SaveChanges();
          }
      }
  
  

  问题：如何做得更好？我在主数据库中删除实体时遇到问题，我的算法不涵盖这种情况。

Answer 1

我假设所有用户的交互或自动事务都只在master数据库中完成（否则您将需要某种合并复制，这不是微不足道的）。

对于已删除的实体，有几个选项。在任何情况下，主数据库都必须将有关已删除实体的信息传播到客户端数据库。

1.如果信息被删除，每个实体都保留该信息。

在这种情况下，您可以使用软删除选项，该选项可以通过覆盖DbContext的OnModelCreating和SaveChange方法在EF中轻松实现（您可以在网上找到许多带有实现的代码示例）。此选项也有一些缺点——您可能有相当复杂的域模型以及实体之间的关系，因此在删除其父实体时必须处理软删除子实体。如果您有不同的主数据库和客户端数据库的前端应用程序，您必须升级所有这些应用程序才能将新的软删除属性（例如IsDelated）投入使用。但是在这种情况下，（软）删除实体的同步本身非常简单，因为它只需要在客户端更新一个附加属性。

2、删除实体的新表。

在这种情况下，您必须为每个实体创建一个附加表，并在删除任何实体之前插入Id值。您必须重写DbContext的SaveChanges以拦截EntityState中的实体。已删除状态。

关于第一个问题，这取决于您想要增强什么。如果希望表中有许多记录，则应考虑引入其他字段，仅更新在主数据库中真正更新过的记录-您可以分别在int（实体版本）、DateTime或guid值之间进行选择，具体取决于最适合您的情况。

如果您想将处理逐个属性更新的问题分开，您可以仅为同步目的创建特殊的实体模型，将数据反序列化为这些对象，然后使用AutoMapper更新您的实体，例如：

使现代化

dbUser = Mapper.Map<User>(apiUser);
db.Set<User>().Attach(dbUser);
db.Entry(dbUser).State = EntityState.Modified;
db.SaveChanges();

添加

dbUser = Mapper.Map<User>(apiUser);
db.client.Add(dbUser)
db.SaveChanges();