DataPrism
0.1.0
DocsAPI
Generated with
DataPrism/dataprism/dataprism.skunk/dataprism.skunk.sql/SkunkTransactionDb

SkunkTransactionDb

dataprism.skunk.sql.SkunkTransactionDb
class SkunkTransactionDb[F[_]](s: Session[F], val xa: Transaction[F])(implicit evidence$1: Concurrent[F]) extends SkunkSessionDb[F], CatsTransactionDb[F, Codec]

Attributes

Source
SkunkTransactionDb.scala
Graph
Supertypes
trait TransactionDb[F, Codec]
class SkunkSessionDb[F]
trait Fs2Db[F, Codec]
trait CatsDb[F, Codec]
trait Db[F, Codec]
class Object
trait Matchable
class Any
Show all

Members list

Type members

Types

override type Savepoint = xa.Savepoint

Attributes

Source
SkunkTransactionDb.scala

Value members

Concrete methods

override def commit: F[Unit]

Attributes

Definition Classes
Source
SkunkTransactionDb.scala
override def rollback: F[Unit]

Attributes

Definition Classes
Source
SkunkTransactionDb.scala
override def rollback(savepoint: xa.Savepoint): F[Unit]

Attributes

Definition Classes
Source
SkunkTransactionDb.scala
override def savepoint: F[xa.Savepoint]

Attributes

Definition Classes
Source
SkunkTransactionDb.scala

Inherited methods

protected def completionToInt(completion: Completion): Int

Attributes

Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
protected def makeCommand(sql: SqlStr[Codec]): (Command[Seq[Any]], Seq[Seq[Any]])

Attributes

Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
protected def makeQuery[Res[_[_]]](sql: SqlStr[Codec], dbTypes: Res[Codec])(using FT: TraverseKC[Res]): (Query[Seq[Any], Res[Id]], Seq[Seq[Any]])

Attributes

Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
def mapK[G[_]](f: FunctionK[F, G]): Db[G, Codec]

Attributes

Inherited from:
Db
Source
Db.scala
override def run(sql: SqlStr[Codec]): F[Int]

Attributes

Definition Classes
Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
override def runBatch(sql: SqlStr[Codec]): F[Seq[Int]]

Attributes

Definition Classes
Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
override def runIntoRes[Res[_[_]]](sql: SqlStr[Codec], dbTypes: Res[Codec], minRows: Int, maxRows: Int)(using FT: TraverseKC[Res]): F[Seq[Res[Id]]]

Attributes

Definition Classes
Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
override def runIntoResStream[Res[_[_]]](sql: SqlStr[Codec], dbTypes: Res[Codec], chunkSize: Int)(using FT: TraverseKC[Res]): Stream[F, Res[Id]]

Attributes

Definition Classes
Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala
override def runIntoSimple[Res](sql: SqlStr[Codec], dbTypes: Codec[Res]): F[Seq[Res]]

Attributes

Definition Classes
Inherited from:
SkunkSessionDb
Source
SkunkSessionDb.scala

Concrete fields

val xa: Transaction[F]

Attributes

Source
SkunkTransactionDb.scala
Generated with