bootrust 0.1.0

An elegant macroless data access layer abstraction, simple and easy-use object-relational mapping powered by the Serde serialization framework. 一个优雅的无宏的数据访问层抽象, 由serde序列化框架提供支持的简单易用的对象关系映射
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

#[cfg(all(
    not(feature = "full"),
    any(
        feature = "sqlite_async",
        feature = "mysql_async",
        feature = "postgresql_async"
    )
))]
use bootrust::{
    asyncdatabase::{auto_config, RelationalDatabase},
    entity::Entity,
};
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug, Clone)]
struct User {
    id: i64,
    name: String,
    // 将 DateTime<Utc> 序列化为 Unix 秒数（i64）
    #[serde(with = "chrono::serde::ts_seconds")]
    created_at: DateTime<Utc>,
}

#[cfg(all(
    not(feature = "full"),
    any(
        feature = "sqlite_async",
        feature = "mysql_async",
        feature = "postgresql_async"
    )
))]
impl Entity for User {
    fn table() -> String {
        "example".to_string()
    }
    fn primary_key() -> String {
        "id".to_string()
    }
}

#[tokio::main]
async fn main() {
    #[cfg(all(
        not(feature = "full"),
        any(
            feature = "sqlite_async",
            feature = "mysql_async",
            feature = "postgresql_async"
        )
    ))]
    simple_example().await.unwrap();
}

#[cfg(all(
    not(feature = "full"),
    any(
        feature = "sqlite_async",
        feature = "mysql_async",
        feature = "postgresql_async"
    )
))]
async fn simple_example() -> Result<(), Box<dyn std::error::Error>> {
    // 根据 URL 自动选择数据库驱动
    let db = auto_config().await;

    // create table
    // suggest write sql in init.sql, hard code  here is just example
    db.execute(
        "
    drop table if exists  example
",
        vec![],
    )
    .await?;

    db.execute(
        "
    create table  example(
id BIGINT  PRIMARY KEY,
name TEXT,
created_at BIGINT
)",
        vec![],
    )
    .await?;

    // create new users
    let new_user = User {
        id: 1,
        name: "Alice".into(),
        created_at: Utc::now(),
    };

    let another_user = User {
        id: 2,
        name: "Bob".into(),
        created_at: Utc::now(),
    };

    User::create(&db, &new_user).await?;
    User::create(&db, &another_user).await?;

    // find all
    let users: Vec<User> = User::find_all(&db).await?;
    println!("{:?}", users);
    let user1: User = User::find_by_id(&db, 1).await?.expect("cant find");
    println!("{:?}", user1);

    Ok(())
}