Android -room persistent library - DAO 调用是异步的，因此如何获得回调？

Question

根据我的阅读，Room 不允许您在主线程上发出数据库查询（这会导致主线程延迟）。 所以想象一下我是尝试更新 UI 主线程上的文本视图，其中一些数据我将如何获得回电。让我给你举个例子。想象一下，我想将我的业务模型数据存储到一个名为 Events 的对象中。因此我们会有一个 EventDao 对象：

假设我们在下面有这个 DAO 对象：

@Dao
public interface EventDao {

   @Query("SELECT * FROM " + Event.TABLE_NAME + " WHERE " + Event.DATE_FIELD + " > :minDate" limit 1)
   LiveData<List<Event>> getEvent(LocalDateTime minDate);

   @Insert(onConflict = REPLACE)
   void addEvent(Event event);

   @Delete
   void deleteEvent(Event event);

   @Update(onConflict = REPLACE)
   void updateEvent(Event event);

}

现在在一些 activity 中我有一个文本视图，我想更新它的值所以我这样做：

 myTextView.setText(EventDao.getEvent(someDate));/*i think this is illegal as im trying to call room dao on mainthread, therefore how is this done correctly ? would i need to show a spinner while it updates ?*/

因为提取是在主线程之外发生的，所以我认为我不能像这样调用它并期望顺利更新。这里最好的方法是什么？

更多信息：我想使用房间数据库作为检索模型信息的机制，而不是将其静态保存在内存中。因此，在我通过休息服务下载模型后，我可以通过数据库在本地使用该模型。

更新：因为我要返回一个实时数据，所以我可以这样做：

eventDao = eventDatabase.eventDao();
eventDao.getEvent().observe(this, event -> {
     myTextView.setText(event.get(0));
});

这适用于非常小的东西。但想象一下我的数据库有一百万个项目。然后，当我执行此调用时，检索数据会有延迟。第一次调用时，用户会看到有延迟。如何避免这种情况？所以要清楚，有时我不想要实时数据，我只需要更新一次视图。我需要知道该怎么做？即使它与 liveData 无关。

Answer 1

有一种方法可以关闭异步并允许同步访问。

构建数据库时可以使用：allowMainThreadQueries()

以及在内存中使用：Room.inMemoryDatabaseBuilder()

虽然不推荐。所以最后，如果我想要超快速访问，我可以使用内存数据库和主线程访问。我想这取决于我的数据有多大，在这种情况下非常小。

但是如果你确实想使用回调....这里使用 rxJava 是我为我想存储在数据库中的国家/地区列表制作的：

public Observable<CountryModel> queryCountryInfoFor(final String isoCode) {
    return Observable.fromCallable(new Callable<CountryModel>() {
        @Override
        public CountryModel call() throws Exception {
            return db.countriesDao().getCountry(isoCode);
        }
    }).subscribeOn(Schedulers.io())
       
 .observeOn(AndroidSchedulers.mainThread());

}

然后您可以轻松地向该函数添加订阅者以使用 Rxjava 获取回调。

Answer 2

如果您想同步查询而不接收数据集更新通知，请不要将 return 值包装在 LiveData 对象中。查看 Google.

中的示例代码

看看loadProductSync()here

Answer 3

As Bohsen 建议使用实时数据进行同步查询。但是在某些特殊情况下，我们想做一些基于逻辑的异步操作。在下面的示例中，我需要为父评论获取一些子评论。它已经在数据库中可用，但需要根据它在 recyclerview 适配器中的 parent_id 来获取。为此，我使用了 AsyncTask 的 return 概念来取回结果。（Return 在 Kotlin 中）

存储者Class

fun getChildDiscussions(parentId: Int): List<DiscussionEntity>? {
        return GetChildDiscussionAsyncTask(discussionDao).execute(parentId).get()
    }

private class GetChildDiscussionAsyncTask constructor(private val discussionDao: DiscussionDao?): AsyncTask<Int, Void, List<DiscussionEntity>?>() {
        override fun doInBackground(vararg params: Int?): List<DiscussionEntity>? {
            return discussionDao?.getChildDiscussionList(params[0]!!)
        }
    }

道Class

@Query("SELECT * FROM discussion_table WHERE parent_id = :parentId")
fun getChildDiscussionList(parentId: Int): List<DiscussionEntity>?

Answer 4

嗯，正确的答案是使用 ListenableFuture 或 Observable，具体取决于您是需要一次性查询还是在数据库之后发出新值更改和您要使用的框架。

来自文档 “为了防止查询阻塞 UI，Room 不允许在主线程上访问数据库。此限制意味着您必须使 DAO 查询异步。该Room 库包括与多个不同框架的集成，以提供异步查询执行。"

一次性查询示例。您只需将其添加到 gradle 文件中即可。

// optional - Guava support for Room, including Optional and ListenableFuture
implementation "androidx.room:room-guava:$room_version"

然后您在 DAO 中的 SQL 查询变为。

@Query("SELECT * FROM " + Event.TABLE_NAME)
ListenableFuture<List<Event>> getEventList();

最后一步是 future 调用本身。

 ListenableFuture<List<Event>> future = dao.getEventList();
 future.addListener(new Runnable() {
    @Override
    public void run() {
        try {
            List<Event>> result = future.get();
        } catch (ExecutionException | InterruptedException e) {
        }
    }
}, Executors.newSingleThreadExecutor());

来源：https://developer.android.com/training/data-storage/room/async-queries#guava-livedata

Android -room persistent library - DAO 调用是异步的，因此如何获得回调？

Android -room persistent library - DAO calls are async, therefore how to get callback?

android

android-room