gluesql-shared-memory-storage 0.12.0

GlueSQL - Open source SQL database engine fully written in Rust with pure functional execution layer, easily swappable storage and web assembly support!
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

use {
    super::SharedMemoryStorage,
    async_trait::async_trait,
    gluesql_core::{ast::ColumnDef, result::MutResult, store::AlterTable},
    memory_storage::MemoryStorage,
    std::sync::Arc,
};

#[async_trait(?Send)]
impl AlterTable for SharedMemoryStorage {
    async fn rename_schema(self, table_name: &str, new_table_name: &str) -> MutResult<Self, ()> {
        let database = Arc::clone(&self.database);
        let mut database = database.write().await;

        if let Err(error) = MemoryStorage::rename_schema(&mut database, table_name, new_table_name)
        {
            return Err((self, error));
        }

        Ok((self, ()))
    }

    async fn rename_column(
        self,
        table_name: &str,
        old_column_name: &str,
        new_column_name: &str,
    ) -> MutResult<Self, ()> {
        let database = Arc::clone(&self.database);
        let mut database = database.write().await;

        if let Err(error) = MemoryStorage::rename_column(
            &mut database,
            table_name,
            old_column_name,
            new_column_name,
        ) {
            return Err((self, error));
        }

        Ok((self, ()))
    }

    async fn add_column(self, table_name: &str, column_def: &ColumnDef) -> MutResult<Self, ()> {
        let database = Arc::clone(&self.database);
        let mut database = database.write().await;

        if let Err(error) = MemoryStorage::add_column(&mut database, table_name, column_def) {
            return Err((self, error));
        }

        Ok((self, ()))
    }

    async fn drop_column(
        self,
        table_name: &str,
        column_name: &str,
        if_exists: bool,
    ) -> MutResult<Self, ()> {
        let database = Arc::clone(&self.database);
        let mut database = database.write().await;

        if let Err(error) =
            MemoryStorage::drop_column(&mut database, table_name, column_name, if_exists)
        {
            return Err((self, error));
        }

        Ok((self, ()))
    }
}