DataPrism
0.1.0
DocsAPI
Generated with
DataPrism/dataprism/dataprism.jdbc/dataprism.jdbc.sql/Fs2DataSourceDb

Fs2DataSourceDb

dataprism.jdbc.sql.Fs2DataSourceDb
class Fs2DataSourceDb[F[_]](ds: DataSource)(implicit evidence$1: Sync[F]) extends CatsDataSourceDb[F], Fs2Db[F, JdbcCodec]

Attributes

Source
Fs2DataSourceDb.scala
Graph
Supertypes
trait Fs2Db[F, JdbcCodec]
class CatsDataSourceDb[F]
trait ConnectionDb[F]
trait CatsDb[F, JdbcCodec]
trait Db[F, JdbcCodec]
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

override def runIntoResStream[Res[_[_]]](sql: SqlStr[JdbcCodec], dbTypes: Res[JdbcCodec], chunkSize: Int)(using FT: TraverseKC[Res]): Stream[F, Res[Id]]

Attributes

Definition Classes
Source
Fs2DataSourceDb.scala

Inherited methods

override protected def getConnection(using ResourceManager): Connection

Attributes

Definition Classes
Inherited from:
CatsDataSourceDb
Source
CatsDataSourceDb.scala
protected def makeAndUsePrepared[A : Monoid](sql: SqlStr[JdbcCodec], trueBatch: Boolean)(f: ResourceManager ?=> (PreparedStatement, Connection) => A): F[A]

Attributes

Inherited from:
ConnectionDb
Source
ConnectionDb.scala
protected def makePrepared(sql: SqlStr[JdbcCodec], con: Connection)(using ResourceManager): PreparedStatement

Attributes

Inherited from:
ConnectionDb
Source
ConnectionDb.scala
protected def makePreparedWithBatch[A : Monoid](sql: SqlStr[JdbcCodec], con: Connection, trueBatch: Boolean)(use: PreparedStatement => A)(implicit evidence$1: Monoid[A], ResourceManager): A

Attributes

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

Attributes

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

Attributes

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

Attributes

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

Attributes

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

Attributes

Definition Classes
Inherited from:
ConnectionDb
Source
ConnectionDb.scala
protected def setArgs(con: Connection, ps: PreparedStatement, args: Seq[SqlArg[JdbcCodec]], batch: Int)(using ResourceManager): Unit

Attributes

Inherited from:
ConnectionDb
Source
ConnectionDb.scala
override def transaction[A](f: (TransactionDb[F, JdbcCodec]) ?=> F[A])(using NotGiven[TransactionDb[F, JdbcCodec]]): F[A]

Attributes

Definition Classes
Inherited from:
CatsTransactionalDb
Source
CatsTransactionalDb.scala
override def transactionResource(using NotGiven[TransactionDb[F, JdbcCodec]]): Resource[F, CatsTransactionDb[F, JdbcCodec]]

Attributes

Definition Classes
Inherited from:
CatsDataSourceDb
Source
CatsDataSourceDb.scala
override protected def wrapTry[A](tryV: => Try[A]): F[A]

Attributes

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