pgevolve 0.4.6

Postgres declarative schema management CLI — diff source SQL against a live database and generate reviewable migrations.
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

//! `pgevolve apply` — apply a plan directory to a live database.
//!
//! Exit codes follow spec §13:
//! - `0` success
//! - `2` pre-flight mismatch (target identity, drift, unapproved intents)
//! - `3` apply error (lock held, step failed)
//! - other errors bubble up as `1`

use anyhow::Result;

use pgevolve_core::catalog::CatalogFilter;

use crate::cli::ApplyArgs;
use crate::config::PgevolveConfig;
use crate::connection::{connect, resolve_db};
use crate::executor::{ApplyError, ApplyOutcome, ApplyOverrides, apply};

/// Run `pgevolve apply`.
pub async fn run(args: ApplyArgs, cfg: &PgevolveConfig) -> Result<i32> {
    let opts = resolve_db(cfg, &args.db, args.url.as_deref())?;
    let mut client = connect(&opts).await?;
    let filter = CatalogFilter::new(opts.managed_schemas.clone(), opts.ignore_objects.clone())?;
    let overrides = ApplyOverrides {
        allow_different_target: args.allow_different_target,
        allow_drift: args.allow_drift,
        allow_unwaived_lint: false,
        allow_unapproved_intents: false,
        actor: None,
        abort_after_step: None,
    };
    let result = apply(&args.plan_dir, &mut client, &filter, overrides).await;
    match result {
        Ok(ApplyOutcome::Succeeded { apply_id }) => {
            println!("applied (apply_id={apply_id})");
            Ok(0)
        }
        Err(e) => {
            eprintln!("{e}");
            Ok(match e {
                ApplyError::TargetIdentityMismatch { .. }
                | ApplyError::DriftDetected(_)
                | ApplyError::UnapprovedIntents { .. }
                | ApplyError::LintWaiverMissing { .. } => 2,
                ApplyError::LockHeld | ApplyError::StepFailed { .. } => 3,
                _ => return Err(e.into()),
            })
        }
    }
}