libsql

Types

Connection

pub type Connection

Error

</>

pub type Error {
  LibsqlError(code: ErrorCode, message: String, offset: Int)
}

Constructors

LibsqlError(code: ErrorCode, message: String, offset: Int)

ErrorCode

</>

pub type ErrorCode {
  Abort
  Auth
  Busy
  Cantopen
  Constraint
  Corrupt
  Done
  Empty
  GenericError
  Format
  Full
  Internal
  Interrupt
  Ioerr
  Locked
  Mismatch
  Misuse
  Nolfs
  Nomem
  Notadb
  Notfound
  Notice
  GenericOk
  Perm
  Protocol
  Range
  Readonly
  Row
  Schema
  Toobig
  Warning
  AbortRollback
  AuthUser
  BusyRecovery
  BusySnapshot
  BusyTimeout
  CantopenConvpath
  CantopenDirtywal
  CantopenFullpath
  CantopenIsdir
  CantopenNotempdir
  CantopenSymlink
  ConstraintCheck
  ConstraintCommithook
  ConstraintDatatype
  ConstraintForeignkey
  ConstraintFunction
  ConstraintNotnull
  ConstraintPinned
  ConstraintPrimarykey
  ConstraintRowid
  ConstraintTrigger
  ConstraintUnique
  ConstraintVtab
  CorruptIndex
  CorruptSequence
  CorruptVtab
  ErrorMissingCollseq
  ErrorRetry
  ErrorSnapshot
  IoerrAccess
  IoerrAuth
  IoerrBeginAtomic
  IoerrBlocked
  IoerrCheckreservedlock
  IoerrClose
  IoerrCommitAtomic
  IoerrConvpath
  IoerrCorruptfs
  IoerrData
  IoerrDelete
  IoerrDeleteNoent
  IoerrDirClose
  IoerrDirFsync
  IoerrFstat
  IoerrFsync
  IoerrGettemppath
  IoerrLock
  IoerrMmap
  IoerrNomem
  IoerrRdlock
}

Constructors

```
Abort
```
```
Auth
```
```
Busy
```
```
Cantopen
```
```
Constraint
```
```
Corrupt
```
```
Done
```
```
Empty
```
```
GenericError
```
```
Format
```
```
Full
```
```
Internal
```
```
Interrupt
```
```
Ioerr
```
```
Locked
```
```
Mismatch
```
```
Misuse
```
```
Nolfs
```
```
Nomem
```
```
Notadb
```
```
Notfound
```
```
Notice
```
```
GenericOk
```
```
Perm
```
```
Protocol
```
```
Range
```
```
Readonly
```
```
Row
```
```
Schema
```
```
Toobig
```
```
Warning
```
```
AbortRollback
```
```
AuthUser
```
```
BusyRecovery
```
```
BusySnapshot
```
```
BusyTimeout
```
```
CantopenConvpath
```
```
CantopenDirtywal
```
```
CantopenFullpath
```
```
CantopenIsdir
```
```
CantopenNotempdir
```
```
CantopenSymlink
```
```
ConstraintCheck
```
```
ConstraintCommithook
```
```
ConstraintDatatype
```
```
ConstraintForeignkey
```
```
ConstraintFunction
```
```
ConstraintNotnull
```
```
ConstraintPinned
```
```
ConstraintPrimarykey
```
```
ConstraintRowid
```
```
ConstraintTrigger
```
```
ConstraintUnique
```
```
ConstraintVtab
```
```
CorruptIndex
```
```
CorruptSequence
```
```
CorruptVtab
```
```
ErrorMissingCollseq
```
```
ErrorRetry
```
```
ErrorSnapshot
```
```
IoerrAccess
```
```
IoerrAuth
```
```
IoerrBeginAtomic
```
```
IoerrBlocked
```
```
IoerrCheckreservedlock
```
```
IoerrClose
```
```
IoerrCommitAtomic
```
```
IoerrConvpath
```
```
IoerrCorruptfs
```
```
IoerrData
```
```
IoerrDelete
```
```
IoerrDeleteNoent
```
```
IoerrDirClose
```
```
IoerrDirFsync
```
```
IoerrFstat
```
```
IoerrFsync
```
```
IoerrGettemppath
```
```
IoerrLock
```
```
IoerrMmap
```
```
IoerrNomem
```
```
IoerrRdlock
```

Replicated

</>

pub type Replicated {
  Replicated(frame_no: option.Option(Int), frames_synced: Int)
}

Constructors

Replicated(frame_no: option.Option(Int), frames_synced: Int)

Statement

</>

pub type Statement

Value

</>

pub type Value

Values

begin

</>

pub fn begin(on connection: Connection) -> Result(Nil, Error)

blob

</>

pub fn blob(value: BitArray) -> Value

bool

</>

pub fn bool(value: Bool) -> Value

changes

</>

pub fn changes(connection: Connection) -> Result(Int, Error)

close

</>

pub fn close(connection: Connection) -> Result(Nil, Error)

commit

</>

pub fn commit(on connection: Connection) -> Result(Nil, Error)

decode_bool

</>

pub fn decode_bool() -> decode.Decoder(Bool)

error_code_from_int

</>

pub fn error_code_from_int(code: Int) -> ErrorCode

error_code_to_int

</>

pub fn error_code_to_int(error: ErrorCode) -> Int

exec

</>

pub fn exec(
  sql: String,
  on connection: Connection,
) -> Result(Nil, Error)

exec_batch

</>

pub fn exec_batch(
  sql: String,
  on connection: Connection,
  with batches: List(List(Value)),
) -> Result(Nil, Error)

exec_prepared

</>

pub fn exec_prepared(
  on statement: Statement,
  with params: List(Value),
) -> Result(Nil, Error)

finalize

</>

pub fn finalize(statement: Statement) -> Result(Nil, Error)

float

</>

pub fn float(value: Float) -> Value

int

</>

pub fn int(value: Int) -> Value

interrupt

</>

pub fn interrupt(connection: Connection) -> Result(Nil, Error)

last_insert_rowid

</>

pub fn last_insert_rowid(
  connection: Connection,
) -> Result(Int, Error)

null

</>

pub fn null() -> Value

nullable

</>

pub fn nullable(
  inner_type: fn(t) -> Value,
  value: option.Option(t),
) -> Value

open

</>

pub fn open(path: String) -> Result(Connection, Error)

open_remote

</>

pub fn open_remote(
  url: String,
  token: String,
) -> Result(Connection, Error)

open_replica

</>

pub fn open_replica(
  path: String,
  url: String,
  token: String,
) -> Result(Connection, Error)

open_synced_database

</>

pub fn open_synced_database(
  path: String,
  url: String,
  token: String,
) -> Result(Connection, Error)

prepare

</>

pub fn prepare(
  sql: String,
  on connection: Connection,
) -> Result(Statement, Error)

query

</>

pub fn query(
  sql: String,
  on connection: Connection,
  with arguments: List(Value),
  expecting decoder: decode.Decoder(t),
) -> Result(List(t), Error)

query_first

</>

pub fn query_first(
  sql: String,
  on connection: Connection,
  with arguments: List(Value),
  expecting decoder: decode.Decoder(t),
) -> Result(option.Option(t), Error)

query_first_named

</>

pub fn query_first_named(
  sql: String,
  on connection: Connection,
  with arguments: List(#(String, Value)),
  expecting decoder: decode.Decoder(t),
) -> Result(option.Option(t), Error)

query_named

</>

pub fn query_named(
  sql: String,
  on connection: Connection,
  with arguments: List(#(String, Value)),
  expecting decoder: decode.Decoder(t),
) -> Result(List(t), Error)

query_one

</>

pub fn query_one(
  sql: String,
  on connection: Connection,
  with arguments: List(Value),
  expecting decoder: decode.Decoder(t),
) -> Result(t, Error)

query_one_named

</>

pub fn query_one_named(
  sql: String,
  on connection: Connection,
  with arguments: List(#(String, Value)),
  expecting decoder: decode.Decoder(t),
) -> Result(t, Error)

query_prepared

</>

pub fn query_prepared(
  on statement: Statement,
  with params: List(Value),
  expecting decoder: decode.Decoder(t),
) -> Result(List(t), Error)

replication_index

</>

pub fn replication_index(
  connection: Connection,
) -> Result(option.Option(Int), Error)

rollback

</>

pub fn rollback(on connection: Connection) -> Result(Nil, Error)

sync

</>

pub fn sync(connection: Connection) -> Result(Replicated, Error)

text

</>

pub fn text(value: String) -> Value

total_changes

</>

pub fn total_changes(
  connection: Connection,
) -> Result(Int, Error)

transaction

</>

pub fn transaction(
  on connection: Connection,
  run f: fn() -> Result(a, Error),
) -> Result(a, Error)

with_connection

</>

pub fn with_connection(path: String, f: fn(Connection) -> a) -> a

with_remote_connection

</>

pub fn with_remote_connection(
  url: String,
  token: String,
  f: fn(Connection) -> a,
) -> a

with_replica_connection

</>

pub fn with_replica_connection(
  path: String,
  url: String,
  token: String,
  f: fn(Connection) -> a,
) -> a

with_statement

</>

pub fn with_statement(
  sql: String,
  on connection: Connection,
  run f: fn(Statement) -> a,
) -> a

with_synced_database

</>

pub fn with_synced_database(
  path: String,
  url: String,
  token: String,
  f: fn(Connection) -> a,
) -> a