mool 0.2.0

A source-first Rust database toolkit for typed SQL queries, migrations, and model metadata
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

#![cfg(feature = "migrations")]

mod common;

use common::{Post, User};
use mool as db;

fn root_schema() -> db::Schema {
    db::schema(db::Dialect::Postgres)
        .model::<User>()
        .build()
        .expect("valid root test schema")
}

fn crate_schema() -> db::Schema {
    db::schema(db::Dialect::Postgres)
        .model::<Post>()
        .build()
        .expect("valid crate test schema")
}

/// Verifies root and crate schema sources build the expected namespace-specific schemas.
#[test]
fn migration_registry_builds_schema_for_namespaces() {
    let mut registry = db::MigrationRegistry::new();
    registry
        .register_schema(db::root_schema(root_schema))
        .unwrap();
    registry
        .register_schema(db::crate_schema("blog", crate_schema))
        .unwrap();

    assert!(
        registry
            .schema_for(None)
            .unwrap()
            .tables
            .contains_key("users")
    );
    assert!(
        registry
            .schema_for(Some("blog"))
            .unwrap()
            .tables
            .contains_key("posts")
    );
}

/// Verifies registry merge keeps root and crate schema sources from both registries.
#[test]
fn migration_registry_merges_schema_sources() {
    let mut left = db::MigrationRegistry::new();
    left.register_schema(db::root_schema(root_schema)).unwrap();
    let mut right = db::MigrationRegistry::new();
    right
        .register_schema(db::crate_schema("blog", crate_schema))
        .unwrap();

    left.merge(right).unwrap();

    assert!(left.schema_for(None).unwrap().tables.contains_key("users"));
    assert!(
        left.schema_for(Some("blog"))
            .unwrap()
            .tables
            .contains_key("posts")
    );
}

/// Verifies invalid namespaces are rejected before they reach migration routing.
#[test]
fn migration_registry_rejects_invalid_schema_namespace() {
    let mut registry = db::MigrationRegistry::new();
    let err = registry
        .register_schema(db::crate_schema("bad/name", crate_schema))
        .unwrap_err();

    assert_eq!(
        err.to_string(),
        "invalid migration namespace 'bad/name': namespace cannot contain '/'"
    );
}