Struct CreateTableQuery 

pub struct CreateTableQuery {

    pub collection_model: CollectionModel,
    pub name: String,
    pub columns: Vec<CreateColumnDef>,
    pub if_not_exists: bool,
    pub default_ttl_ms: Option<u64>,
    pub context_index_fields: Vec<String>,
    pub context_index_enabled: bool,
    pub timestamps: bool,
    pub partition_by: Option<PartitionSpec>,
    pub tenant_by: Option<String>,
    pub append_only: bool,
    pub subscriptions: Vec<SubscriptionDescriptor>,
    pub vault_own_master_key: bool,
}

CREATE TABLE name (columns) or CREATE {KV|CONFIG|VAULT} name

Fields

collection_model: CollectionModel

Declared collection model. Defaults to Table for CREATE TABLE.

name: String

Table name

columns: Vec<CreateColumnDef>

Column definitions

if_not_exists: bool

IF NOT EXISTS flag

default_ttl_ms: Option<u64>

Optional default TTL applied to newly inserted items in this collection.

context_index_fields: Vec<String>

Fields to prioritize in the context index (WITH CONTEXT INDEX ON (f1, f2))

context_index_enabled: bool

Enables the global context index for this table (WITH context_index = true). Default false — pure OLTP tables skip the tokenisation / 3-way RwLock write storm on every insert. Having context_index_fields non-empty also enables it implicitly.

timestamps: bool

When true, CREATE TABLE implicitly adds two user-visible columns created_at and updated_at (BIGINT unix-ms). The runtime populates them from UnifiedEntity::created_at/updated_at on every write; created_at is immutable after insert. Enabled via WITH timestamps = true in the DDL.

partition_by: Option<PartitionSpec>

Partitioning spec (Phase 2.2 PG parity).

When present the table is the parent of a partition tree — every child partition is registered via ALTER TABLE ... ATTACH PARTITION. Phase 2.2 stops at registry-only: queries against a partitioned parent don’t auto-rewrite as UNION yet (Phase 4 adds pruning).

tenant_by: Option<String>

Table-scoped multi-tenancy declaration (Phase 2.5.4).

Syntax: CREATE TABLE t (...) WITH (tenant_by = 'col_name') or the shorthand CREATE TABLE t (...) TENANT BY (col_name). The runtime treats the named column as the tenant discriminator and automatically:

1. Registers the table → column mapping so INSERTs that omit the column get CURRENT_TENANT() auto-filled.
2. Installs an implicit RLS policy equivalent to USING (col = CURRENT_TENANT()) for SELECT/UPDATE/DELETE/INSERT.
3. Flips rls_enabled_tables on so the policy actually applies.

None leaves the table non-tenant-scoped — callers manage tenancy manually via explicit CREATE POLICY if they want it.

append_only: bool

When true, UPDATE and DELETE on this table are rejected at parse time. Corresponds to CREATE TABLE ... APPEND ONLY or WITH (append_only = true). Default false (mutable).

subscriptions: Vec<SubscriptionDescriptor>

Declarative event subscriptions for this table. #291 stores metadata only; event emission is intentionally out of scope.

vault_own_master_key: bool

CREATE VAULT ... WITH OWN MASTER KEY: provision per-vault key material instead of using the cluster vault key.

Trait Implementations

impl Clone for CreateTableQuery

fn clone(&self) -> CreateTableQuery

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CreateTableQuery

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.