ducklake 0.0.5

Rust SDK for DuckLake.
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

/* ---------------------------------- CREATE TABLE ---------------------------------- */

use crate::db::Dialect;

/// Simple trait to simplify the creation of ducklake tables.
pub trait CreateTable {
    fn create_entity<E: CreatableEntity>(dialect: Dialect) -> sea_query::TableCreateStatement;
}

pub trait CreatableEntity {
    fn create_table(dialect: Dialect) -> sea_query::TableCreateStatement;
}

impl CreateTable for sea_query::Table {
    fn create_entity<E: CreatableEntity>(dialect: Dialect) -> sea_query::TableCreateStatement {
        E::create_table(dialect)
    }
}

/* ------------------------------------- INSERT ------------------------------------- */

/// Simple trait to simplify the insertion of rows into ducklake tables.
pub trait InsertIntoTable {
    fn insert_entity(entity: impl InsertableEntity) -> sea_query::InsertStatement;
    fn insert_entities<E: InsertableEntity>(
        entities: impl IntoIterator<Item = E>,
    ) -> sea_query::InsertStatement;
}

pub trait InsertableEntity {
    fn insert_into_table(&self) -> sea_query::InsertStatement;
    fn insert_all_into_table(
        entities: impl IntoIterator<Item = Self>,
    ) -> sea_query::InsertStatement;
}

impl InsertIntoTable for sea_query::Query {
    fn insert_entity(entity: impl InsertableEntity) -> sea_query::InsertStatement {
        entity.insert_into_table()
    }

    fn insert_entities<E: InsertableEntity>(
        entities: impl IntoIterator<Item = E>,
    ) -> sea_query::InsertStatement {
        E::insert_all_into_table(entities)
    }
}