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

SkunkSessionDb

dataprism.skunk.sql.SkunkSessionDb
abstract class SkunkSessionDb[F[_]](autoTransact: Boolean)(implicit evidence$1: Concurrent[F]) extends Fs2Db[F, Codec]

Attributes

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

Members list

Value members

Abstract methods

protected def getSession: Resource[F, Session[F]]

Attributes

Source
SkunkSessionDb.scala

Concrete methods

protected def completionToInt(completion: Completion): Int

Attributes

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

Attributes

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

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

Attributes

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

Attributes

Definition Classes
Db
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
Db
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
Source
SkunkSessionDb.scala
override def runIntoSimple[Res](sql: SqlStr[Codec], dbTypes: Codec[Res]): F[Seq[Res]]

Attributes

Definition Classes
Db
Source
SkunkSessionDb.scala

Inherited methods

def mapK[G[_]](f: FunctionK[F, G]): Db[G, Codec]

Attributes

Inherited from:
Db
Source
Db.scala
Generated with