Enum NodedbStatement 

pub enum NodedbStatement {
    CreateCollection {
        name: String,
        if_not_exists: bool,
        raw_sql: String,
    },
    DropCollection {
        name: String,
        if_exists: bool,
        purge: bool,
        cascade: bool,
        cascade_force: bool,
    },
    UndropCollection {
        name: String,
    },
    AlterCollection {
        name: String,
        raw_sql: String,
    },
    DescribeCollection {
        name: String,
    },
    ShowCollections,
    CreateIndex {
        unique: bool,
        raw_sql: String,
    },
    DropIndex {
        name: String,
        collection: Option<String>,
        if_exists: bool,
    },
    ShowIndexes {
        collection: Option<String>,
    },
    Reindex {
        collection: String,
    },
    CreateTrigger {
        or_replace: bool,
        deferred: bool,
        sync: bool,
        raw_sql: String,
    },
    DropTrigger {
        name: String,
        collection: String,
        if_exists: bool,
    },
    AlterTrigger {
        raw_sql: String,
    },
    ShowTriggers {
        collection: Option<String>,
    },
    CreateSchedule {
        raw_sql: String,
    },
    DropSchedule {
        name: String,
        if_exists: bool,
    },
    AlterSchedule {
        raw_sql: String,
    },
    ShowSchedules,
    ShowScheduleHistory {
        name: String,
    },
    CreateSequence {
        name: String,
        if_not_exists: bool,
        raw_sql: String,
    },
    DropSequence {
        name: String,
        if_exists: bool,
    },
    AlterSequence {
        raw_sql: String,
    },
    DescribeSequence {
        name: String,
    },
    ShowSequences,
    CreateAlert {
        raw_sql: String,
    },
    DropAlert {
        name: String,
        if_exists: bool,
    },
    AlterAlert {
        raw_sql: String,
    },
    ShowAlerts,
    ShowAlertStatus {
        name: String,
    },
    CreateRetentionPolicy {
        raw_sql: String,
    },
    DropRetentionPolicy {
        name: String,
        if_exists: bool,
    },
    AlterRetentionPolicy {
        raw_sql: String,
    },
    ShowRetentionPolicies,
    CreateChangeStream {
        raw_sql: String,
    },
    DropChangeStream {
        name: String,
        if_exists: bool,
    },
    AlterChangeStream {
        raw_sql: String,
    },
    ShowChangeStreams,
    CreateConsumerGroup {
        raw_sql: String,
    },
    DropConsumerGroup {
        name: String,
        stream: String,
        if_exists: bool,
    },
    ShowConsumerGroups {
        stream: Option<String>,
    },
    CreateRlsPolicy {
        raw_sql: String,
    },
    DropRlsPolicy {
        name: String,
        collection: String,
        if_exists: bool,
    },
    ShowRlsPolicies {
        collection: Option<String>,
    },
    CreateMaterializedView {
        raw_sql: String,
    },
    DropMaterializedView {
        name: String,
        if_exists: bool,
    },
    ShowMaterializedViews,
    CreateContinuousAggregate {
        raw_sql: String,
    },
    DropContinuousAggregate {
        name: String,
        if_exists: bool,
    },
    ShowContinuousAggregates,
    BackupTenant {
        raw_sql: String,
    },
    RestoreTenant {
        dry_run: bool,
        raw_sql: String,
    },
    ShowNodes,
    ShowNode {
        node_id: String,
    },
    RemoveNode {
        node_id: String,
    },
    ShowCluster,
    ShowMigrations,
    ShowRanges,
    ShowRouting,
    ShowSchemaVersion,
    ShowPeerHealth,
    Rebalance,
    ShowRaftGroups,
    ShowRaftGroup {
        group_id: String,
    },
    AlterRaftGroup {
        raw_sql: String,
    },
    Analyze {
        collection: Option<String>,
    },
    Compact {
        collection: String,
    },
    ShowStorage {
        collection: Option<String>,
    },
    ShowCompactionStatus,
    CreateUser {
        raw_sql: String,
    },
    DropUser {
        username: String,
    },
    AlterUser {
        raw_sql: String,
    },
    ShowUsers,
    GrantRole {
        raw_sql: String,
    },
    RevokeRole {
        raw_sql: String,
    },
    GrantPermission {
        raw_sql: String,
    },
    RevokePermission {
        raw_sql: String,
    },
    ShowPermissions {
        collection: Option<String>,
    },
    ShowGrants {
        username: Option<String>,
    },
    ShowTenants,
    ShowAuditLog,
    ShowConstraints {
        collection: String,
    },
    ShowTypeGuards {
        collection: String,
    },
    GraphInsertEdge {
        collection: String,
        src: String,
        dst: String,
        label: String,
        properties: GraphProperties,
    },
    GraphDeleteEdge {
        collection: String,
        src: String,
        dst: String,
        label: String,
    },
    GraphSetLabels {
        node_id: String,
        labels: Vec<String>,
        remove: bool,
    },
    GraphTraverse {
        start: String,
        depth: usize,
        edge_label: Option<String>,
        direction: GraphDirection,
    },
    GraphNeighbors {
        node: String,
        edge_label: Option<String>,
        direction: GraphDirection,
    },
    GraphPath {
        src: String,
        dst: String,
        max_depth: usize,
        edge_label: Option<String>,
    },
    GraphAlgo {
        algorithm: String,
        collection: String,
        damping: Option<f64>,
        tolerance: Option<f64>,
        resolution: Option<f64>,
        max_iterations: Option<usize>,
        sample_size: Option<usize>,
        source_node: Option<String>,
        direction: Option<String>,
        mode: Option<String>,
    },
    MatchQuery {
        raw_sql: String,
    },
    GraphRagFusion {
        collection: String,
        params: FusionParams,
    },
    Other {
        raw_sql: String,
    },
}

Typed representation of every NodeDB DDL statement.

Handlers receive a fully-parsed variant instead of raw &[&str] parts, eliminating array-index panics and enabling exhaustive match coverage for new DDL commands.

Variants

CreateCollection

Fields

name: String

if_not_exists: bool

raw_sql: String

DropCollection

Fields

name: String

if_exists: bool

purge: bool

DROP COLLECTION <n> PURGE — skip the soft-delete step and go straight to CatalogEntry::PurgeCollection. Requires superuser or tenant_admin. Fails if dependents exist unless cascade is also set.

cascade: bool

DROP COLLECTION <n> CASCADE — recursively drop dependents (triggers, RLS, MVs sourcing the collection, change streams, schedules). Rejects on cascade cycles (32-deep limit).

cascade_force: bool

DROP COLLECTION <n> CASCADE FORCE — only difference from cascade: also drops schedules whose SQL carries references_unknown = true. Requires superuser.

UndropCollection

UNDROP COLLECTION <n> — restore a soft-deleted collection whose retention window has not yet elapsed. Flips StoredCollection.is_active back to true via a new PutCollection catalog entry. Fails if the retention window has already expired (storage is already purged) or if an active collection of the same name exists.

Fields

name: String

AlterCollection

Fields

name: String

raw_sql: String

DescribeCollection

Fields

name: String

ShowCollections

CreateIndex

Fields

unique: bool

raw_sql: String

DropIndex

Fields

name: String

collection: Option<String>

if_exists: bool

ShowIndexes

Fields

collection: Option<String>

Reindex

Fields

collection: String

CreateTrigger

Fields

or_replace: bool

deferred: bool

sync: bool

raw_sql: String

DropTrigger

Fields

name: String

collection: String

if_exists: bool

AlterTrigger

Fields

raw_sql: String

ShowTriggers

Fields

collection: Option<String>

CreateSchedule

Fields

raw_sql: String

DropSchedule

Fields

name: String

if_exists: bool

AlterSchedule

Fields

raw_sql: String

ShowSchedules

ShowScheduleHistory

Fields

name: String

CreateSequence

Fields

name: String

if_not_exists: bool

raw_sql: String

DropSequence

Fields

name: String

if_exists: bool

AlterSequence

Fields

raw_sql: String

DescribeSequence

Fields

name: String

ShowSequences

CreateAlert

Fields

raw_sql: String

DropAlert

Fields

name: String

if_exists: bool

AlterAlert

Fields

raw_sql: String

ShowAlerts

ShowAlertStatus

Fields

name: String

CreateRetentionPolicy

Fields

raw_sql: String

DropRetentionPolicy

Fields

name: String

if_exists: bool

AlterRetentionPolicy

Fields

raw_sql: String

ShowRetentionPolicies

CreateChangeStream

Fields

raw_sql: String

DropChangeStream

Fields

name: String

if_exists: bool

AlterChangeStream

Fields

raw_sql: String

ShowChangeStreams

CreateConsumerGroup

Fields

raw_sql: String

DropConsumerGroup

Fields

name: String

stream: String

if_exists: bool

ShowConsumerGroups

Fields

stream: Option<String>

CreateRlsPolicy

Fields

raw_sql: String

DropRlsPolicy

Fields

name: String

collection: String

if_exists: bool

ShowRlsPolicies

Fields

collection: Option<String>

CreateMaterializedView

Fields

raw_sql: String

DropMaterializedView

Fields

name: String

if_exists: bool

ShowMaterializedViews

CreateContinuousAggregate

Fields

raw_sql: String

DropContinuousAggregate

Fields

name: String

if_exists: bool

ShowContinuousAggregates

BackupTenant

Fields

raw_sql: String

RestoreTenant

Fields

dry_run: bool

raw_sql: String

ShowNodes

ShowNode

Fields

node_id: String

RemoveNode

Fields

node_id: String

ShowCluster

ShowMigrations

ShowRanges

ShowRouting

ShowSchemaVersion

ShowPeerHealth

Rebalance

ShowRaftGroups

ShowRaftGroup

Fields

group_id: String

AlterRaftGroup

Fields

raw_sql: String

Analyze

Fields

collection: Option<String>

Compact

Fields

collection: String

ShowStorage

Fields

collection: Option<String>

ShowCompactionStatus

CreateUser

Fields

raw_sql: String

DropUser

Fields

username: String

AlterUser

Fields

raw_sql: String

ShowUsers

GrantRole

Fields

raw_sql: String

RevokeRole

Fields

raw_sql: String

GrantPermission

Fields

raw_sql: String

RevokePermission

Fields

raw_sql: String

ShowPermissions

Fields

collection: Option<String>

ShowGrants

Fields

username: Option<String>

ShowTenants

ShowAuditLog

ShowConstraints

Fields

collection: String

ShowTypeGuards

Fields

collection: String

GraphInsertEdge

Fields

collection: String

src: String

dst: String

label: String

properties: GraphProperties

GraphDeleteEdge

Fields

collection: String

src: String

dst: String

label: String

GraphSetLabels

GRAPH LABEL / GRAPH UNLABEL.

Fields

node_id: String

labels: Vec<String>

remove: bool

true for UNLABEL, false for LABEL.

GraphTraverse

Fields

start: String

depth: usize

edge_label: Option<String>

direction: GraphDirection

GraphNeighbors

Fields

node: String

edge_label: Option<String>

direction: GraphDirection

GraphPath

Fields

src: String

dst: String

max_depth: usize

edge_label: Option<String>

GraphAlgo

Fields

algorithm: String

collection: String

damping: Option<f64>

tolerance: Option<f64>

resolution: Option<f64>

max_iterations: Option<usize>

sample_size: Option<usize>

source_node: Option<String>

direction: Option<String>

mode: Option<String>

MatchQuery

MATCH (x)-[:l]->(y) RETURN x, y — the query body is compiled deep inside the Data Plane via engine::graph::pattern::compiler::parse, so the AST variant just captures the raw SQL for that consumer.

Fields

raw_sql: String

GraphRagFusion

GRAPH RAG FUSION ON <collection> QUERY ARRAY[…] [options…]

All numeric and label options are optional at parse time; the pgwire handler applies defaults and caps so validation errors surface with proper SQLSTATE codes rather than parser panics.

query_vector is None when no ARRAY[…] clause was found — the handler rejects such requests with SQLSTATE 42601.

Fields

collection: String

params: FusionParams

Other

Catch-all for DDL-like commands not yet promoted to their own variant. Preserves the raw SQL for the legacy dispatch path so new variants can be added incrementally without breaking existing handlers.

Fields

raw_sql: String

Trait Implementations

impl Clone for NodedbStatement

fn clone(&self) -> NodedbStatement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodedbStatement

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

Formats the value using the given formatter.

impl PartialEq for NodedbStatement

fn eq(&self, other: &NodedbStatement) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for NodedbStatement