-
-
Notifications
You must be signed in to change notification settings - Fork 566
Expand file tree
/
Copy pathSqlConnection.ts
More file actions
69 lines (61 loc) · 1.69 KB
/
SqlConnection.ts
File metadata and controls
69 lines (61 loc) · 1.69 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
/**
* @since 1.0.0
*/
import * as Context from "effect/Context"
import type { Effect } from "effect/Effect"
import type { Scope } from "effect/Scope"
import type { Stream } from "effect/Stream"
import type { SqlError } from "./SqlError.js"
/**
* @category model
* @since 1.0.0
*/
export interface Connection {
readonly execute: (
sql: string,
params: ReadonlyArray<unknown>,
transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
) => Effect<ReadonlyArray<any>, SqlError>
/**
* Execute the specified SQL query and return the raw results directly from
* underlying SQL client.
*/
readonly executeRaw: (
sql: string,
params: ReadonlyArray<unknown>
) => Effect<unknown, SqlError>
readonly executeStream: (
sql: string,
params: ReadonlyArray<unknown>,
transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
) => Stream<any, SqlError>
readonly executeValues: (
sql: string,
params: ReadonlyArray<unknown>
) => Effect<ReadonlyArray<ReadonlyArray<unknown>>, SqlError>
readonly executeUnprepared: (
sql: string,
params: ReadonlyArray<unknown>,
transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
) => Effect<ReadonlyArray<any>, SqlError>
}
/**
* @since 1.0.0
*/
export namespace Connection {
/**
* @category model
* @since 1.0.0
*/
export type Acquirer = Effect<Connection, SqlError, Scope>
}
/**
* @category tag
* @since 1.0.0
*/
export const Connection = Context.GenericTag<Connection>("@services/Connection")
/**
* @category model
* @since 1.0.0
*/
export type Row = { readonly [column: string]: unknown }