qw 0.3.0

QW
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
114
115
116
117

use qw::{FieldDef, generate_add_column_sql, generate_migration_sql, write_migration};
use sercli::Migrations;

#[test]
fn generates_sql_with_default_pk() {
    let sql = generate_migration_sql(
        "Post",
        true,
        &[
            FieldDef {
                name:     "title".into(),
                sql_type: "varchar".into(),
                not_null: true,
            },
            FieldDef {
                name:     "views".into(),
                sql_type: "integer".into(),
                not_null: false,
            },
        ],
    );

    assert_eq!(
        sql,
        r#"CREATE TABLE "posts"
(
    "id" bigint NOT NULL PRIMARY KEY,
    "title" varchar NOT NULL,
    "views" integer
);
"#
    );
}

#[test]
fn generates_sql_without_default_pk() {
    let sql = generate_migration_sql(
        "UserStat",
        false,
        &[
            FieldDef {
                name:     "user_id".into(),
                sql_type: "bigint".into(),
                not_null: true,
            },
            FieldDef {
                name:     "score".into(),
                sql_type: "integer".into(),
                not_null: true,
            },
        ],
    );

    assert_eq!(
        sql,
        r#"CREATE TABLE "user_stats"
(
    "user_id" bigint NOT NULL,
    "score" integer NOT NULL
);
"#
    );
}

#[test]
fn generates_add_column_sql() {
    let sql = generate_add_column_sql(
        "posts",
        &FieldDef {
            name:     "body".into(),
            sql_type: "varchar".into(),
            not_null: true,
        },
    );
    assert_eq!(
        sql,
        r#"ALTER TABLE "posts" ADD COLUMN "body" varchar NOT NULL;
"#
    );

    let sql = generate_add_column_sql(
        "posts",
        &FieldDef {
            name:     "views".into(),
            sql_type: "integer".into(),
            not_null: false,
        },
    );
    assert_eq!(
        sql,
        r#"ALTER TABLE "posts" ADD COLUMN "views" integer;
"#
    );
}

#[test]
fn written_migration_is_parseable() {
    let dir = tempfile::tempdir().unwrap();
    let path = dir.path().to_str().unwrap();

    let sql = generate_migration_sql(
        "Article",
        true,
        &[FieldDef {
            name:     "title".into(),
            sql_type: "varchar".into(),
            not_null: true,
        }],
    );

    write_migration(path, "add_articles", &sql).unwrap();

    let migrations = Migrations::get(path).unwrap();
    let entity = migrations.entities.get("Article").expect("Article not found");
    assert_eq!(entity.table_name, "articles");
    assert_eq!(entity.fields.len(), 2); // id + title
}