ducklake 0.0.9

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

use super::changes::Change;
use super::{IfExistsStrategy, Transaction};
use crate::{DucklakeResult, io};

impl<'a> Transaction<'a> {
    /// Create a new schema in the catalog.
    pub fn create_schema(
        &mut self,
        name: &str,
        path: Option<String>,
        if_exists: IfExistsStrategy,
    ) -> DucklakeResult<()> {
        // If the schema already exists and the strategy is specified accordingly, simply
        // return without making any changes
        if matches!(if_exists, IfExistsStrategy::Skip) && self.catalog().schema(name).is_ok() {
            return Ok(());
        }

        let path: io::DucklakePath = path.unwrap_or_else(|| name.to_string()).parse()?;
        let schema_ref = self.catalog_mut().add_schema(name, path.clone())?;
        let change = Change::CreateSchema {
            schema_ref,
            name: name.to_string(),
            path: path.ensure_directory(),
        };
        self.changes.push(change);
        Ok(())
    }

    /// Delete an existing schema from the catalog.
    pub fn delete_schema(&mut self, name: &str) -> DucklakeResult<()> {
        let mut schema = self.catalog_mut().schema_mut(name)?;
        schema.delete()?;
        let change = Change::DeleteSchema {
            schema_ref: schema.ref_(),
        };
        self.changes.push(change);
        Ok(())
    }
}