class R2dbcExecutor extends AnyRef
INTERNAL API:
- Annotations
- @InternalStableApi()
- Alphabetic
- By Inheritance
- R2dbcExecutor
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new R2dbcExecutor(connectionFactory: ConnectionFactory, log: Logger, logDbCallsExceeding: FiniteDuration)(implicit ec: ExecutionContext, system: ActorSystem[_])
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- val connectionFactory: ConnectionFactory
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def executeDdl(logPrefix: String)(statement: (Connection) => Statement): Future[Done]
Run DDL statement with auto commit.
- def executeDdls(logPrefix: String)(statementFactory: (Connection) => IndexedSeq[Statement]): Future[Done]
Run DDL statements in the same transaction.
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def select[A](logPrefix: String)(statement: (Connection) => Statement, mapRow: (Row) => A): Future[IndexedSeq[A]]
- def selectOne[A](logPrefix: String)(statement: (Connection) => Statement, mapRow: (Row) => A): Future[Option[A]]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def update(logPrefix: String)(statementsFactory: (Connection) => IndexedSeq[Statement]): Future[IndexedSeq[Int]]
Several update statements in the same transaction.
- def updateInBatch(logPrefix: String)(statementFactory: (Connection) => Statement): Future[Int]
Update statement that is constructed by several statements combined with
add(). - def updateInBatchReturning[A](logPrefix: String)(statementFactory: (Connection) => Statement, mapRow: (Row) => A): Future[IndexedSeq[A]]
Update statement that is constructed by several statements combined with
add().Update statement that is constructed by several statements combined with
add(). Returns the mapped result of all rows. For example with Postgres:INSERT INTO foo(name) VALUES ('bar') returning db_timestamp - def updateOne(logPrefix: String)(statementFactory: (Connection) => Statement): Future[Int]
One update statement with auto commit.
- def updateOneReturning[A](logPrefix: String)(statementFactory: (Connection) => Statement, mapRow: (Row) => A): Future[A]
One update statement with auto commit and return mapped result.
One update statement with auto commit and return mapped result. For example with Postgres:
INSERT INTO foo(name) VALUES ('bar') returning db_timestamp - final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withAutoCommitConnection[A](logPrefix: String)(fun: (Connection) => Future[A]): Future[A]
Runs the passed function in using a Connection with auto-commit enable (non-transactional).
- def withConnection[A](logPrefix: String)(fun: (Connection) => Future[A]): Future[A]
Runs the passed function in using a Connection that's participating on a transaction Transaction is commit at the end or rolled back in case of failures.