- New: Allow
mapTo*
mappers to returnnull
values. This is useful when querying on a single, nullable column for whichnull
is a valid value. - Fix: When
mapToOne
does not emit a value downstream, request another value from upstream to ensure fixed-item requests (such astake(1)
) as properly honored. - Fix: Add logging to synchronous
execute
methods.
QueryObservable
constructor is now public allow instances to be created for tests.
- Fix: Document explicitly and correctly handle the fact that
Query.run()
can returnnull
in some situations. ThemapToOne
,mapToOneOrDefault
,mapToList
, andasRows
helpers have all been updated to handle this case and each is documented with their respective behavior.
- Fix: Apply backpressure strategy between database/content provider and the supplied
Scheduler
. This guards against backpressure exceptions when the scheduler is unable to keep up with the rate at which queries are being triggered. - Fix: Indent the subsequent lines of a multi-line queries when logging.
-
New: Require a
Scheduler
when wrapping a database or content provider which will be used when sending query triggers. This allows the query to be run in subsequent operators without needing an additionalobserveOn
. It also eliminates the need to usesubscribeOn
since the suppliedScheduler
will be used for all emissions (similar to RxJava'stimer
,interval
, etc.).This also corrects a potential violation of the RxJava contract and potential source of bugs in that all triggers will occur on the supplied
Scheduler
. Previously the initial value would trigger synchronously (on the subscribing thread) while subsequent ones trigger on the thread which performed the transaction. The new behavior puts the initial trigger on the same thread as all subsequent triggers and also does not force transactions to block while sending triggers.
- New: Query logs now contain timing information on how long they took to execute. This only covers
the time until a
Cursor
was made available, not object mapping or delivering to subscribers. - Fix: Switch query logging to happen when
Query.run
is called, not when a query is triggered. - Fix: Check for subscribing inside a transaction using a more accurate primitive.
- New: Expose
mapToOne
,mapToOneOrDefault
, andmapToList
as static methods onQuery
. These mirror the behavior of the methods of the same name onQueryObservable
but can be used later in a stream by passing the returnedOperator
instances tolift()
(e.g.,take(1).lift(Query.mapToOne(..))
). - Requires RxJava 1.1.0 or newer.
- New:
execute
method provides the ability to execute arbitrary SQL statements. - New:
executeAndTrigger
method provides the ability to execute arbitrary SQL statements and notifying any queries to update on the specified table. - Fix:
Query.asRows
no longer callsonCompleted
when the downstream subscriber has unsubscribed.
- New:
mapToOneOrDefault
replacesmapToOneOrNull
for more flexibility. - Fix: Notifications of table updates as the result of a transaction now occur after the transaction has been applied. Previous the notification would happen during the commit at which time it was invalid to create a new transaction in a subscriber.
- New:
mapToOne
andmapToOneOrNull
operators onQueryObservable
. These work on queries which return 0 or 1 rows and are a convenience for turning them into a typeT
given a mapper of typeFunc1<Cursor, T>
(the same which can be used formapToList
). - Fix: Remove
@WorkerThread
annotations for now. Various combinations of lint, RxJava, and retrolambda can cause false-positives.
- Transactions are now exposed as objects instead of methods. Call
newTransaction()
to start a transaction. On theTransaction
instance, callmarkSuccessful()
to indicate success andend()
to commit or rollback the transaction. TheTransaction
instance implementsCloseable
to allow its use in a try-with-resources construct. See thenewTransaction()
Javadoc for more information. Query
instances can now be turned directly into anObservable<T>
by callingasRows
with aFunc1<Cursor, T>
that maps rows to a typeT
. This allows easy filtering and limiting in memory rather than in the query. See theasRows
Javadoc for more information.createQuery
now returns aQueryObservable
which offers amapToList
operator. This operator also takes aFunc1<Cursor, T>
for mapping rows to a typeT
, but instead of individual rows it collects all the rows into a list. For large query results or frequently updated tables this can create a lot of objects. See themapToList
Javadoc for more information.- New: Nullability,
@CheckResult
, and@WorkerThread
annotations on all APIs allow a more useful interaction with lint in consuming projects.
- Fix: Add support for backpressure.
- An
Observable<Query>
can now be created from wrapping aContentResolver
in order to observe queries from another app's content provider. SqlBrite
class is now a factory for both aBriteDatabase
(theSQLiteOpenHelper
wrapper) andBriteContentResolver
(theContentResolver
wrapper).
Initial release.