pgorm 0.1.2

A lightweight Postgres-only ORM for Rust
Documentation 
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

//! Database schema setup helpers for examples

#![allow(dead_code)]

use pgorm::{GenericClient, OrmError, query};

/// Setup schema for users table (used in changeset_input example)
pub async fn setup_users_schema(conn: &impl GenericClient) -> Result<(), OrmError> {
    query("DROP TABLE IF EXISTS users CASCADE")
        .execute(conn)
        .await?;

    query(
        "CREATE TABLE users (
            id BIGSERIAL PRIMARY KEY,
            name TEXT NOT NULL,
            email TEXT NOT NULL UNIQUE,
            age INT,
            external_id UUID NOT NULL,
            homepage TEXT,
            created_at TIMESTAMPTZ NOT NULL DEFAULT now()
        )",
    )
    .execute(conn)
    .await?;

    Ok(())
}

/// Setup schema for users and posts tables (used in eager_loading example)
pub async fn setup_users_posts_schema(conn: &impl GenericClient) -> Result<(), OrmError> {
    query("DROP TABLE IF EXISTS posts CASCADE")
        .execute(conn)
        .await?;
    query("DROP TABLE IF EXISTS users CASCADE")
        .execute(conn)
        .await?;

    query(
        "CREATE TABLE users (
            id BIGSERIAL PRIMARY KEY,
            name TEXT NOT NULL
        )",
    )
    .execute(conn)
    .await?;

    query(
        "CREATE TABLE posts (
            id BIGSERIAL PRIMARY KEY,
            user_id BIGINT NOT NULL REFERENCES users(id),
            editor_id BIGINT REFERENCES users(id),
            title TEXT NOT NULL
        )",
    )
    .execute(conn)
    .await?;

    Ok(())
}

/// Setup schema for products table (used in update_model example)
pub async fn setup_products_schema(conn: &impl GenericClient) -> Result<(), OrmError> {
    query("DROP TABLE IF EXISTS products CASCADE")
        .execute(conn)
        .await?;

    query(
        "CREATE TABLE products (
            id BIGSERIAL PRIMARY KEY,
            name TEXT NOT NULL,
            description TEXT,
            price_cents BIGINT NOT NULL,
            in_stock BOOLEAN NOT NULL DEFAULT true
        )",
    )
    .execute(conn)
    .await?;

    Ok(())
}

/// Setup schema for products and categories tables (used in pg_client example)
pub async fn setup_products_categories_schema(conn: &impl GenericClient) -> Result<(), OrmError> {
    query("DROP TABLE IF EXISTS products CASCADE")
        .execute(conn)
        .await?;
    query("DROP TABLE IF EXISTS categories CASCADE")
        .execute(conn)
        .await?;

    query(
        "CREATE TABLE categories (
            id BIGSERIAL PRIMARY KEY,
            name TEXT NOT NULL
        )",
    )
    .execute(conn)
    .await?;

    query(
        "CREATE TABLE products (
            id BIGSERIAL PRIMARY KEY,
            name TEXT NOT NULL,
            price_cents BIGINT NOT NULL,
            in_stock BOOLEAN NOT NULL DEFAULT true
        )",
    )
    .execute(conn)
    .await?;

    Ok(())
}