ormer 0.2.9

A minimalist ORM framework that supports SQLite, PostgreSQL, MySQL, and SqlServer
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

#![cfg(any(feature = "sqlite", feature = "postgresql"))]

use ormer::Model;

#[derive(Debug, Clone, ormer::Model)]
#[table = "hypertable_route_events_1"]
struct HypertableRouteEvent {
    #[primary]
    id: i64,
    payload: String,
    #[hypertable]
    #[ormer_ignore]
    tenant: String,
}

fn route_event(tenant: &str) -> HypertableRouteEvent {
    HypertableRouteEvent {
        id: 1,
        payload: "created".to_string(),
        tenant: tenant.to_string(),
    }
}

#[test]
fn string_hypertable_route_value_is_extracted_from_ignored_field() {
    assert_eq!(HypertableRouteEvent::COLUMNS, &["id", "payload"]);

    let route = route_event("acme").table_route().unwrap();
    assert_eq!(route.get("tenant"), Some("acme"));
}

#[cfg(feature = "sqlite")]
#[test]
fn sqlite_insert_ignores_string_hypertable_route() {
    let event = route_event("acme");
    let statement =
        ormer::abstract_layer::common::common_helpers::build_insert_statement_with_conflict::<
            HypertableRouteEvent,
        >(ormer::DbType::Sqlite, &[&event], None)
        .unwrap();

    assert_eq!(
        statement.0,
        "INSERT INTO hypertable_route_events_1 (id, payload) VALUES (?, ?)"
    );
}

#[cfg(feature = "sqlite")]
#[test]
fn sqlite_select_route_table_keeps_base_table() {
    let (sql, params) = HypertableRouteEvent::query()
        .route_table("tenant", "acme")
        .to_sql_with_params(ormer::DbType::Sqlite);

    assert_eq!(sql, "SELECT id, payload FROM hypertable_route_events_1");
    assert!(params.is_empty());
}

#[cfg(feature = "postgresql")]
#[test]
fn postgresql_insert_routes_string_hypertable_table() {
    let event = route_event("acme");
    let statement =
        ormer::abstract_layer::common::common_helpers::build_insert_statement_with_conflict::<
            HypertableRouteEvent,
        >(ormer::DbType::PostgreSQL, &[&event], None)
        .unwrap();

    assert_eq!(
        statement.0,
        "INSERT INTO hypertable_route_events_1_acme (id, payload) VALUES ($1, $2)"
    );
}

#[cfg(feature = "postgresql")]
#[test]
fn postgresql_select_routes_string_hypertable_table() {
    let (sql, params) = HypertableRouteEvent::query()
        .route_table("tenant", "acme")
        .to_sql_with_params(ormer::DbType::PostgreSQL);

    assert_eq!(
        sql,
        "SELECT id, payload FROM hypertable_route_events_1_acme"
    );
    assert!(params.is_empty());
}