database-migration 0.2.0

Database agnostic functions and data structures to build database migration tools.
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 crate::config::MIGRATION_KEY_FORMAT_STR;
use crate::migration::{ApplicableMigration, Execution, Migration, ScriptContent};
use chrono::{DateTime, NaiveDateTime, Utc};
use indexmap::IndexMap;

pub fn key(value: &str) -> NaiveDateTime {
    NaiveDateTime::parse_from_str(value, MIGRATION_KEY_FORMAT_STR).expect("invalid migration key")
}

pub fn datetime(value: &str) -> DateTime<Utc> {
    DateTime::parse_from_rfc3339(value)
        .expect("invalid RFC 3339 datetime")
        .to_utc()
}

pub fn defined_migrations(
    values: impl IntoIterator<Item = Migration>,
) -> IndexMap<NaiveDateTime, Migration> {
    values
        .into_iter()
        .map(|m| (m.key, m))
        .collect::<IndexMap<_, _>>()
}

pub fn script_contents(
    values: impl IntoIterator<Item = ScriptContent>,
) -> IndexMap<NaiveDateTime, ScriptContent> {
    values
        .into_iter()
        .map(|m| (m.key, m))
        .collect::<IndexMap<_, _>>()
}

pub fn executed_migrations(
    values: impl IntoIterator<Item = Execution>,
) -> IndexMap<NaiveDateTime, Execution> {
    values
        .into_iter()
        .map(|m| (m.key, m))
        .collect::<IndexMap<_, _>>()
}

pub fn applicable_migrations(
    values: impl IntoIterator<Item = ApplicableMigration>,
) -> IndexMap<NaiveDateTime, ApplicableMigration> {
    values
        .into_iter()
        .map(|m| (m.key, m))
        .collect::<IndexMap<_, _>>()
}