scala.slick.jdbc

SessionWithAsyncTransaction

class SessionWithAsyncTransaction extends jdbc.JdbcBackend.BaseSession

Reimplementation of the transaction semantics of Slick's BaseSession#withTransaction, but in an API which can be driven from multiple asynchronous callbacks rather than only a single block.

NOTE: Used by SlickPlayIteratees to provide read consistency across chunked reads.

Source
SessionWithAsyncTransaction.scala
Linear Supertypes
JdbcBackend.BaseSession, JdbcBackend.SessionDef, JdbcBackend.SessionDef, Closeable, AutoCloseable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. SessionWithAsyncTransaction
  2. BaseSession
  3. SessionDef
  4. SessionDef
  5. Closeable
  6. AutoCloseable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SessionWithAsyncTransaction(db: DatabaseDef)

Type Members

  1. class LoggingPreparedStatement extends LoggingStatement with PreparedStatement

    Definition Classes
    SessionDef

  2. class LoggingStatement extends Statement

    Definition Classes
    SessionDef

Value Members

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

    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  4. def asDynamicSession[T](f: ⇒ T): T

    Definition Classes
    SessionDef

  5. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  6. def capabilities: JdbcBackend.DatabaseCapabilities

    Definition Classes
    BaseSession → SessionDef

  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  8. def close(): Unit

    Definition Classes
    BaseSession → SessionDef → SessionDef → Closeable → AutoCloseable

  9. def completeAsyncTransaction(): Unit

  10. lazy val conn: Connection

    Definition Classes
    BaseSession → SessionDef

  11. final def createStatement(defaultType: ResultSetType, defaultConcurrency: ResultSetConcurrency, defaultHoldability: ResultSetHoldability): Statement

    Definition Classes
    SessionDef

  12. val database: JdbcBackend.Database

    Definition Classes
    BaseSession → SessionDef

  13. var doRollback: Boolean

    Attributes
    protected
    Definition Classes
    BaseSession

  14. def ensureAsyncTransactionIsCompleted(): Unit

    Bring any active transaction to completion, resulting in either commit or rollback

  15. def ensureAsyncTransactionIsStarted(): Unit

  16. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  17. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  18. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  19. def forParameters(rsType: ResultSetType, rsConcurrency: ResultSetConcurrency, rsHoldability: ResultSetHoldability): JdbcBackend.Session

    Definition Classes
    SessionDef

  20. def force(): Unit

    Definition Classes
    SessionDef → SessionDef

  21. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  22. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  23. var inTransaction: Boolean

    Attributes
    protected
    Definition Classes
    BaseSession

  24. def isInTransaction: Boolean

    Definition Classes
    BaseSession

  25. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  26. def isOpen: Boolean

    Definition Classes
    SessionWithAsyncTransaction → BaseSession

  27. def loggingPreparedStatement(st: PreparedStatement): PreparedStatement

    Attributes
    protected
    Definition Classes
    SessionDef

  28. def loggingStatement(st: Statement): Statement

    Attributes
    protected
    Definition Classes
    SessionDef

  29. lazy val metaData: DatabaseMetaData

    Definition Classes
    BaseSession → SessionDef

  30. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  31. final def notify(): Unit

    Definition Classes
    AnyRef

  32. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  33. var open: Boolean

    Attributes
    protected
    Definition Classes
    BaseSession

  34. final def prepareInsertStatement(sql: String, columnIndexes: Array[Int]): PreparedStatement

    Definition Classes
    SessionDef

  35. final def prepareInsertStatement(sql: String, columnNames: Array[String]): PreparedStatement

    Definition Classes
    SessionDef

  36. final def prepareStatement(sql: String, defaultType: ResultSetType, defaultConcurrency: ResultSetConcurrency, defaultHoldability: ResultSetHoldability): PreparedStatement

    Definition Classes
    SessionDef

  37. def resultSetConcurrency: ResultSetConcurrency

    Definition Classes
    SessionDef

  38. def resultSetHoldability: ResultSetHoldability

    Definition Classes
    SessionDef

  39. def resultSetType: ResultSetType

    Definition Classes
    SessionDef

  40. def rollback(): Unit

    Definition Classes
    BaseSession → SessionDef → SessionDef

  41. def startAsyncTransaction(): Unit

  42. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  43. def toString(): String

    Definition Classes
    AnyRef → Any

  44. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  45. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  46. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  47. def withAsyncTransaction[T](f: (SessionDef) ⇒ T): T

    Execute the given block with an active async transaction

    Execute the given block with an active async transaction

    NOTE: If the given block throws an exception, then:

    1. The open transaction will be rolled back 2. Further calls are not allowed, throwing IllegalStateException, create a new Session instead

  48. final def withPreparedInsertStatement[T](sql: String, columnIndexes: Array[Int])(f: (PreparedStatement) ⇒ T): T

    Definition Classes
    SessionDef

  49. final def withPreparedInsertStatement[T](sql: String, columnNames: Array[String])(f: (PreparedStatement) ⇒ T): T

    Definition Classes
    SessionDef

  50. final def withPreparedStatement[T](sql: String, defaultType: ResultSetType, defaultConcurrency: ResultSetConcurrency, defaultHoldability: ResultSetHoldability)(f: (PreparedStatement) ⇒ T): T

    Definition Classes
    SessionDef

  51. final def withStatement[T](defaultType: ResultSetType, defaultConcurrency: ResultSetConcurrency, defaultHoldability: ResultSetHoldability)(f: (Statement) ⇒ T): T

    Definition Classes
    SessionDef

  52. def withTransaction[T](f: ⇒ T): T

    Definition Classes
    BaseSession → SessionDef → SessionDef

Inherited from JdbcBackend.BaseSession

Inherited from JdbcBackend.SessionDef

Inherited from JdbcBackend.SessionDef

Inherited from Closeable

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped