sql-bridge 0.2.0

SQL bridge for sqlx-repo
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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137

use sql_bridge::{Error, MySqlDialect, PostgreSqlDialect, SQLiteDialect, parse};

#[test]
fn rename_table() {
    let query = "alter table test rename to foo";
    let mut ast = parse(query).unwrap();
    assert!(ast.len() == 1);
    let ast = ast.pop().unwrap();

    assert_eq!(
        ast.to_sql(&MySqlDialect {}).unwrap(),
        "ALTER TABLE `test` RENAME TO `foo`",
    );
    assert_eq!(
        ast.to_sql(&PostgreSqlDialect {}).unwrap(),
        "ALTER TABLE \"test\" RENAME TO \"foo\"",
    );
    assert_eq!(
        ast.to_sql(&SQLiteDialect {}).unwrap(),
        "ALTER TABLE `test` RENAME TO `foo`",
    );
}

#[test]
fn add_column() {
    let query = "alter table test add column foo int";
    let mut ast = parse(query).unwrap();
    assert!(ast.len() == 1);
    let ast = ast.pop().unwrap();

    assert_eq!(
        ast.to_sql(&MySqlDialect {}).unwrap(),
        "ALTER TABLE `test` ADD COLUMN `foo` INT"
    );
    assert_eq!(
        ast.to_sql(&PostgreSqlDialect {}).unwrap(),
        "ALTER TABLE \"test\" ADD COLUMN \"foo\" INT"
    );
    assert_eq!(
        ast.to_sql(&SQLiteDialect {}).unwrap(),
        "ALTER TABLE `test` ADD COLUMN `foo` INTEGER"
    );
}

#[test]
fn drop_column() {
    let query = "alter table test drop column foo";
    let mut ast = parse(query).unwrap();
    assert!(ast.len() == 1);
    let ast = ast.pop().unwrap();

    assert_eq!(
        ast.to_sql(&MySqlDialect {}).unwrap(),
        "ALTER TABLE `test` DROP COLUMN `foo`"
    );
    assert_eq!(
        ast.to_sql(&PostgreSqlDialect {}).unwrap(),
        "ALTER TABLE \"test\" DROP COLUMN \"foo\""
    );
    assert_eq!(
        ast.to_sql(&SQLiteDialect {}).unwrap(),
        "ALTER TABLE `test` DROP COLUMN `foo`"
    );
}

#[test]
fn rename_column() {
    let query = "alter table test rename column old_col to new_col";
    let mut ast = parse(query).unwrap();
    assert!(ast.len() == 1);
    let ast = ast.pop().unwrap();

    assert_eq!(
        ast.to_sql(&MySqlDialect {}).unwrap(),
        "ALTER TABLE `test` RENAME COLUMN `old_col` TO `new_col`"
    );
    assert_eq!(
        ast.to_sql(&PostgreSqlDialect {}).unwrap(),
        "ALTER TABLE \"test\" RENAME COLUMN \"old_col\" TO \"new_col\""
    );
    assert_eq!(
        ast.to_sql(&SQLiteDialect {}).unwrap(),
        "ALTER TABLE `test` RENAME COLUMN `old_col` TO `new_col`"
    );
}

#[test]
fn add_column_if_not_exists() {
    let query = "ALTER TABLE table_name ADD COLUMN IF NOT EXISTS col INTEGER";
    let err = parse(query).unwrap_err();
    assert!(matches!(
        err,
        Error::AlterTable {
            reason: "if not exists"
        }
    ));
    assert_eq!(err.to_string(), "unsupported alter table: if not exists");
}

#[test]
fn drop_column_if_not_exists() {
    let query = "ALTER TABLE table_name DROP COLUMN IF EXISTS column_name";
    let err = parse(query).unwrap_err();
    assert!(matches!(
        err,
        Error::AlterTable {
            reason: "if exists"
        }
    ));
    assert_eq!(err.to_string(), "unsupported alter table: if exists");
}

#[test]
fn drop_behaviour() {
    let query = "ALTER TABLE table_name DROP COLUMN column_name CASCADE";
    let err = parse(query).unwrap_err();
    assert!(matches!(
        err,
        Error::AlterTable {
            reason: "drop behaviour"
        }
    ));
    assert_eq!(err.to_string(), "unsupported alter table: drop behaviour");
}

#[test]
fn column_position() {
    let query = "ALTER TABLE users ADD COLUMN age INT AFTER name";
    let err = parse(query).unwrap_err();
    assert!(matches!(
        err,
        Error::AlterTable {
            reason: "column position"
        }
    ));
    assert_eq!(err.to_string(), "unsupported alter table: column position");
}