pgevolve-core 0.4.2

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
70

//! Dispatchers for `Change::CreateSchema`, `Change::DropSchema`,
//! `Change::AlterSchema`.

use crate::identifier::Identifier;
use crate::ir::schema::Schema;
use crate::plan::raw_step::{RawStep, StepKind, TransactionConstraint};
use crate::plan::rewrite::sql;

use super::super::schema_target;

pub fn create(
    s: Schema,
    destructive: bool,
    destructive_reason: Option<String>,
    out: &mut Vec<RawStep>,
) {
    out.push(RawStep {
        step_no: 0,
        kind: StepKind::CreateSchema,
        destructive,
        destructive_reason,
        intent_id: None,
        targets: vec![schema_target(&s.name)],
        sql: sql::create_schema(&s),
        transactional: TransactionConstraint::InTransaction,
    });
    if let Some(c) = &s.comment {
        out.push(RawStep {
            step_no: 0,
            kind: StepKind::AlterSchemaComment,
            destructive: false,
            destructive_reason: None,
            intent_id: None,
            targets: vec![schema_target(&s.name)],
            sql: sql::comment_on_schema(&s.name, Some(c)),
            transactional: TransactionConstraint::InTransaction,
        });
    }
}

pub fn drop_(
    name: Identifier,
    destructive: bool,
    destructive_reason: Option<String>,
    out: &mut Vec<RawStep>,
) {
    out.push(RawStep {
        step_no: 0,
        kind: StepKind::DropSchema,
        destructive,
        destructive_reason,
        intent_id: None,
        targets: vec![schema_target(&name)],
        sql: sql::drop_schema(&name),
        transactional: TransactionConstraint::InTransaction,
    });
}

pub fn alter(name: Identifier, comment: Option<String>, out: &mut Vec<RawStep>) {
    out.push(RawStep {
        step_no: 0,
        kind: StepKind::AlterSchemaComment,
        destructive: false,
        destructive_reason: None,
        intent_id: None,
        targets: vec![schema_target(&name)],
        sql: sql::comment_on_schema(&name, comment.as_deref()),
        transactional: TransactionConstraint::InTransaction,
    });
}