debil-mysql 0.5.2

MySQL implementation for debil
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

use debil::*;
use debil_mysql::*;
use mysql_async::OptsBuilder;

#[derive(Table)]
#[sql(
    table_name = "migration_test",
    sql_type = "debil_mysql::MySQLValue",
    primary_key = "pk"
)]
struct Before {
    n: i32,
    #[sql(size = 10)]
    pk: String,
    still_remaining: i32,
}

#[derive(Table)]
#[sql(
    table_name = "migration_test",
    sql_type = "debil_mysql::MySQLValue",
    primary_key = "pk"
)]
struct After {
    n: i64,
    #[sql(size = 100)]
    extra: String,
    #[sql(size = 11)]
    pk: String,
}

#[tokio::test]
async fn it_should_migrate() -> Result<(), Error> {
    let raw_conn = mysql_async::Conn::new(
        OptsBuilder::default()
            .ip_or_hostname("127.0.0.1")
            .user(Some("root"))
            .pass(Some("password"))
            .db_name(Some("db"))
            .prefer_socket(Some(false))
            .pool_opts(Some(mysql_async::PoolOpts::default().with_constraints(
                mysql_async::PoolConstraints::new(1, 1).unwrap(),
            )))
            .clone(),
    )
    .await?;
    let mut conn = DebilConn::from_conn(raw_conn);

    // setup
    conn.drop_table::<After>().await?;

    // migration creates table
    conn.migrate::<Before>().await?;

    // migrate
    conn.migrate::<After>().await?;

    Ok(())
}