migrant_lib 0.34.0 

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
75
76
77
78
79
80
81
82
83
84
85
86
87

/*!
The functionality of the Migrant CLI tool can be used as a library so you can embed general
database & migration management in your binary and don't need to use a secondary tool
in production environments.

Select functionality can be copied from https://github.com/jaemk/migrant/blob/master/src/main.rs

This example shows using `migrant_lib` in a CLI compatible manner in environments where
the database configuration file (`Migrant.toml`) and migration files are available to run-time.
For CLI compatibility and embedded capabilities, see the
[embedded_cli_compatible](https://github.com/jaemk/migrant_lib/blob/master/examples/embedded_cli_compatible.rs)
example.

Run with: `cargo run --example migrant_cli_compatible [--features d-sqlite]`
Note: Running without features will use the corresponding database shell commands.
      Use the respective `--features` to use the actual database driver libraries (`d-sqlite`, `d-postgres`, `d-mysql`)
*/
extern crate migrant_lib;

use migrant_lib::config::SqliteSettingsBuilder;
use migrant_lib::Config;
use std::env;
// use migrant_lib::config::PostgresSettingsBuilder;
// use migrant_lib::config::MySqlSettingsBuilder;

fn run() -> Result<(), migrant_lib::Error> {
    let dir = env::current_dir().unwrap();
    let config = match migrant_lib::search_for_settings_file(&dir) {
        None => {
            Config::init_in(&dir)
                .with_sqlite_options(
                    SqliteSettingsBuilder::empty()
                        .database_path("db/db.db")?
                        .migration_location("migrations/managed")?,
                )
                // .with_postgres_options(
                //     PostgresSettingsBuilder::empty()
                //         .database_name("testing")
                //         .database_user("testing")
                //         .database_password("testing")
                //         .database_host("localhost")
                //         .database_port(5432)
                //         .database_params(&[("port", "5432"), ("sslmode", "disable")])
                //         .migration_location("migrations/managed")?)
                // .with_mysql_options(
                //     MySqlSettingsBuilder::empty()
                //         .database_name("testing")
                //         .database_user("testing")
                //         .database_password("pass")
                //         .database_host("localhost")
                //         .database_port(3306)
                //         .database_params(&[("prefer_socket", "true")])
                //         .migration_location("migrations/managed")?)
                .initialize()?;
            println!(
                "\nSettings file and migrations table initialized. \
                 Please run again to apply migrations."
            );
            return Ok(());
        }
        Some(p) => Config::from_settings_file(&p)?,
    };
    let config = config.reload()?;

    println!("Applying all migrations...");
    migrant_lib::Migrator::with_config(&config)
        .direction(migrant_lib::Direction::Up)
        .all(true)
        .apply()?;
    let config = config.reload()?;
    migrant_lib::list(&config)?;

    println!("Unapplying all migrations...");
    migrant_lib::Migrator::with_config(&config)
        .direction(migrant_lib::Direction::Down)
        .all(true)
        .apply()?;
    let config = config.reload()?;
    migrant_lib::list(&config)?;
    Ok(())
}

pub fn main() {
    if let Err(e) = run() {
        println!("[ERROR] {}", e);
    }
}