safe-migrate 0.8.0

Check PostgreSQL migrations against a synchronized database baseline
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

use super::Resolver;
use crate::_internal::analysis::facts::{AlterSchemaActionFact, RoleFact};
use crate::_internal::analysis::mutations::{
    AlterSchemaMutation, CreateSchemaMutation, DropSchemaMutation, Mutation,
};
use crate::_internal::ast::identifiers::QualifiedName;

impl Resolver {
    pub(super) fn resolve_create_schema(
        name: &QualifiedName,
        if_not_exists: bool,
        authorization: &Option<RoleFact>,
    ) -> Mutation {
        Mutation::CreateSchema(CreateSchemaMutation {
            name: name.name.resolve(),
            if_not_exists,
            authorization: authorization.clone(),
        })
    }

    pub(super) fn resolve_alter_schema(
        name: &QualifiedName,
        action: &AlterSchemaActionFact,
    ) -> Mutation {
        let name = name.name.resolve();
        let action = match action {
            AlterSchemaActionFact::RenameTo { new_name } => AlterSchemaMutation::Rename {
                old_name: name,
                new_name: new_name.resolve(),
            },
            AlterSchemaActionFact::OwnerTo { new_owner } => AlterSchemaMutation::OwnerTo {
                name,
                new_owner: new_owner.clone(),
            },
        };
        Mutation::AlterSchema(action)
    }

    pub(super) fn resolve_drop_schema(
        names: &[QualifiedName],
        if_exists: bool,
        cascade: bool,
    ) -> Mutation {
        Mutation::DropSchema(DropSchemaMutation {
            names: names.iter().map(|name| name.name.resolve()).collect(),
            if_exists,
            cascade,
        })
    }
}