android - 使用 LiveData 转换获取 Room 关系数据库值

Question

Android 和 Java 的新手，正在尝试通过制作应用来学习。但现在我无法正确获取关系数据并将其显示在 RecyclerView 中(使用 ListAdapter 和 Infinite Scroll)。

这是我到目前为止所做工作的要点。

实体:
项目:

@Entity(...)
public class Item {

    @PrimaryKey(autoGenerate = true)
    private long item_id;

    @SerializedName("title")
    @Expose
    private String title = "";

    @Ignore
    @SerializedName("labels")
    @Expose
    private List<String> tags;

    ...
    }

标签:

@Entity(...)
public class Tag {

    @PrimaryKey(autoGenerate = true)
    private long id;

    @ColumnInfo(name = "tag_name")
    private String tagName;
    ...
}

关系:

@Entity(...)
public class ItemTags {

    private long item_id;

    private long tag_id;
    ...
}

改造:

public class ApiClient {
    // Init in Constructor
    private final MutableLiveData<List<Item>> mObservableData;
    ...

    public LiveData<List<Item>> getObservableData() {
        return mObservableData;
    }

    public void onResponse(...) {
        ...
        mObservableData.postValue(responseBody.getItems());

    }
}

存储库:插入数据库。

public void getNetworkCallback() {
    if (isFirstCallbackNeeded()) {
        Log.d(TAG, "getNetworkCallback: Called");
        mClient.getFirstCallback();
        insertItemsToDb();
    }
}

private void insertItemsToDb() {
    LiveData<List<Item>> downloadedData = mClient.getObservableData();
        if (items != null) {
            mExecutors.diskIO().execute(() -> {
                List<Long> itemIds = insertAllItems(items);

                for (int i = 0; i < items.size(); i++) {
                    long itemId = itemIds.get(i);
                    Log.d(TAG, "insertItemsToDb: " + itemId);

                    if (itemId != -1) {
                        List<String> labelNames = items.get(i).getTags();
                        for (String labelName : labelNames) {
                            insertUniqueTagName(new Tag(labelName));

                            long tagId = fetchIdByTagName(labelName);
                            insertRelational_ItemTags(new ItemTags(itemId, tagId));
                        }
                    }
                }
        }
    });
}

至此一切顺利。当数据库为空，得到响应后，数据成功插入数据库。

但每当我尝试获取与每个项目相关的标签时，同时使用 Transformations.map 在 RecyclerView 中显示, Tags返回的列表是 null或为空。

public LiveData<List<Item>> fetchAllItems() {
    LiveData<List<Item>> itemLiveData = mItemDao.fetchAllItems();
    itemLiveData = Transformations.map(itemLiveData, input -> {
        for (Item item : input) {
            mExecutors.diskIO().execute(() -> {
                long itemId = item.getItem_id();
                Log.d(TAG, "getTransformedObservableItems: itemId: " + itemId);
                List<String> tagNames = fetchRelationalTagNameById(itemId);
                Log.d(TAG, "getTransformedObservableItems: tagNames: " + tagNames);
                item.setTags(tagNames);
            });
        }
        return input;
    });

    return itemLiveData;
}

日志:

getTransformedObservableItems: itemId: 1
getTransformedObservableItems: tagNames: []
getTransformedObservableItems: itemId: 2
getTransformedObservableItems: tagNames: []
...

值得一提的是，我只观察 Dao 中的项目列表

@Query("SELECT * FROM item")
LiveData<List<Item>> fetchAllItems();

View 模型:

public ItemViewModel(ApiRepository apiRepository) {
    mObservableLiveData = apiRepository.fetchAllItems();
}

public LiveData<List<Item>> getObservableLiveData() {
    return mObservableLiveData;
}

Activity :

repository.getNetworkCallback();
// RecyclerView ListAdapter
mViewModel.getObservableLiveData().observe(this, adapter::submitList);

我在这里做错了什么？逻辑是否正确？任何建议都是有帮助的。

谢谢。

---

更新:

经过多次尝试，我发现使用 removeObserver()在 LiveData<List<Item>> fetchAllItems()在 insertItemsToDb() 内onChanged()方法，我能够达到结果。

但是因为我正在使用 Executors ，可悲的是，removeObserver()在后台线程中是不允许的。

有人有什么建议吗？

---

解决方案 Transformations#switchMap正如@Pycpik 所建议的

public LiveData<List<Item>> fetchAllTransformedItems() {
    LiveData<List<Item>> itemLiveData = fetchAllItems();
    itemLiveData = Transformations.switchMap(itemLiveData, input -> {
        final MutableLiveData<List<Item>> itemListMutableData = new MutableLiveData<>();
        mExecutors.diskIO().execute(() -> {
            for (Item item : input) {
                long itemId = item.getItem_id();
                List<String> tagNames = fetchRelationalTagNameById(itemId);
                item.setTags(tagNames);
            }
            itemListMutableData.postValue(input);
        });
        return itemListMutableData;
    });

    return itemLiveData;
}

Answer 1

我的情况并不完全相同，但下面是我如何使用 switchMap 和 RxJava 处理获取关系数据。也许它可以帮助你。

public LiveData<List<Item>> fetchAllItems() {
    LiveData<List<Item>> itemLiveData = mItemDao.fetchAllItems();
    itemLiveData = Transformations.switchMap(itemLiveData, input -> {
        MutableLiveData<List<Item>> mutableLiveData = new MutableLiveData<>();
        Completable.fromAction(() -> {
            for (Item item : input) {
                long itemId = item.getItem_id();
                Log.d(TAG, "getTransformedObservableItems: itemId: " + itemId);
                List<String> tagNames = fetchRelationalTagNameById(itemId);
                Log.d(TAG, "getTransformedObservableItems: tagNames: " + tagNames);
                item.setTags(tagNames);
            }
        })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(() -> {mutableLiveData.postValue(input);});
        return mutableLiveData;
    });
    return itemLiveData;
}