Class

slick.memory.HeapBackend

DatabaseDef

Related Doc: package HeapBackend

Permalink

class DatabaseDef extends HeapBackend.DatabaseDef

Source
HeapBackend.scala
Linear Supertypes
HeapBackend.DatabaseDef, Closeable, AutoCloseable, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DatabaseDef
  2. DatabaseDef
  3. Closeable
  4. AutoCloseable
  5. AnyRef
  6. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DatabaseDef(synchronousExecutionContext: ExecutionContext)

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to any2stringadd[DatabaseDef] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (DatabaseDef, B)

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to ArrowAssoc[DatabaseDef] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  6. final def acquireSession(ctx: Context): Unit

    Permalink

    Within a synchronous execution, ensure that a Session is available.

    Within a synchronous execution, ensure that a Session is available.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  7. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  8. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. def close(): Unit

    Permalink

    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.

    Definition Classes
    DatabaseDefDatabaseDef → Closeable → AutoCloseable
  10. def createDatabaseActionContext[T](_useSameThread: Boolean): Context

    Permalink

    Create the default DatabaseActionContext for this backend.

    Create the default DatabaseActionContext for this backend.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDefDatabaseDef
  11. def createPublisher[T](a: DBIOAction[_, Streaming[T], Nothing], createCtx: (Subscriber[_ >: T]) ⇒ StreamingContext): DatabasePublisher[T]

    Permalink

    Create a Reactive Streams Publisher using the given context factory.

    Create a Reactive Streams Publisher using the given context factory.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  12. def createSession(): Session

    Permalink

    Create a new session.

    Create a new session. The session needs to be closed explicitly by calling its close() method.

    Definition Classes
    DatabaseDefDatabaseDef
  13. def createStreamingDatabaseActionContext[T](s: Subscriber[_ >: T], useSameThread: Boolean): StreamingContext

    Permalink

    Create the default StreamingDatabaseActionContext for this backend.

    Create the default StreamingDatabaseActionContext for this backend.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDefDatabaseDef
  14. def createTable(name: String, columns: IndexedSeq[Column], indexes: IndexedSeq[Index], constraints: IndexedSeq[Constraint]): HeapTable

    Permalink
  15. def createTableIfNotExists(name: String, columns: IndexedSeq[Column], indexes: IndexedSeq[Index], constraints: IndexedSeq[Constraint]): HeapTable

    Permalink
  16. def dropTable(name: String): Unit

    Permalink
  17. def dropTableIfExists(name: String): Unit

    Permalink
  18. def ensuring(cond: (DatabaseDef) ⇒ Boolean, msg: ⇒ Any): DatabaseDef

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to Ensuring[DatabaseDef] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  19. def ensuring(cond: (DatabaseDef) ⇒ Boolean): DatabaseDef

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to Ensuring[DatabaseDef] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  20. def ensuring(cond: Boolean, msg: ⇒ Any): DatabaseDef

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to Ensuring[DatabaseDef] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  21. def ensuring(cond: Boolean): DatabaseDef

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to Ensuring[DatabaseDef] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  22. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  23. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  24. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. def formatted(fmtstr: String): String

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to StringFormat[DatabaseDef] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  26. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  27. def getTable(name: String): HeapTable

    Permalink
  28. def getTables: IndexedSeq[HeapTable]

    Permalink
  29. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  30. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  31. def logAction(a: DBIOAction[_, NoStream, Nothing], ctx: Context): Unit

    Permalink
    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  32. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  33. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  34. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  35. final def releaseSession(ctx: Context, discardErrors: Boolean): Unit

    Permalink

    Within a synchronous execution, close the current Session unless it is pinned.

    Within a synchronous execution, close the current Session unless it is pinned.

    discardErrors

    If set to true, swallow all non-fatal errors that arise while closing the Session.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  36. final def run[R](a: DBIOAction[R, NoStream, Nothing]): Future[R]

    Permalink

    Run an Action asynchronously and return the result as a Future.

    Run an Action asynchronously and return the result as a Future.

    Definition Classes
    DatabaseDef
  37. def runInContext[R](a: DBIOAction[R, NoStream, Nothing], ctx: Context, streaming: Boolean, topLevel: Boolean): Future[R]

    Permalink

    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.

    streaming

    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.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  38. def runSynchronousDatabaseAction[R](a: SynchronousDatabaseAction[R, NoStream, This, _], ctx: Context, continuation: Boolean): Future[R]

    Permalink

    Run a SynchronousDatabaseAction on this database.

    Run a SynchronousDatabaseAction on this database.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  39. def scheduleSynchronousStreaming(a: SynchronousDatabaseAction[_, _ <: NoStream, This, _ <: Effect], ctx: StreamingContext, continuation: Boolean)(initialState: StreamState): Unit

    Permalink

    Stream a part of the results of a SynchronousDatabaseAction on this database.

    Stream a part of the results of a SynchronousDatabaseAction on this database.

    Attributes
    protected[slick.basic.BasicBackend]
    Definition Classes
    DatabaseDef
  40. def shutdown: Future[Unit]

    Permalink

    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.

    Definition Classes
    DatabaseDefDatabaseDef
  41. final def stream[T](a: DBIOAction[_, Streaming[T], Nothing]): DatabasePublisher[T]

    Permalink

    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).

    Definition Classes
    DatabaseDef
  42. def streamSynchronousDatabaseAction(a: SynchronousDatabaseAction[_, _ <: NoStream, This, _ <: Effect], ctx: StreamingContext, continuation: Boolean): Future[Null]

    Permalink

    Stream a SynchronousDatabaseAction on this database.

    Stream a SynchronousDatabaseAction on this database.

    Attributes
    protected[this]
    Definition Classes
    DatabaseDef
  43. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  44. val synchronousExecutionContext: ExecutionContext

    Permalink

    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.

    Attributes
    protected
    Definition Classes
    DatabaseDefDatabaseDef
  45. val tables: HashMap[String, HeapTable]

    Permalink
    Attributes
    protected
  46. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  47. def truncateTable(name: String): Unit

    Permalink
  48. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. def [B](y: B): (DatabaseDef, B)

    Permalink
    Implicit information
    This member is added by an implicit conversion from DatabaseDef to ArrowAssoc[DatabaseDef] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from HeapBackend.DatabaseDef

Inherited from Closeable

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from DatabaseDef to any2stringadd[DatabaseDef]

Inherited by implicit conversion StringFormat from DatabaseDef to StringFormat[DatabaseDef]

Inherited by implicit conversion Ensuring from DatabaseDef to Ensuring[DatabaseDef]

Inherited by implicit conversion ArrowAssoc from DatabaseDef to ArrowAssoc[DatabaseDef]

Ungrouped