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
import { assertEquals, assertRejects, withTestDatabase } from "./prelude.ts";import { insert } from "../database/typed-statement-builder.ts";import { transaction, transactionReturning } from "../transaction.ts";
Deno.test(  "transaction - insert",  withTestDatabase(async (sql) => {    const builder = insert("user")({ email: "user@domain.tld" });
    await transaction(builder);
    const [{ count }] =      await sql`SELECT count(*) FROM "user" WHERE email = 'user@domain.tld'`;
    assertEquals(count, "1");
    await sql.end({ timeout: 5 });  }),);
Deno.test(  "transaction - insert returning",  withTestDatabase(async (sql) => {    const builder = insert("user")({ email: "user@domain.tld" }).returning([      "email",    ]);
    const [{ email }] = await transaction(builder);
    assertEquals(email, "user@domain.tld");
    await sql.end({ timeout: 5 });  }),);
Deno.test(  "transactionReturning - insert",  withTestDatabase(async () => {    await assertRejects(() =>      transactionReturning(insert("user")({ email: "user@domain.tld" }))    );  }),);
Deno.test(  "transactionReturning - insert returning",  withTestDatabase(async (sql) => {    const builder = insert("user")({ email: "user@domain.tld" }).returning([      "email",    ]);
    const [{ email }] = await transactionReturning(builder);
    assertEquals(email, "user@domain.tld");
    await sql.end({ timeout: 5 });  }),);