我正在使用sqlbrite进行聊天应用。我需要观察一个数据库,但范围不是固定的。
Observable<Query> messages = db.createQuery("messages", "SELECT * FROM users WHERE timestamp > ? ");
我需要传递一个参数newestMessage.sentTime
,但是一旦新消息传来,newestmessage就会不断更新。因此,我不能仅通过当前的newestMessage
作为参数传递。
单个查询执行的结果永远不会更改并表示快照。要获取更多消息,您必须重新执行查询,即再次致电createQuery
。