Android JetPack現(xiàn)在已經(jīng)在android開發(fā)中大行其道，以下是個人使用LiveData與數(shù)據(jù)庫查詢的一點(diǎn)總結(jié)。
LiveData + Room
官方已經(jīng)出了rxRoom话速，DAO中已經(jīng)可以直接使用RxJava沿量。這里有一個使用LiveData+Room的例子 PDFReader
@Dao
public interface PdfDAO {
@Query("SELECT * FROM Pdf WHERE read_time != 0 ORDER BY read_time DESC")
Flowable<List<Pdf>> getRecentPdf();
@Query("SELECT * FROM Pdf WHERE read_time != 0 ORDER BY read_time DESC")
Flowable<List<Pdf>> getAllPdf();
@Query("SELECT * FROM Pdf WHERE file_path = :path LIMIT 1")
Single<Pdf> getPdf(String path);
@Insert(onConflict = OnConflictStrategy.REPLACE)
Completable insertPdf(Pdf pdf);
@Delete
int deletePdf(Pdf pdf);
}
返回結(jié)果可以是：Maybe颂砸，F(xiàn)lowable，Single其垄，其中Completeable目前只有androidx支持
其中Flowable會一直監(jiān)聽數(shù)據(jù)庫變化，具體如何實(shí)現(xiàn)的以后再分享
于是就可以使用Flowable來實(shí)時更新界面：
public class DocumentLiveData extends LiveData<List<Pdf>> {
private boolean mRecentLivaData;
private PdfDAO mPdfDao;
private Disposable mDisposable;
public DocumentLiveData(Context context, boolean recent) {
mRecentLivaData = recent;
mPdfDao = AppDatabase.getInstance(context).getPdfDAO();
}
@Override
protected void onActive() {
super.onActive();
Flowable<List<Pdf>> flowable;
if (mRecentLivaData) {
flowable = mPdfDao.getRecentPdf();
} else {
flowable = mPdfDao.getAllPdf();
}
mDisposable = flowable.subscribeOn(Schedulers.io())
.subscribe(this::postValue,
t -> Log.e("PdfRepository", "Query pdf items failed", t));
}
@Override
protected void onInactive() {
if (mDisposable != null) {
mDisposable.dispose();
mDisposable = null;
}
super.onInactive();
}
}
LiveData + RxJava + ContentProvider
上面的方法適用與本地自建數(shù)據(jù)庫卤橄，有時需要監(jiān)聽第三方數(shù)據(jù)庫（多通過ContentProvider提供）
以下是一個例子捉捅，查詢系統(tǒng)CalendarProvider中有事件的天：
public class EventDayLiveData extends MutableLiveData<List<Integer>> {
private static final String[] PROJECTION = new String[]{
Instances.START_DAY,
Instances.END_DAY
};
private static final int INDEX_START_DAY = 0;
private static final int INDEX_END_DAY = 1;
public static final String SELECTION = Calendars.VISIBLE + "=1";
private ContentResolver mContentResolver;
private Handler mMainHandler;
private ContentObserver mContentObserver;
private PublishProcessor<Object> triggers;
private Disposable mEventBus;
private CompositeDisposable mQueries;
// 事件加載的起始天, julianDay
private int mStartDay;
// 事件加載的結(jié)束天, julianDay
private int mEndDay;
private Runnable mTimeChangeUpdater = new Runnable() {
@Override
public void run() {
// reload event day
if (triggers != null) {
triggers.onNext("TimeChange");
}
}
};
public EventDayLiveData(Context content) {
mMainHandler = new Handler(Looper.getMainLooper());
mContentResolver = content.getApplicationContext().getContentResolver();
mQueries = new CompositeDisposable();
triggers = PublishProcessor.create();
mContentObserver = new ContentObserver(mMainHandler) {
@Override
public void onChange(boolean selfChange) {
// reload event day
if (triggers != null) {
triggers.onNext("EventChange");
}
}
};
TimeCalendar time = new TimeCalendar(1970, 0, 1);
mStartDay = time.getJulianDay();
time.set(2037, 11,31);
mEndDay = time.getJulianDay();
}
@Override
protected void onActive() {
Timber.d(" onActive");
// 過濾 200 毫秒內(nèi)的多次加載請求
mEventBus = triggers.throttleFirst(200, TimeUnit.MILLISECONDS)
.doOnNext(new Consumer<Object>() {
@Override
public void accept(Object o) throws Exception {
Timber.d(" receive action : %s", o.toString());
}
})
.subscribe(new Consumer<Object>() {
@Override
public void accept(Object o) throws Exception {
loadEventDays();
}
});
//Utils.setMidnightUpdater(mMainHandler, mTimeChangeUpdater, TimeZone.getDefault().getID());
mContentResolver.registerContentObserver(CalendarContract.CONTENT_URI, true, mContentObserver);
triggers.onNext("InitValue");
}
@Override
protected void onInactive() {
Timber.d(" onInactive");
mContentResolver.unregisterContentObserver(mContentObserver);
//Utils.resetMidnightUpdater(mMainHandler, mTimeChangeUpdater);
if (mQueries != null) {
mQueries.dispose();
}
if (mEventBus != null) {
mEventBus.dispose();
}
}
private void loadEventDays() {
final Disposable disposable = Observable.create(
new ObservableOnSubscribe<List<Integer>>() {
@Override
public void subscribe(ObservableEmitter<List<Integer>> emitter) {
if (emitter.isDisposed()) {
return;
}
try {
emitter.onNext(queryEventDay());
emitter.onComplete();
} catch (Exception e) {
emitter.onError(e);
}
}
})
.filter(new Predicate<List<Integer>>() {
@Override
public boolean test(List<Integer> list) {
// 判斷數(shù)據(jù)是否變化
return eventDaysChanged(getValue(), list);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<List<Integer>>() {
@Override
public void accept(List<Integer> list) {
setValue(list);
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) {
Timber.i(throwable,"Query event day failed");
}
});
mQueries.add(disposable);
}
private List<Integer> queryEventDay() {
Uri.Builder builder = EventDays.CONTENT_URI.buildUpon();
ContentUris.appendId(builder, mStartDay);
ContentUris.appendId(builder, mEndDay);
Uri uri = builder.build();
Cursor c = mContentResolver.query(uri, PROJECTION, SELECTION, null, null);
List<Integer> dayList = new ArrayList<>();
if (c != null && c.moveToFirst()) {
while (!c.isAfterLast()) {
int startDay = c.getInt(INDEX_START_DAY);
int endDay = c.getInt(INDEX_END_DAY);
if (endDay != startDay) {
for (int i = startDay; i <= endDay; i++) {
if (!dayList.contains(i)) {
dayList.add(i);
}
}
} else {
if (!dayList.contains(startDay)) {
dayList.add(startDay);
}
}
c.moveToNext();
}
}
if (c != null) {
c.close();
}
return dayList;
}
private boolean eventDaysChanged(List<Integer> oldList, List<Integer> newList) {
if (oldList == null) {
return true;
}
if (oldList.size() != newList.size()) {
return true;
}
return !oldList.containsAll(newList);
}
}
主要思路就是通過注冊數(shù)據(jù)庫變化來持續(xù)獲取事件流丟給PublishProcessor下發(fā)到下游訂閱者處理
