postg 0.1.7

Embedded PostgreSQL manager for Rust
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
75
76
77
78
79
80
81
82
83
84

use assert_cmd::Command;
use predicates::prelude::*;
use std::fs;

#[test]
fn test_cli_query_and_dump_sql() {
    let tmp = tempfile::TempDir::new().unwrap();
    let data_dir = tmp.path().to_str().unwrap();

    // 1. Start and create a table via query
    Command::cargo_bin("postg")
        .unwrap()
        .args(["--data-dir", data_dir, "query", "CREATE TABLE my_cli_test (id INT)"])
        .assert()
        .success();

    // 2. Insert data
    Command::cargo_bin("postg")
        .unwrap()
        .args(["--data-dir", data_dir, "query", "INSERT INTO my_cli_test VALUES (99)"])
        .assert()
        .success();

    // 3. Dump to SQL
    let dump_file = tmp.path().join("out.sql");
    Command::cargo_bin("postg")
        .unwrap()
        .args(["--data-dir", data_dir, "dump", "--file", dump_file.to_str().unwrap()])
        .assert()
        .success();

    let sql = fs::read_to_string(&dump_file).unwrap();
    assert!(sql.contains("CREATE TABLE public.my_cli_test"));

    // 4. Restore SQL (to the same DB)
    Command::cargo_bin("postg")
        .unwrap()
        .args(["--data-dir", data_dir, "restore", dump_file.to_str().unwrap()])
        .assert()
        .success();
}

#[test]
fn test_cli_sync_commands() {
    let tmp = tempfile::TempDir::new().unwrap();
    let data_dir = tmp.path().to_str().unwrap();

    // 1. Sync init
    Command::cargo_bin("postg")
        .unwrap()
        .args([
            "--engine", "postgresql-spock",
            "--data-dir", data_dir,
            "sync", "init",
            "--node-name", "test_node",
            "--dsn", "host=127.0.0.1 port=5432 user=postgres dbname=postgres"
        ])
        .assert()
        .success();

    // 2. Sync publish
    Command::cargo_bin("postg")
        .unwrap()
        .args([
            "--engine", "postgresql-spock",
            "--data-dir", data_dir,
            "sync", "publish",
            "--schema", "public"
        ])
        .assert()
        .success();

    // 3. Sync status
    Command::cargo_bin("postg")
        .unwrap()
        .args([
            "--engine", "postgresql-spock",
            "--data-dir", data_dir,
            "sync", "status"
        ])
        .assert()
        .success()
        .stdout(predicate::str::contains("Sync Status"));
}