carbon-core 1.0.0

Core library for Carbon
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

//! CRUD trait family used by the `postgres` row types.

use crate::error::CarbonResult;

/// Static schema metadata: table name + column list.
pub trait Table {
    fn table() -> &'static str;
    fn columns() -> Vec<&'static str>;
}

/// Inserts the row, failing on primary-key conflict.
#[async_trait::async_trait]
pub trait Insert {
    async fn insert(&self, pool: &sqlx::PgPool) -> CarbonResult<()>;
}

/// Inserts or updates the row by primary key (`ON CONFLICT DO UPDATE`).
/// Used by `PostgresJsonAccountProcessor` and friends on every update.
#[async_trait::async_trait]
pub trait Upsert {
    async fn upsert(&self, pool: &sqlx::PgPool) -> CarbonResult<()>;
}

/// Deletes the row matching `Key`.
#[async_trait::async_trait]
pub trait Delete {
    type Key;

    async fn delete(key: Self::Key, pool: &sqlx::PgPool) -> CarbonResult<()>;
}

/// Selects the row matching `Key`, returning `Ok(None)` when absent.
#[async_trait::async_trait]
pub trait Lookup: Sized {
    type Key;

    async fn lookup(key: Self::Key, pool: &sqlx::PgPool) -> CarbonResult<Option<Self>>;
}