vibesql_executor/alter/
mod.rs1mod columns;
4mod constraints;
5mod table_options;
6mod validation;
7
8use vibesql_ast::*;
9use vibesql_storage::Database;
10
11use crate::{errors::ExecutorError, privilege_checker::PrivilegeChecker};
12
13pub struct AlterTableExecutor;
15
16impl AlterTableExecutor {
17 pub fn execute(
19 stmt: &AlterTableStmt,
20 database: &mut Database,
21 ) -> Result<String, ExecutorError> {
22 let table_name = match stmt {
24 AlterTableStmt::AddColumn(s) => &s.table_name,
25 AlterTableStmt::DropColumn(s) => &s.table_name,
26 AlterTableStmt::AlterColumn(s) => match s {
27 AlterColumnStmt::SetDefault { table_name, .. } => table_name,
28 AlterColumnStmt::DropDefault { table_name, .. } => table_name,
29 AlterColumnStmt::SetNotNull { table_name, .. } => table_name,
30 AlterColumnStmt::DropNotNull { table_name, .. } => table_name,
31 },
32 AlterTableStmt::AddConstraint(s) => &s.table_name,
33 AlterTableStmt::DropConstraint(s) => &s.table_name,
34 AlterTableStmt::RenameTable(s) => &s.table_name,
35 AlterTableStmt::ModifyColumn(s) => &s.table_name,
36 AlterTableStmt::ChangeColumn(s) => &s.table_name,
37 };
38 PrivilegeChecker::check_alter(database, table_name)?;
39
40 match stmt {
41 AlterTableStmt::AddColumn(add_column) => {
42 columns::execute_add_column(add_column, database)
43 }
44 AlterTableStmt::DropColumn(drop_column) => {
45 columns::execute_drop_column(drop_column, database)
46 }
47 AlterTableStmt::AlterColumn(alter_column) => {
48 columns::execute_alter_column(alter_column, database)
49 }
50 AlterTableStmt::AddConstraint(add_constraint) => {
51 constraints::execute_add_constraint(add_constraint, database)
52 }
53 AlterTableStmt::DropConstraint(drop_constraint) => {
54 constraints::execute_drop_constraint(drop_constraint, database)
55 }
56 AlterTableStmt::RenameTable(rename_table) => {
57 table_options::execute_rename_table(rename_table, database)
58 }
59 AlterTableStmt::ModifyColumn(modify_column) => {
60 columns::execute_modify_column(modify_column, database)
61 }
62 AlterTableStmt::ChangeColumn(change_column) => {
63 columns::execute_change_column(change_column, database)
64 }
65 }
66 }
67}