sea-orm 1.1.20

🐚 An async & dynamic ORM 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

use crate::common::setup::create_table;
use crate::local::{bakery, worker};
use sea_orm::{error::*, sea_query, DatabaseConnection, DbConn, ExecResult};
use sea_query::{ColumnDef, ForeignKey, ForeignKeyAction, Index, Table};

pub async fn create_tables(db: &DatabaseConnection) -> Result<(), DbErr> {
    create_worker_table(db).await?;
    create_bakery_table(db).await?;
    Ok(())
}

pub async fn create_bakery_table(db: &DbConn) -> Result<ExecResult, DbErr> {
    let stmt = Table::create()
        .table(bakery::Entity)
        .col(
            ColumnDef::new(bakery::Column::Id)
                .integer()
                .not_null()
                .auto_increment()
                .primary_key(),
        )
        .col(ColumnDef::new(bakery::Column::Name).string().not_null())
        .col(
            ColumnDef::new(bakery::Column::ProfitMargin)
                .double()
                .not_null(),
        )
        .col(
            ColumnDef::new(bakery::Column::ManagerId)
                .integer()
                .not_null(),
        )
        .col(
            ColumnDef::new(bakery::Column::CashierId)
                .integer()
                .not_null(),
        )
        .foreign_key(
            ForeignKey::create()
                .name("fk-bakery-manager_id")
                .from(bakery::Entity, bakery::Column::ManagerId)
                .to(worker::Entity, worker::Column::Id),
        )
        .foreign_key(
            ForeignKey::create()
                .name("fk-bakery-cashier_id")
                .from(bakery::Entity, bakery::Column::CashierId)
                .to(worker::Entity, worker::Column::Id),
        )
        .to_owned();

    create_table(db, &stmt, bakery::Entity).await
}

pub async fn create_worker_table(db: &DbConn) -> Result<ExecResult, DbErr> {
    let stmt = Table::create()
        .table(worker::Entity)
        .col(
            ColumnDef::new(worker::Column::Id)
                .integer()
                .not_null()
                .auto_increment()
                .primary_key(),
        )
        .col(ColumnDef::new(worker::Column::Name).string().not_null())
        .to_owned();

    create_table(db, &stmt, worker::Entity).await
}