indexlake 0.2.0

An experimental table format with extensible index 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

use uuid::Uuid;

use crate::{ILError, ILResult, catalog::TransactionHelper, table::Table};

#[derive(Debug)]
pub enum TableAlter {
    RenameTable { new_name: String },
    RenameColumn { old_name: String, new_name: String },
}

pub(crate) async fn process_table_alter(
    tx_helper: &mut TransactionHelper,
    table: &Table,
    alter: TableAlter,
) -> ILResult<()> {
    match alter {
        TableAlter::RenameTable { new_name } => {
            tx_helper
                .update_table_name(&table.table_id, &new_name)
                .await?;
        }
        TableAlter::RenameColumn { old_name, new_name } => {
            alter_rename_column(tx_helper, &table.table_id, &old_name, &new_name).await?;
        }
    }
    Ok(())
}

pub(crate) async fn alter_rename_column(
    tx_helper: &mut TransactionHelper,
    table_id: &Uuid,
    old_name: &str,
    new_name: &str,
) -> ILResult<()> {
    let Some(field_record) = tx_helper.get_table_field(table_id, old_name).await? else {
        return Err(ILError::invalid_input(format!(
            "Field name {old_name} not found for table id {table_id}"
        )));
    };
    tx_helper
        .update_field_name(&field_record.field_id, new_name)
        .await?;
    Ok(())
}