| IAsyncDatabaseConnection Interface |
An interface for scheduling asynchronous access to an IDatabaseConnection in FIFO order.
Namespace: SQLitePCL.pretty
Assembly: SQLitePCL.pretty.Async (in SQLitePCL.pretty.Async.dll) Version: 1.0.0.0 (1.0.0)
SyntaxThe IAsyncDatabaseConnection type exposes the following members.
Methods| Name | Description | |
|---|---|---|
 | Dispose | Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. (Inherited from IDisposable.) |
| DisposeAsync |
Shutdown the underlying operations queue used by the IAsyncDatabaseConnection
and prevents the queuing of additional database access requests. Requests to access the database
prior to the call to DisposeAsync are allowed to complete, after which underlying
IDatabaseConnection is disposed.
|
| UseT |
Returns a cold IObservable which schedules the function f on the database operation queue each
time it is is subscribed to. The published values are generated by enumerating the IEnumerable returned by f.
|
Extension Methods| Name | Description | |
|---|---|---|
 | DeleteAllAsyncT(IEnumerableInt64, FuncIReadOnlyListIResultSetValue, T) | Overloaded.
Deletes all object instances specified by their primary keys.
(Defined by AsyncDatabaseConnection.) |
| DeleteAllAsyncT(IEnumerableInt64, FuncIReadOnlyListIResultSetValue, T, CancellationToken) | Overloaded.
Deletes all object instances specified by their primary keys.
(Defined by AsyncDatabaseConnection.) |
| DeleteAllRowsAsyncT | Overloaded.
Deletes all rows in a given table, asynchronously.
(Defined by AsyncDatabaseConnection.) |
| DeleteAllRowsAsyncT(CancellationToken) | Overloaded.
Deletes all rows in a given table, asynchronously.
(Defined by AsyncDatabaseConnection.) |
| DropTableIfExistsAsyncT | Overloaded.
Drops the table if exists async.
(Defined by AsyncDatabaseConnection.) |
| DropTableIfExistsAsyncT(CancellationToken) | Overloaded.
Drops the table if exists async.
(Defined by AsyncDatabaseConnection.) |
| ExecuteAllAsync(String) | Overloaded.
Compiles and executes multiple SQL statements.
(Defined by AsyncDatabaseConnection.) |
| ExecuteAllAsync(String, CancellationToken) | Overloaded.
Compiles and executes multiple SQL statements.
(Defined by AsyncDatabaseConnection.) |
| ExecuteAsync(String) | Overloaded.
Compiles and executes a SQL statement.
(Defined by AsyncDatabaseConnection.) |
| ExecuteAsync(String, Object) | Overloaded.
Compiles and executes a SQL statement with the provided bind parameter values.
(Defined by AsyncDatabaseConnection.) |
| ExecuteAsync(String, CancellationToken) | Overloaded.
Compiles and executes a SQL statement.
(Defined by AsyncDatabaseConnection.) |
| ExecuteAsync(String, CancellationToken, Object) | Overloaded.
Compiles and executes a SQL statement with the provided bind parameter values.
(Defined by AsyncDatabaseConnection.) |
| FindAllAsyncT(IEnumerableInt64, FuncIReadOnlyListIResultSetValue, T) | Overloaded.
Finds all object instances specified by their primary keys.
(Defined by AsyncDatabaseConnection.) |
| FindAllAsyncT(IEnumerableInt64, FuncIReadOnlyListIResultSetValue, T, CancellationToken) | Overloaded.
Finds all object instances specified by their primary keys.
(Defined by AsyncDatabaseConnection.) |
| InitTableAsyncT | Overloaded.
Creates or migrate a table in the database for the given table mapping, creating indexes if needed.
(Defined by AsyncDatabaseConnection.) |
| InitTableAsyncT(CancellationToken) | Overloaded.
Creates or migrate a table in the database for the given table mapping, creating indexes if needed.
(Defined by AsyncDatabaseConnection.) |
| InsertOrReplaceAllAsyncT(IEnumerableT, FuncIReadOnlyListIResultSetValue, T) | Overloaded.
Inserts the objects into the database, replacing existing entries if the given primary keys already exist.
(Defined by AsyncDatabaseConnection.) |
| InsertOrReplaceAllAsyncT(IEnumerableT, FuncIReadOnlyListIResultSetValue, T, CancellationToken) | Overloaded.
Inserts the objects into the database, replacing existing entries if the given primary keys already exist.
(Defined by AsyncDatabaseConnection.) |
| OpenBlobAsync(ColumnInfo, Int64, Boolean) | Overloaded.
Opens the blob located by the a database, table, column, and rowid for incremental asynchronous I/O as a Stream.
(Defined by AsyncDatabaseConnection.) |
| OpenBlobAsync(ColumnInfo, Int64, Boolean, CancellationToken) | Overloaded.
Opens the blob located by the a database, table, column, and rowid for incremental asynchronous I/O as a Stream.
(Defined by AsyncDatabaseConnection.) |
| OpenBlobAsync(String, String, String, Int64, Boolean) | Overloaded.
Opens the blob located by the a database, table, column, and rowid for incremental asynchronous I/O as a Stream.
(Defined by AsyncDatabaseConnection.) |
| OpenBlobAsync(String, String, String, Int64, Boolean, CancellationToken) | Overloaded.
Opens the blob located by the a database, table, column, and rowid for incremental asynchronous I/O as a Stream.
(Defined by AsyncDatabaseConnection.) |
| PrepareAllAsync(String) | Overloaded.
Compiles one or more SQL statements.
(Defined by AsyncDatabaseConnection.) |
| PrepareAllAsync(String, CancellationToken) | Overloaded.
Compiles one or more SQL statements.
(Defined by AsyncDatabaseConnection.) |
| PrepareStatementAsync(String) | Overloaded.
Compiles a SQL statement.
(Defined by AsyncDatabaseConnection.) |
| PrepareStatementAsync(String, CancellationToken) | Overloaded.
Compiles a SQL statement.
(Defined by AsyncDatabaseConnection.) |
| Query(String) | Overloaded.
Returns a cold observable that compiles a SQL statement
that publishes the rows in the result set for each subscription.
(Defined by AsyncDatabaseConnection.) |
| Query(ISqlQuery) | Overloaded.
Returns a cold observable that compiles a SQL query
that publishes the rows in the result set for each subscription.
(Defined by AsyncDatabaseConnection.) |
| Query(String, Object) | Overloaded.
Returns a cold observable that compiles a SQL statement with
provided bind parameter values, that publishes the rows in the result
set for each subscription.
(Defined by AsyncDatabaseConnection.) |
| Query(ISqlQuery, Object) | Overloaded.
Returns a cold observable that compiles a SQL query with
provided bind parameter values, that publishes the rows in the result
set for each subscription.
(Defined by AsyncDatabaseConnection.) |
| Use(ActionIDatabaseConnection) | Overloaded.
Schedules the Actionf on the database operations queue.
(Defined by AsyncDatabaseConnection.) |
| Use(ActionIDatabaseConnection, CancellationToken, CancellationToken) | Overloaded.
Schedules the Actionf on the database operations queue.
(Defined by AsyncDatabaseConnection.) |
| UseT(FuncIDatabaseConnection, T) | Overloaded.
Schedules the FuncT, TResultf on the database operations queue.
(Defined by AsyncDatabaseConnection.) |
| UseT(FuncIDatabaseConnection, IEnumerableT) | Overloaded.
Returns a cold IObservable which schedules the function f on the database operation queue each
time it is is subscribed to. The published values are generated by enumerating the IEnumerable returned by f.
(Defined by AsyncDatabaseConnection.) |
| UseT(FuncIDatabaseConnection, CancellationToken, T, CancellationToken) | Overloaded.
Schedules the FuncT, TResultf on the database operations queue.
(Defined by AsyncDatabaseConnection.) |
Properties| Name | Description | |
|---|---|---|
 | Profile |
A hot IObservableT of this connection's SQLite profile events.
|
| Trace |
A hot IObservableT of this connection's SQLite trace events.
|
| Update |
A hot IObservableT of this connection's SQLite update events.
|
See Also