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

SkunkSessionPoolDb

dataprism.skunk.sql.SkunkSessionPoolDb
class SkunkSessionPoolDb[F[_]](pool: Resource[F, Session[F]], autoTransact: Boolean)(implicit evidence$1: Concurrent[F]) extends SkunkSessionDb[F], CatsTransactionalDb[F, Codec]

Attributes

Source
SkunkSessionPoolDb.scala
Graph
Supertypes
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

Value members

Concrete methods

def skunkMapK[G[_] : Concurrent](f: FunctionK[F, G]): SkunkSessionPoolDb[G]

Attributes

Source
SkunkSessionPoolDb.scala
override def transactionResource(using NotGiven[TransactionDb[F, Codec]]): Resource[F, CatsTransactionDb[F, Codec]]

Attributes

Definition Classes
Source
SkunkSessionPoolDb.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
override def transaction[A](f: (TransactionDb[F, Codec]) ?=> F[A])(using NotGiven[TransactionDb[F, Codec]]): F[A]

Attributes

Definition Classes
Inherited from:
CatsTransactionalDb
Source
CatsTransactionalDb.scala
Generated with