quill-sql 0.3.1

use crate::error::QuillSQLResult;
use std::sync::Arc;

use crate::plan::logical_plan::{Insert, LogicalPlan, Values};

use super::LogicalPlanner;

impl<'a> LogicalPlanner<'a> {
    pub fn plan_insert(
        &self,
        table_name: &sqlparser::ast::ObjectName,
        columns_ident: &[sqlparser::ast::Ident],
        source: &sqlparser::ast::Query,
    ) -> QuillSQLResult<LogicalPlan> {
        let mut input = self.plan_set_expr(source.body.as_ref())?;
        let table = self.bind_table_name(table_name)?;
        let table_schema = self.context.catalog.table_schema(&table)?;

        let projected_schema = if columns_ident.is_empty() {
            table_schema.clone()
        } else {
            let columns: Vec<String> = columns_ident
                .iter()
                .map(|ident| ident.value.clone())
                .collect();
            let indices = columns
                .iter()
                .map(|name| table_schema.index_of(Some(&table), name.as_str()))
                .collect::<QuillSQLResult<Vec<usize>>>()?;

            Arc::new(table_schema.project(&indices)?)
        };

        if let LogicalPlan::Values(Values { values, .. }) = input {
            input = LogicalPlan::Values(Values {
                values,
                schema: projected_schema.clone(),
            })
        }

        Ok(LogicalPlan::Insert(Insert {
            table,
            table_schema,
            projected_schema,
            input: Arc::new(input),
        }))
    }
}