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
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
88
89
90
91
92
93
94
95
96

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

#[derive(Clone)]
struct R {
    s: String,
    n: i32,
}

// custom implementation
impl SQLMapper for R {
    type ValueType = MySQLValue;

    fn map_from_sql(values: std::collections::HashMap<String, Self::ValueType>) -> Self {
        R {
            s: <Self::ValueType as SQLValue<String>>::deserialize(values["s"].clone()),
            n: <Self::ValueType as SQLValue<i32>>::deserialize(values["n"].clone()),
        }
    }
}

impl SQLTable for R {
    fn table_name(_: std::marker::PhantomData<Self>) -> String {
        "r_table".to_string()
    }

    fn schema_of(_: std::marker::PhantomData<Self>) -> Vec<(String, String, FieldAttribute)> {
        vec![
            (
                "s".to_string(),
                "varchar(50)".to_string(),
                Default::default(),
            ),
            ("n".to_string(), "int".to_string(), Default::default()),
        ]
    }

    fn primary_key_columns(_: std::marker::PhantomData<Self>) -> Vec<String> {
        vec!["s".to_string(), "n".to_string()]
    }

    fn map_to_sql(self) -> Vec<(String, Self::ValueType)> {
        let mut result = Vec::new();
        result.push((
            "s".to_string(),
            <Self::ValueType as SQLValue<String>>::serialize(self.s),
        ));
        result.push((
            "n".to_string(),
            <Self::ValueType as SQLValue<i32>>::serialize(self.n),
        ));

        result
    }
}

#[tokio::test]
async fn migrate_save_and_select() -> Result<(), mysql_async::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);

    conn.create_table::<R>().await.unwrap();

    // This is not working for update (#7)
    conn.save(R {
        s: "foo".to_string(),
        n: 100,
    })
    .await
    .unwrap();

    // check thread safety
    tokio::spawn(conn_load::<R>(conn)).await.unwrap();

    Ok(())
}

async fn conn_load<R: debil::SQLTable<ValueType = debil_mysql::MySQLValue> + Sync + Send>(
    mut conn: debil_mysql::DebilConn,
) {
    conn.load::<R>(QueryBuilder::new()).await.unwrap();
    conn.first::<R>(QueryBuilder::new()).await.unwrap();
}