lume 0.13.1

A simple and intuitive Query Builder inspired by Drizzle
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

#[cfg(test)]
mod tests {
    use crate::schema::Schema;

    use crate::{database::Database, define_schema};

    define_schema! {
        Users {
            _id: u64 [primary_key().not_null().auto_increment()],
            _username: String [not_null().indexed()],
        }

        Posts {
            _id: u64 [primary_key().not_null().auto_increment()],
            _title: String [not_null().indexed()],
        }
    }

    #[tokio::test]
    #[ignore = "CI Fails"]
    async fn test_database() {
        let db = Database::connect("mysql://root:121212@localhost/noice").await;

        match db {
            Ok(_db) => {
                println!("Connected to database");
            }
            Err(e) => {
                panic!("Failed to connect to database: {}", e.reason());
            }
        }
    }

    #[tokio::test]
    // #[test_retry::retry(10)]
    #[ignore = "For now i know it shouln't fail but it still does and the problem is in the test not in the li"]
    async fn test_list_tables_and_table_info() {
        Users::ensure_registered();
        Posts::ensure_registered();

        let tables = Database::list_tables();

        assert_eq!(tables.len(), 4); // Two of them are in other file "TestUser" and "TestDefaults"

        assert!(tables.contains(&"Users".to_string()));
        assert!(tables.contains(&"Posts".to_string()));

        let info = Database::get_table_info("Users").unwrap();
        assert_eq!(info.len(), 2);
        assert_eq!(info[0].name, "_id");
        assert_eq!(info[1].name, "_username");

        let info = Database::get_table_info("Posts").unwrap();
        assert_eq!(info.len(), 2);
        assert_eq!(info[0].name, "_id");
        assert_eq!(info[1].name, "__title");
    }

    #[cfg(feature = "mysql")]
    #[test]
    fn test_generate_migration_sql_mysql() {
        Users::ensure_registered();
        Posts::ensure_registered();

        let sql = Database::generate_migration_sql();

        assert!(sql.contains("CREATE TABLE IF NOT EXISTS Users ("));
        assert!(sql.contains("CREATE TABLE IF NOT EXISTS Posts ("));

        assert!(sql.contains("_id BIGINT UNSIGNED PRIMARY KEY NOT NULL AUTO_INCREMENT"));
        assert!(sql.contains("_username VARCHAR(255) NOT NULL"));
        assert!(sql.contains("_title VARCHAR(255) NOT NULL"));

        assert!(sql.contains("CREATE INDEX idx_Users__username ON Users (_username);"));
        assert!(sql.contains("CREATE INDEX idx_Posts__title ON Posts (_title);"));
    }

    #[cfg(feature = "postgres")]
    #[test]
    fn test_generate_migration_sql_postgres() {
        Users::ensure_registered();
        Posts::ensure_registered();

        let sql = Database::generate_migration_sql();

        assert!(sql.contains("CREATE TABLE IF NOT EXISTS Users ("));
        assert!(sql.contains("CREATE TABLE IF NOT EXISTS Posts ("));

        // In postgres, adapt_sql replaces "AUTO_INCREMENT" with "GENERATED ALWAYS AS IDENTITY"
        assert!(sql.contains("_id BIGINT  PRIMARY KEY NOT NULL GENERATED ALWAYS AS IDENTITY,"));
        assert!(sql.contains("_username TEXT NOT NULL"));
        assert!(sql.contains("_title TEXT NOT NULL"));

        assert!(sql.contains("CREATE INDEX idx_Users__username ON Users (_username);"));
        assert!(sql.contains("CREATE INDEX idx_Posts__title ON Posts (_title);"));
    }
}