Free all resources allocated by Slick for this Database, blocking the current thread until everything has been shut down.
Free all resources allocated by Slick for this Database, blocking the current thread until everything has been shut down.
Backend implementations which are based on a naturally blocking shutdown procedure can
simply implement this method and get shutdown
as an asynchronous wrapper for free. If
the underlying shutdown procedure is asynchronous, you should implement shutdown
instead
and wrap it with Await.result
in this method.
Create the default DatabaseActionContext for this backend.
Create the default DatabaseActionContext for this backend.
Create a new session.
Create a new session. The session needs to be closed explicitly by calling its close() method.
Create the default StreamingDatabaseActionContext for this backend.
Create the default StreamingDatabaseActionContext for this backend.
Return the default ExecutionContet for this Database which should be used for running SynchronousDatabaseActions for asynchronous execution.
Return the default ExecutionContet for this Database which should be used for running SynchronousDatabaseActions for asynchronous execution.
Within a synchronous execution, ensure that a Session is available.
Within a synchronous execution, ensure that a Session is available.
Create a Reactive Streams Publisher
using the given context factory.
Create a Reactive Streams Publisher
using the given context factory.
Within a synchronous execution, close the current Session unless it is pinned.
Within a synchronous execution, close the current Session unless it is pinned.
If set to true, swallow all non-fatal errors that arise while closing the Session.
Run an Action asynchronously and return the result as a Future.
Run an Action in an existing DatabaseActionContext.
Run an Action in an existing DatabaseActionContext. This method can be overridden in subclasses to support new DatabaseActions which cannot be expressed through SynchronousDatabaseAction.
Whether to return the result as a stream. In this case, the context must
be a StreamingDatabaseActionContext
and the Future result should be
completed with null
or failed after streaming has finished. This
method should not call any Subscriber
method other than onNext
.
Run a SynchronousDatabaseAction
on this database.
Run a SynchronousDatabaseAction
on this database.
Stream a part of the results of a SynchronousDatabaseAction
on this database.
Stream a part of the results of a SynchronousDatabaseAction
on this database.
Free all resources allocated by Slick for this Database.
Free all resources allocated by Slick for this Database. This is done asynchronously, so
you need to wait for the returned Future
to complete in order to ensure that everything
has been shut down.
Create a Publisher
for Reactive Streams which, when subscribed to, will run the specified
DBIOAction
and return the result directly as a stream without buffering everything first.
Create a Publisher
for Reactive Streams which, when subscribed to, will run the specified
DBIOAction
and return the result directly as a stream without buffering everything first.
This method is only supported for streaming actions.
The Publisher itself is just a stub that holds a reference to the action and this Database.
The action does not actually start to run until the call to onSubscribe
returns, after
which the Subscriber is responsible for reading the full response or cancelling the
Subscription. The created Publisher can be reused to serve a multiple Subscribers,
each time triggering a new execution of the action.
For the purpose of combinators such as cleanup
which can run after a stream has been
produced, cancellation of a stream by the Subscriber is not considered an error. For
example, there is no way for the Subscriber to cause a rollback when streaming the
results of someQuery.result.transactionally
.
When using a JDBC back-end, all onNext
calls are done synchronously and the ResultSet row
is not advanced before onNext
returns. This allows the Subscriber to access LOB pointers
from within onNext
. If streaming is interrupted due to back-pressure signaling, the next
row will be prefetched (in order to buffer the next result page from the server when a page
boundary has been reached).
Stream a SynchronousDatabaseAction
on this database.
Stream a SynchronousDatabaseAction
on this database.
A database instance to which connections can be created.