Rxjava2_Flowable_Sqlite_Android数据库访问实例(2)-木庄网络博客

使用了lambda简化了表达式进一步简化代码：

简化方法：在/app/build.gradle里面加入如下内容：(defaultConfig的外面)

compileOptions { 
 sourceCompatibility JavaVersion.VERSION_1_8 
 targetCompatibility JavaVersion.VERSION_1_8 
}

接口调用（获得数据库实例）：

//全局定义的实例获取类，以后想要换数据库，只需在这个类里切换即可 
public class Injection { 
 public static DbSource getDbSource(Context context) { 
  //choose one of them 
  //return BriteDb.getInstance(context); 
  return SimpleDb.getInstance(context); 
 } 
} 
 
DbSource db = Injection.getInstance(mContext); 
 
disposable1 = db.getAllTask() 
       .flatMap(Flowable::fromIterable) 
       .filter(task -> {     //自定义过滤 
         if (!task.getIsuploadend()) { 
          return true; 
         } else { 
          return false; 
         } 
       }) 
       .subscribe(taskItems -> //这里是使用了lambda简化了表达式 
        doTaskProcess(taskItems) 
       , throwable -> { 
        throwable.printStackTrace(); 
       },// onCompleted 
       () -> { 
        if (disposable1 != null && !disposable1.isDisposed()) { 
         disposable1.dispose(); 
        } 
       }); 
 
 disposable1 = db.getRunningTask() 
    .filter(Optional::isPresent) //判断是否为空，为空的就跳过 
    .map(Optional::get)    //获取到真的参数 
    .subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(taskItem -> {     //onNext() 
       //has running task 
       mTid = taskItem.getTid(); 
    }, throwable -> throwable.printStackTrace() //onError() 
    , () -> disposable1.dispose());    //onComplete() 
 
disposable1 = db.markUploadEnd(tid, isuploadend) 
    .subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(status -> {     //onNext() 
       if (status) { 
        //dosomething 
       } 
    }, throwable -> throwable.printStackTrace() //onError() 
    , () -> disposable1.dispose());    //onComplete() 
 
disposable1 = db.deleteTask(tid) 
    .subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(status -> {     //onNext() 
       if (status) { 
        //dosomething 
       } 
    }, throwable -> throwable.printStackTrace() //onError() 
    , () -> disposable1.dispose());    //onComplete()

以上这篇Rxjava2_Flowable_Sqlite_Android数据库访问实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

标签：SQLite

返回前面的内容