pgevolve-core 0.4.0

Postgres declarative schema management — core library (parser, IR, diff, planner) powering the pgevolve CLI.
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

//! `CREATE SCHEMA` → [`crate::ir::schema::Schema`].

use pg_query::protobuf::CreateSchemaStmt;

use crate::ir::schema::Schema;
use crate::parse::builder::shared;
use crate::parse::error::{ParseError, SourceLocation};

/// Build a [`Schema`] from a `CREATE SCHEMA` AST.
pub fn build_schema(
    stmt: &CreateSchemaStmt,
    location: &SourceLocation,
) -> Result<Schema, ParseError> {
    if stmt.schemaname.is_empty() {
        return Err(ParseError::Structural {
            location: location.clone(),
            message: "CREATE SCHEMA requires a schema name".into(),
        });
    }
    Ok(Schema::new(shared::ident(&stmt.schemaname, location)?))
}

#[cfg(test)]
mod tests {
    use super::*;
    use pg_query::NodeEnum;
    use std::path::PathBuf;

    fn loc() -> SourceLocation {
        SourceLocation::new(PathBuf::from("test.sql"), 1, 1)
    }

    fn build(sql: &str) -> Schema {
        let parsed = pg_query::parse(sql).expect("parses");
        let stmt = parsed
            .protobuf
            .stmts
            .into_iter()
            .next()
            .and_then(|raw| raw.stmt)
            .and_then(|n| n.node)
            .expect("stmt");
        let NodeEnum::CreateSchemaStmt(s) = stmt else {
            panic!()
        };
        build_schema(&s, &loc()).expect("builds")
    }

    #[test]
    fn bare_schema() {
        let s = build("CREATE SCHEMA app;");
        assert_eq!(s.name.as_str(), "app");
    }

    #[test]
    fn case_folded() {
        let s = build("CREATE SCHEMA Billing;");
        assert_eq!(s.name.as_str(), "billing");
    }
}