pgevolve-core 0.3.6

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
61
62
63
64
65
66
67
68
69

//! AST → IR builders.
//!
//! Each submodule consumes one classified [`crate::parse::Statement`] variant
//! and produces zero-or-more IR objects, optionally appended to a partial
//! [`crate::ir::catalog::Catalog`] via [`Builder`].

pub mod alter_table_attach_partition;
pub mod alter_table_stmt;
pub mod comment_stmt;
pub mod create_composite_type_stmt;
pub mod create_domain_stmt;
pub mod create_enum_stmt;
pub mod create_extension_stmt;
pub mod create_function_stmt;
pub mod create_materialized_view_stmt;
pub mod create_schema_stmt;
pub mod create_seq_stmt;
pub mod create_stmt;
pub mod create_trigger_stmt;
pub mod create_view_stmt;
pub mod default_privileges;
pub mod desugar_serial;
pub mod grants;
pub mod index_stmt;
pub mod owner_stmt;
pub mod plpgsql;
pub mod policy_stmt;
pub mod publication_stmt;
pub mod reloptions;
pub mod shared;
pub mod subscription_stmt;

use std::collections::HashMap;

use crate::identifier::QualifiedName;
use crate::ir::catalog::Catalog;
use crate::parse::error::SourceLocation;

/// Mutable accumulator passed through builders during a single
/// `parse_directory` pass.
#[derive(Debug, Default)]
pub struct Builder {
    /// The catalog being assembled.
    pub catalog: Catalog,
    /// First-seen source location for every object qname, for duplicate diagnostics.
    pub locations: HashMap<String, SourceLocation>,
}

impl Builder {
    /// Construct an empty builder.
    pub fn new() -> Self {
        Self::default()
    }

    /// Record the source location at which `qname` was first defined.
    /// Returns the prior location if the qname is already known.
    pub fn record_location(
        &mut self,
        qname: &QualifiedName,
        location: SourceLocation,
    ) -> Option<SourceLocation> {
        let key = qname.to_string();
        if let Some(prior) = self.locations.get(&key) {
            return Some(prior.clone());
        }
        self.locations.insert(key, location);
        None
    }
}