android - 分页库-从网络请求时从缓存填充

我必须从数据库中加载缓存的数据版本，同时我想向服务器发出新数据的请求，并且我希望每页执行一次。
因此，例如对于第一页，我想显示数据库中第一页数据的缓存版本，同时仅请求第一页的新数据。

我想使用Paging Library实现。

我尝试创建自定义数据源，该数据源帮助我拦截了页面加载请求，然后我用所需的页码和限制进行了网络调用，同时我从db返回了缓存的版本，问题是从网络获取新数据后，我更新了数据库，但这些更新不会反映出来。

（我相信使用Invalidation Tracker会对整个表进行任何修改，并且每当表无效时数据源都会失效，我也在数据源中添加了该Tracker，但仍然无法正常工作;我能够确定Invalidation通过临时创建跟踪器事物：JobDao中的LivePagedListProvider getJobs（）并检查生成的实现）

码：

public class JobListDataSource<T> extends TiledDataSource<T> {

private final JobsRepository mJobsRepository;
private final InvalidationTracker.Observer mObserver;


String query = "";

public JobListDataSource(JobsRepository jobsRepository) {
    mJobsRepository = jobsRepository;

    mObserver = new InvalidationTracker.Observer(JobEntity.TABLE_NAME) {
        @Override
        public void onInvalidated(@NonNull Set<String> tables) {
            invalidate();
        }
    };

    jobsRepository.addInvalidationTracker(mObserver);
}


@Override
public int countItems() {
    return DataSource.COUNT_UNDEFINED;
}

@Override
public List<T> loadRange(int startPosition, int count) {
    return (List<T>) mJobsRepository.getJobs(query, startPosition, count);
}


public void setQuery(String query) {
    this.query = query;
}
}

作业存储库功能：

public List<JobEntity> getJobs(String query, int startPosition, int count) {
    if (!isJobListInit) {
        JobList jobList = mApiService.getOpenJobList(
                mRequestJobList.setPageNo(startPosition/count + 1)
                .setMaxResults(count)
                .setSearchKeyword(query)
        ).blockingSingle();
        mJobDao.insert(jobList.getJobsData());
    }
    return mJobDao.getJobs(startPosition, count);
}

public void addInvalidationTracker(InvalidationTracker.Observer observer) {
    mAppDatabase.getInvalidationTracker().addObserver(observer);
}

最佳答案

因此，我了解了为什么它不起作用，最后出现了一个错误，我在JobsRepository中将错误的参数传递给JobDao的getJobs方法。

JobDao的getJobs方法如下：

@Query("SELECT * FROM jobs ORDER BY jobID ASC LIMIT :limit OFFSET :offset")
List<JobEntity> getJobs(int limit, int offset);

JobsRepository中的getJobs（）调用如下：

return mJobDao.getJobs(startPosition, count);

因此，第一个参数是极限，第二个参数是偏移量，但是我绕过了其他方向。

现在它就像一种魅力！

此外，我在JobsRepository中对getJobs（）进行了更改：
首先从db获取数据（如果可用），并在需要时向网络发出异步请求。
如果db中没有可用数据，请对网络进行同步调用，从网络中获取数据，解析并保存为db，现在从db中访问最新数据并返回。
因此，函数如下所示：

//you can even refactor this code so that all the network related stuff is in one class and just call that method
public List<JobListItemEntity> getJobs(String query, int startPosition, int count) {
    Observable<JobList> jobListObservable = mApiService.getOpenJobList(
            mRequestJobList.setPageNo(startPosition / count + 1)
                    .setMaxResults(count)
                    .setSearchKeyword(query));

    List<JobListItemEntity> jobs = mJobDao.getJobsLimitOffset(count, startPosition);

    //no data in db, make a synchronous call to network to get the data
    if (jobs.size() == 0) {
        JobList jobList = jobListObservable.blockingSingle();
        updateJobList(jobList, startPosition, false);
    } else if (shouldFetchJobList(jobs)) {
        //data available in db, so show a cached version and make async network call to update data as this data is no longer fresh
        jobListObservable.subscribe(new Observer<JobList>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(JobList jobList) {
                updateJobList(jobList, startPosition, true);
            }

            @Override
            public void onError(Throwable e) {
                Timber.e(e);
            }

            @Override
            public void onComplete() {

            }
        });
    }
    return mJobDao.getJobsLimitOffset(count, startPosition);
}

updateJobList（）代码：

    private void updateJobList(JobList jobList, int startPosition, boolean performInvalidation) {
    JobListItemEntity[] jobs = jobList.getJobsData();

    Date currentDate = Calendar.getInstance().getTime();

    //tracks when this item was inserted in db, used in calculating whether data is stale
    for (int i = 0; i < jobs.length; i++) {
        jobs[i].insertedAt = currentDate;
    }

    mJobDao.insert(jobs);

    if (performInvalidation) {
        mJobListDataSource.invalidate();
    }
}

（我也将JobDao中的getJobs（）重命名为getJobsLimitOffset（），因为它更易读，这也是分页库生成方法的方式）