RxJava 和 Sqlbrite - 使用什么运算符

Question

我开始将 RxJava 与 SqlBrite 结合使用，但我在使用 zip 运算符时遇到了一些问题。

假设我有 2 个类、User 和 Tweet。

public class User {
    public long id;
    public List<Tweet> users;
    ...
}

public class Tweet {
    public long id;
    public User poster;
    ...
}

以及它们各自的 SQLite 表：

user
---------
id INTEGER PRIMARY KEY

tweet
---------
id INTEGER PRIMARY KEY
poster_id INTEGER
FOREIGN KEY(poster_id) REFERENCES user(id)

及其各自的 SqlBrite DAO

用户道：

public class UserDao {
    private final BriteDatabase briteDb;
    private final TweetDAO tweetDao;

    ...

    public Observable<List<User>> getUsersWithTheirTweets() {
        Observable<User> usersObs = briteDb.createQuery("user", "SELECT * FROM user")
                .map(new Func1<SqlBrite.Query, List<User>>() {
                    @Override
                    public List<User> call(SqlBrite.Query query) {
                        Cursor cursor = query.run();
                        List<User> result = new ArrayList<>(cursor.getCount());
                        while (cursor.moveToNext()) {
                            User user = UserTable.parseCursor(cursor);
                            result.add(user);
                        }
                        cursor.close();
                        return result;
                    }
                })
                // transform Observable<List<User>> into Observable<User>
                .flatMap(new Func1<List<User>, Observable<User>>() {
                    @Override
                    public Observable<User> call(List<User> users) {
                        return Observable.from(users);
                    }
                });

        // combine each user with his tweets
        return Observable.zip(usersObs, usersObs.flatMap(new Func1<User, Observable<List<Tweet>>>() {
            @Override
            public Observable<List<Tweet>> call(User user) {
                return tweetDao.getTweetsByUser(user);
            }
        }), new Func2<User, List<Tweet>, User>() {
            @Override
            public User call(User user, List<Tweet> tweets) {
                user.tweets = tweets;
                return user;
            }
        }).toList();
    }

}

TweetDAO:

public class TweetDAO {
    private final BriteDatabase briteDb;

    ...

    public Observable<List<Tweet>> getTweetsForUser(final User user) {
        briteDb.createQuery("tweet", "SELECT * FROM tweet WHERE poster_id = ?", Long.toString(user.id))
                .map(new Func1<SqlBrite.Query, List<User>>() {
                    @Override
                    public List<Tweet> call(SqlBrite.Query query) {
                        Cursor cursor = query.run();
                        List<Tweet> result = new ArrayList<>(cursor.getCount());
                        while (cursor.moveToNext()) {
                            Tweet tweet = TweetTable.parseCursor(cursor);
                            tweet.user = user;
                            result.add(tweet);
                        }
                        cursor.close();
                        return result;
                    }
                })
    }
}

如您在 UserDao 中所见，我尝试使用 zip 和 flatMap 运算符的组合来为每个 User.

第一个问题：有更好的方法吗？

第二个问题：zip 运算符似乎永远挂起并且永远不会完成...我看到调用了 tweetDao.getTweetsByUser(user) 但 zip 的 Func 是从来没有打电话...有人知道为什么吗？

第三个问题：除了使用 flatMap 和 from 的组合之外，是否有更好的方法将 Observable<List<T>> 转换为 Observable<T>？

该死，RxJava 很强大，但学习曲线非常陡峭...

Answer 1

为什么不让数据库处理连接？

SELECT * FROM user INNER JOIN tweet ON user._id = tweet.poster_id

如果两个表中有同名的列，您可能需要重命名某些列。

关于加入的更多信息here

RxJava 和 Sqlbrite - 使用什么运算符

RxJava and Sqlbrite - what operator to use

java

android

rx-java

sqlbrite