vespertide-query 0.3.0

Converts migration actions into SQL statements with bind parameters
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
71
72
73
74

//! Shared test-only helpers for `builder::parallel` and `builder::sequential`.
//!
//! Both submodules previously carried byte-identical copies of these eight
//! helpers in their inline `mod tests` blocks. They now live here as
//! `pub(super)` items, reachable from both child modules' tests via
//! `use super::test_support::*;`.

#![cfg(test)]

use vespertide_core::{
    ColumnDef, ColumnType, ForeignKeyOrphanStrategy, MigrationAction, ReferenceAction,
    SimpleColumnType, TableConstraint, TableDef,
};

use crate::DatabaseBackend;
use crate::sql::BuiltQuery;

pub(super) fn nn_col(name: &str, ty: SimpleColumnType) -> ColumnDef {
    ColumnDef::new(name, ColumnType::Simple(ty), false)
}

pub(super) fn index(name: Option<&str>, column: &str) -> TableConstraint {
    TableConstraint::Index {
        name: name.map(Into::into),
        columns: vec![column.into()],
    }
}

pub(super) fn foreign_key() -> TableConstraint {
    TableConstraint::ForeignKey {
        name: Some("fk_u__pk".into()),
        columns: vec!["pk".into()],
        ref_table: "other".into(),
        ref_columns: vec!["id".into()],
        on_delete: Some(ReferenceAction::Cascade),
        on_update: None,
        orphan_strategy: ForeignKeyOrphanStrategy::default(),
    }
}

pub(super) fn table(name: &str, constraints: Vec<TableConstraint>) -> TableDef {
    TableDef {
        name: name.into(),
        description: None,
        columns: vec![nn_col("pk", SimpleColumnType::Integer)],
        constraints,
    }
}

pub(super) fn schema_u_with_constraints(constraints: Vec<TableConstraint>) -> Vec<TableDef> {
    vec![table("u", constraints)]
}

pub(super) fn schema_u_and_v_with_u_constraints(
    constraints: Vec<TableConstraint>,
) -> Vec<TableDef> {
    vec![table("u", constraints), table("v", vec![])]
}

pub(super) fn add_required_column(table: &str, column: &str) -> MigrationAction {
    MigrationAction::AddColumn {
        table: table.into(),
        column: Box::new(nn_col(column, SimpleColumnType::Integer)),
        fill_with: None,
    }
}

pub(super) fn sqlite_sql(queries: &[BuiltQuery]) -> String {
    queries
        .iter()
        .map(|q| q.build(DatabaseBackend::Sqlite))
        .collect::<Vec<_>>()
        .join("\n")
}