use PhysicalPlan::CreateTransactionalView;
use reifydb_catalog::error::{CatalogError, CatalogObjectKind};
use reifydb_transaction::transaction::Transaction;
use reifydb_type::fragment::Fragment;
use crate::{
Result,
plan::{
logical,
physical::{Compiler, CreateTransactionalViewNode, PhysicalPlan},
},
};
impl<'bump> Compiler<'bump> {
pub(crate) fn compile_create_transactional(
&mut self,
rx: &mut Transaction<'_>,
create: logical::CreateTransactionalViewNode<'bump>,
) -> Result<PhysicalPlan<'bump>> {
let ns_segments: Vec<&str> = create.view.namespace.iter().map(|n| n.text()).collect();
let Some(namespace) = self.catalog.find_namespace_by_segments(rx, &ns_segments)? else {
let ns_fragment = if let Some(n) = create.view.namespace.first() {
let interned = self.interner.intern_fragment(n);
interned.with_text(ns_segments.join("::"))
} else {
Fragment::internal("default".to_string())
};
return Err(CatalogError::NotFound {
kind: CatalogObjectKind::Namespace,
namespace: ns_segments.join("::"),
name: String::new(),
fragment: ns_fragment,
}
.into());
};
let physical_plan = self.compile(rx, create.as_clause)?.unwrap();
Ok(CreateTransactionalView(CreateTransactionalViewNode {
namespace,
view: self.interner.intern_fragment(&create.view.name),
if_not_exists: create.if_not_exists,
columns: create.columns,
as_clause: self.bump_box(physical_plan),
storage_kind: create.storage_kind,
tick: create.tick,
ttl: create.ttl,
}))
}
}