SQLite

zio.blocks.sql.Dialect.SQLite
object SQLite extends Dialect

Attributes

Source
Dialect.scala
Graph
Supertypes
trait Dialect
trait SqlMigration
class Object
trait Matchable
class Any
Self type
SQLite.type

Members list

Value members

Concrete methods

def createQueueTableDDL(table: String, col: String): String

Idempotent CREATE TABLE IF NOT EXISTS DDL for the dirty-key queue table.

Idempotent CREATE TABLE IF NOT EXISTS DDL for the dirty-key queue table.

Attributes

Source
Dialect.scala
def createShadowTableDDL(shadowName: String, sourceTable: String): String

Idempotent shadow-table DDL copying sourceTable structure; unsupported on SQLite (raises UnsupportedOperationException).

Idempotent shadow-table DDL copying sourceTable structure; unsupported on SQLite (raises UnsupportedOperationException).

Attributes

Source
Dialect.scala
def createTriggerDDL(queueTable: String, sourceTable: String, sourceIdColumn: String, queueKeyColumn: String): List[String]

Statements installing capture triggers that upsert source-row keys into the queue table. Must be idempotent (safe to re-run on restart).

Statements installing capture triggers that upsert source-row keys into the queue table. Must be idempotent (safe to re-run on restart).

Attributes

Source
Dialect.scala
def dequeueSQL(table: String, col: String, batchSize: Int): String

SELECT claiming up to batchSize queue keys, ordered by key; on PostgreSQL the claim locks rows with FOR UPDATE SKIP LOCKED.

SELECT claiming up to batchSize queue keys, ordered by key; on PostgreSQL the claim locks rows with FOR UPDATE SKIP LOCKED.

Attributes

Source
Dialect.scala

Inherited methods

def ddl[A](table: Table[A]): Seq[Frag]

Pure DDL for the given table: create and drop fragments.

Pure DDL for the given table: create and drop fragments.

Delegates to existing Table/Ddl builders without opening any connection.

Attributes

Inherited from:
Dialect
Source
Dialect.scala

Concrete fields

val sqlDialect: SqlDialect

The SqlDialect this generation strategy targets, for mismatch checks against the live connection.

The SqlDialect this generation strategy targets, for mismatch checks against the live connection.

Attributes

Source
Dialect.scala
val supportsSkipLocked: Boolean

Whether dequeueSQL uses FOR UPDATE SKIP LOCKED (PostgreSQL only).

Whether dequeueSQL uses FOR UPDATE SKIP LOCKED (PostgreSQL only).

Attributes

Source
Dialect.scala