我正在学习 RxJava 并浏览了几篇文章和视频。我对 RxJava 可以提供的东西感到非常棒，所以我认为目前正在了解响应式编程的全部内容。 This tutorial by Dan Lew在某种程度上帮助我理解了使用 RxJava 的基础知识。但我发现，当我认为自己已经完全理解 RxJava 时，我脑海中冒出的问题就越多。

因为我是一个在编写代码时学到最多的人，所以这就是我正在尝试做的事情。我已经有一个使用 SQLite 的应用程序。我的应用程序有 7 个饼图，它们从数据库游标获取数据。每个饼图从光标处获取不同行的数据(浮点值)，并根据其数据生成图表。

我现在要做的是，我想使用 RxJava 从数据库中检索数据并填充图表。但是我不知道 RxJava 应该如何与数据库交互。我是否需要使用任何其他库来执行此操作？因为我找到了rxjava-jdbc和 SqlBrite我认为这对我有帮助，但我真的需要它们吗？我还找到了一个 question in SO它似乎没有使用任何额外的库(当然除了 RxJava)而且他似乎使用了 ContentObservable 但我仍然没有完全理解它。此外，回答他问题的人甚至不使用 ContentObservable。而且我只知道 Android 有自己的 Observable 类.. 与 RxJava 一起使用是否完全兼容？如果不是，为什么同名？

有人请帮助我...

============================================= =========

下面是对 GreyBeardedGeek 的解决方案的回应:

这是我的 Callable，它从 sqlite 中检索数据

public class GetIncome implements Callable<Map<String,String>> {
    public static final String FILE_NAME = "CGetIncome";

    Context myContext;
    int year, month;

    public GetIncome(Context context, int getYear, int getMonth){
        myContext = context;
        year = getYear;
        month = getMonth;
    }

    @Override
    public Map<String,String> call() throws Exception {
        Map<String,String> output = new HashMap<>();
        JarControl jc = new JarControl(myContext);
        JSONObject getIncome = jc.getIncome(year,month,0,0);

        output.put("necessities",getIncome.getString("necessities"));
        output.put("savings",getIncome.getString("savings"));

        return output;
    }
}

下面是我尝试使用主要 Activity 中的 Callable 的方式:

Callable<Map<String,String>> getIncome = new GetIncome(getContext(),2015,9);

现在我不知道如何将可调用的 getIncome 放入 Observables 中。你提到 rx 中的 fromCallables 应该这样做..但实际上该怎么做？根据this tutorial that shows how to use Observable.from ，所以我希望能够通过执行 Observable.fromCallable 来使用 Callables，但显然该函数不存在。快速搜索显示 .fromCallable 应该通过执行类似 Async.fromCallable() 的操作来使用，但由于我是 RxJava 的新手，我只能根据 the tutorial 了解如何创建可调用对象。显示...

很抱歉我对 RxJava 的极端菜鸟

最佳答案

我敢肯定会有很多其他意见，但到目前为止，我已经采取了几种不同的方法:

• 如果您想要相对少量的数据(并且您可以保证它始终具有已知的大小上限)，那么:

  • 创建一个访问数据库的同步方法，获取游标，迭代游标以创建包含数据的数据结构(例如列表)，然后返回它。
  • 创建一个调用该方法的 Callable
  • 使用 rx.fromCallable 创建一个 Observable

• 如果您需要无限数量的行，请执行与上述类似的操作，但返回 Cursor。

编辑:示例代码:

private Map<String, String> getDataFromDatabase() { 
   Map<String, String> result = new HashMap<>(); 
   // do whatever you need to (i.e. db query, cursor) to fill it in 
   return result; 
} 

private Callable<Map<String, String>> getData() { 
   return new Callable() { 
      public Map<String, String> call() { 
        return getDataFromDatabase(); 
    } 
}

// in utility class  RxUtil.java 
public static <T> Observable<T> makeObservable(final Callable<T> func) {
        return Observable.create(
                new Observable.OnSubscribe<T>() {
                    @Override
                    public void call(Subscriber<? super T> subscriber) {
                        try {
                            T observed = func.call();
                            if (observed != null) { // to make defaultIfEmpty work
                                subscriber.onNext(observed);
                            }
                            subscriber.onCompleted();
                        } catch (Exception ex) {
                            subscriber.onError(ex);
                        }
                    }
                });
    }


// and finally, 
public Observable<Map<String, String>> getDataObservable() {
   return RxUtil.makeObservable(getData());
}

关于android - 使用 sqlite 开始使用 RxJava，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32672012/