5

我目前正在重构遗留代码以使用 Android 架构组件，并在一种存储库模式中设置房间数据库和 volley 请求。因此表示层/域层要求存储库获取 LiveData-Objects 以观察或告诉他与服务器同步，之后删除旧的数据库条目并从服务器重新获取所有当前条目。

我已经为同步部分编写了测试，所以我确信对象被正确地提取并插入到数据库中。但是，当编写测试以观察该数据库表的条目时（并测试对象是否正确保存以及在将它们放入数据库之前需要完成的所有操作）时，我正在观察的 LiveData> 不会被触发。

在下面的代码片段中，您可以假设 synchronizeFormsWithServer(...) 方法可以正常工作并且异步执行数据库操作。它包含从数据库中删除所有表单对象的操作，这些表单对象不在从服务器获取的表单列表中，并插入所有新的表单对象。因为在测试开始时数据库是空的，所以这应该没那么重要

未触发观察者的测试：

  @Test
  public void shouldSaveFormsFromServerIntoDb() throws Exception
   {
    Lifecycle lifecycle = Mockito.mock(Lifecycle.class);
    when(lifecycle.getCurrentState()).thenReturn(Lifecycle.State.RESUMED);
    LifecycleOwner owner = Mockito.mock(LifecycleOwner.class);
    when(owner.getLifecycle()).thenReturn(lifecycle);

    final CountDownLatch l = new CountDownLatch(19);

    formRepository.allForms().observe(owner, formList ->
    {
     if (formList != null && formList.isEmpty())
      {
       for (Form form : formList)
        {
         testForm(form);
         l.countDown();
        }
      }
    });

    formRepository.synchronizeFormsWithServer(owner);
    l.await(2, TimeUnit.MINUTES);
    assertEquals(0, l.getCount());
   }

FormRepository 代码：

  @Override
  public LiveData<List<Form>> allForms()
   {
    return formDatastore.getAllForms();
   }

数据存储：

  @Override
  public LiveData<List<Form>> getAllForms()
   {
    return database.formDao().getAllForms();
   }

formDao 代码（数据库是按照您对房间的期望实现的）：

  @Query("SELECT * FROM form")
  LiveData<List<Form>> getAllForms();

很可能，我对 LiveData-Components 不了解，因为这是我第一次使用它们，所以我可能从根本上搞错了。

非常感谢每一点帮助:)

PS：我偶然发现了这篇文章，它讨论了一个类似的问题，但是由于我目前根本没有使用 DI，而只使用了一个 formrepository 实例（它只有一个 formDao 实例关联）我不认为这是一样的问题。

4

3 回答 3

12

好的，所以我找到了解决方案，虽然我不知道为什么它会这样。

还记得我说过“不要担心同步方法”吗？嗯......原来有一些问题，这进一步延迟了解决方案。

我认为最重要的错误是当网络响应进来时更新数据库中对象的方法。我曾经调用

@Update
void update(Form form)

在 dao 中，由于未知原因不会触发 LiveData-Observer。所以我把它改成了

@Insert(onConflict = OnConflictStrategy.REPLACE)
void insert(Form form);

完成此操作后，我可以从我的存储库中轻松获取 Form-LiveData

LiveData<List<Form>> liveData = formRepository.allForms();

然后像往常一样订阅它。之前失败的测试现在看起来像这样：

  @Test
  public void shouldSaveFormsFromServerIntoDb() throws Exception
   {
    Lifecycle lifecycle = Mockito.mock(Lifecycle.class);
    when(lifecycle.getCurrentState()).thenReturn(Lifecycle.State.RESUMED);
    LifecycleOwner owner = Mockito.mock(LifecycleOwner.class);
    when(owner.getLifecycle()).thenReturn(lifecycle);

    final CountDownLatch l = new CountDownLatch(19);

    final SortedList<Form> sortedForms = new SortedList<Form>(Form.class, new SortedList.Callback<Form>()
     {
      @Override
      public int compare(Form o1, Form o2)
       {
        return o1.getUniqueId().compareTo(o2.getUniqueId());
       }


      @Override
      public void onChanged(int position, int count)
       {
        Log.d(LOG_TAG, "onChanged: Form at position " + position + " has changed. Count is " + count);
        for (int i = 0; i < count; i++)
         {
          l.countDown();
         }
       }


      @Override
      public boolean areContentsTheSame(Form oldItem, Form newItem)
       {
        return (oldItem.getContent() != null && newItem.getContent() != null && oldItem.getContent().equals(newItem.getContent())) || oldItem.getContent() == null && newItem.getContent() == null;
       }


      @Override
      public boolean areItemsTheSame(Form item1, Form item2)
       {
        return item1.getUniqueId().equals(item2.getUniqueId());
       }


      @Override
      public void onInserted(int position, int count)
       {

       }


      @Override
      public void onRemoved(int position, int count)
       {

       }


      @Override
      public void onMoved(int fromPosition, int toPosition)
       {

       }
     });

    LiveData<List<Form>> ld = formRepository.allForms();
    ld.observe(owner, formList ->
    {
     if (formList != null && !formList.isEmpty())
      {
       Log.d(LOG_TAG, "shouldSaveFormsFromServerIntoDb: List contains " + sortedForms.size() + " Forms");
       sortedForms.addAll(formList);
      }
    });

    formRepository.synchronizeFormsWithServer(owner);
    l.await(2, TimeUnit.MINUTES);
    assertEquals(0, l.getCount());
   }

我知道将从服务器获取恰好 19 个表单，然后每个表单将被更改一次（第一次我加载包含所有表单数据减少的列表，第二次我从服务器加载每个项目再次替换旧值在具有更多数据的新值的数据库中）。

我不知道这是否会帮助你@joao86，但也许你有类似的问题。如果是这样，请务必在此处发表评论:)

于 2017-09-05T16:08:24.043 回答
7

您必须在所有地方使用相同的数据库实例。

=> 为此使用单例

于 2018-09-17T10:42:05.883 回答
3

我和你有类似的问题——> LiveData 在第一次调用后没有更新它的值

而不是使用 LiveData 使用 MutableLiveData 并将MutableLiveData<List<Form>>对象传递给存储库并执行setValue或postValue处理列表的新内容。

根据我对此的经验，这并不多，显然观察者也与您首先分配的对象相关联，并且必须对该对象进行每次更改。

于 2017-08-31T09:47:02.563 回答