Enum NodedbStatement 

pub enum NodedbStatement {
    CreateCollection {
        name: String,
        if_not_exists: bool,
        engine: Option<String>,
        columns: Vec<(String, String)>,
        options: Vec<(String, String)>,
        flags: Vec<String>,
        balanced_raw: Option<String>,
    },
    CreateTable {
        name: String,
        if_not_exists: bool,
        engine: Option<String>,
        columns: Vec<(String, String)>,
        options: Vec<(String, String)>,
        flags: Vec<String>,
        balanced_raw: Option<String>,
    },
    DropCollection {
        name: String,
        if_exists: bool,
        purge: bool,
        cascade: bool,
        cascade_force: bool,
    },
    UndropCollection {
        name: String,
    },
    AlterCollection {
        name: String,
        operation: AlterCollectionOp,
    },
    DescribeCollection {
        name: String,
    },
    ShowCollections,
    CreateIndex {
        unique: bool,
        index_name: Option<String>,
        collection: String,
        field: String,
        case_insensitive: bool,
        where_condition: Option<String>,
    },
    DropIndex {
        name: String,
        collection: Option<String>,
        if_exists: bool,
    },
    ShowIndexes {
        collection: Option<String>,
    },
    Reindex {
        collection: String,
        index_name: Option<String>,
        concurrent: bool,
    },
    CreateTrigger {

        or_replace: bool,
        execution_mode: String,
        name: String,
        timing: String,
        events_insert: bool,
        events_update: bool,
        events_delete: bool,
        collection: String,
        granularity: String,
        when_condition: Option<String>,
        priority: i32,
        security: String,
        body_sql: String,
    
},
    DropTrigger {
        name: String,
        collection: String,
        if_exists: bool,
    },
    AlterTrigger {
        name: String,
        action: String,
        new_owner: Option<String>,
    },
    ShowTriggers {
        collection: Option<String>,
    },
    CreateSchedule {
        name: String,
        cron_expr: String,
        body_sql: String,
        scope: String,
        missed_policy: String,
        allow_overlap: bool,
    },
    DropSchedule {
        name: String,
        if_exists: bool,
    },
    AlterSchedule {
        name: String,
        action: String,
        cron_expr: Option<String>,
    },
    ShowSchedules,
    ShowScheduleHistory {
        name: String,
    },
    CreateSequence {
        name: String,
        if_not_exists: bool,
        start: Option<i64>,
        increment: Option<i64>,
        min_value: Option<i64>,
        max_value: Option<i64>,
        cycle: bool,
        cache: Option<i64>,
        format_template_raw: Option<String>,
        reset_period_raw: Option<String>,
        gap_free: bool,
        scope: Option<String>,
    },
    DropSequence {
        name: String,
        if_exists: bool,
    },
    AlterSequence {
        name: String,
        action: String,
        with_value: Option<String>,
    },
    DescribeSequence {
        name: String,
    },
    ShowSequences,
    CreateAlert {
        name: String,
        collection: String,
        where_filter: Option<String>,
        condition_raw: String,
        group_by: Vec<String>,
        window_raw: String,
        fire_after: u32,
        recover_after: u32,
        severity: String,
        notify_targets_raw: String,
    },
    DropAlert {
        name: String,
        if_exists: bool,
    },
    AlterAlert {
        name: String,
        action: String,
    },
    ShowAlerts,
    ShowAlertStatus {
        name: String,
    },
    CreateRetentionPolicy {
        name: String,
        collection: String,
        body_raw: String,
        eval_interval_raw: Option<String>,
    },
    DropRetentionPolicy {
        name: String,
        if_exists: bool,
    },
    AlterRetentionPolicy {
        name: String,
        action: String,
        set_key: Option<String>,
        set_value: Option<String>,
    },
    ShowRetentionPolicies,
    CreateChangeStream {
        name: String,
        collection: String,
        with_clause_raw: String,
    },
    DropChangeStream {
        name: String,
        if_exists: bool,
    },
    AlterChangeStream {
        name: String,
        action: String,
    },
    ShowChangeStreams,
    CreateConsumerGroup {
        group_name: String,
        stream_name: String,
    },
    DropConsumerGroup {
        name: String,
        stream: String,
        if_exists: bool,
    },
    ShowConsumerGroups {
        stream: Option<String>,
    },
    CreateRlsPolicy {
        name: String,
        collection: String,
        policy_type: String,
        predicate_raw: String,
        is_restrictive: bool,
        on_deny_raw: Option<String>,
        tenant_id_override: Option<u64>,
    },
    DropRlsPolicy {
        name: String,
        collection: String,
        if_exists: bool,
    },
    ShowRlsPolicies {
        collection: Option<String>,
    },
    CreateMaterializedView {
        name: String,
        source: String,
        query_sql: String,
        refresh_mode: String,
    },
    DropMaterializedView {
        name: String,
        if_exists: bool,
    },
    ShowMaterializedViews,
    CreateContinuousAggregate {
        name: String,
        source: String,
        bucket_raw: String,
        aggregate_exprs_raw: String,
        group_by: Vec<String>,
        with_clause_raw: String,
    },
    DropContinuousAggregate {
        name: String,
        if_exists: bool,
    },
    ShowContinuousAggregates,
    CreateDatabase {
        name: String,
        if_not_exists: bool,
        options: Vec<(String, String)>,
    },
    DropDatabase {
        name: String,
        if_exists: bool,
        cascade: bool,
    },
    AlterDatabase {
        name: String,
        operation: AlterDatabaseOperation,
    },
    ShowDatabases,
    ShowDatabaseQuota {
        name: String,
    },
    ShowDatabaseUsage {
        name: String,
    },
    ShowDatabaseLineage {
        name: String,
    },
    AlterTenant {
        name: String,
        database: String,
        operation: AlterTenantOperation,
    },
    ShowTenantQuotaInDatabase {
        name: String,
        database: String,
    },
    ShowTenantUsageInDatabase {
        name: String,
        database: String,
    },
    UseDatabase {
        name: String,
    },
    CloneDatabase {
        new_name: String,
        source_name: String,
        as_of: CloneAsOf,
    },
    MirrorDatabase {
        local_name: String,
        source_cluster: String,
        source_database: String,
        mode: MirrorMode,
    },
    ShowDatabaseMirrorStatus {
        name: Option<String>,
    },
    MoveTenant {
        tenant_name: String,
        from_db: String,
        to_db: String,
    },
    BackupDatabase {
        name: String,
        uri: String,
    },
    RestoreDatabase {
        name: String,
        uri: String,
    },
    BackupTenant {
        tenant_id: String,
    },
    RestoreTenant {
        dry_run: bool,
        tenant_id: String,
    },
    ShowNodes,
    ShowNode {
        node_id: String,
    },
    RemoveNode {
        node_id: String,
    },
    ShowCluster,
    ShowMigrations,
    ShowRanges,
    ShowRouting,
    ShowSchemaVersion,
    ShowPeerHealth,
    Rebalance,
    ShowRaftGroups,
    ShowRaftGroup {
        group_id: String,
    },
    AlterRaftGroup {
        group_id: String,
        action: String,
        node_id: String,
    },
    Analyze {
        collection: Option<String>,
    },
    Compact {
        collection: String,
    },
    ShowStorage {
        collection: Option<String>,
    },
    ShowCompactionStatus,
    CreateUser {
        username: String,
        password: String,
        role: Option<String>,
        tenant_id: Option<u64>,
    },
    DropUser {
        username: String,
    },
    AlterUser {
        username: String,
        op: AlterUserOp,
    },
    ShowUsers,
    AlterRole {
        name: String,
        sub_op: AlterRoleOp,
    },
    GrantRole {
        role: String,
        username: String,
    },
    RevokeRole {
        role: String,
        username: String,
    },
    GrantPermission {
        permission: String,
        target_type: String,
        target_name: String,
        grantee: String,
    },
    GrantDatabasePermission {
        permission: String,
        db_name: String,
        grantee: String,
    },
    RevokePermission {
        permission: String,
        target_type: String,
        target_name: String,
        grantee: String,
    },
    RevokeDatabasePermission {
        permission: String,
        db_name: String,
        grantee: String,
    },
    ShowPermissions {
        on_collection: Option<String>,
        for_grantee: Option<String>,
    },
    ShowGrants {
        username: Option<String>,
    },
    CreateOidcProvider {
        name: String,
        issuer: String,
        jwks_uri: String,
        audience: Option<String>,
        claim_mappings: Vec<OidcClaimMappingClause>,
    },
    AlterOidcProviderClaimMapping {
        name: String,
        claim_mappings: Vec<OidcClaimMappingClause>,
    },
    DropOidcProvider {
        name: String,
        if_exists: bool,
    },
    ShowOidcProviders,
    ShowConflictPolicy {
        collection: String,
    },
    ShowTenants,
    ShowAuditLog,
    ShowConstraints {
        collection: String,
    },
    ShowTypeGuards {
        collection: String,
    },
    CreateEnumType {
        name: String,
        labels: Vec<String>,
    },
    CreateCompositeType {
        name: String,
        fields: Vec<(String, String)>,
    },
    DropType {
        name: String,
        if_exists: bool,
    },
    AlterTypeAddValue {
        type_name: String,
        label: String,
    },
    ShowTypes,
    CreateSynonymGroup {
        name: String,
        terms: Vec<String>,
    },
    DropSynonymGroup {
        name: String,
        if_exists: bool,
    },
    ShowSynonymGroups,
    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,
        edge_label: Option<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 {
        body: String,
    },
    GraphRagFusion {
        collection: String,
        params: FusionParams,
    },
    CopyFromFile {
        collection: String,
        path: String,
        format: Option<CopyFormat>,
        delimiter: Option<char>,
        header: bool,
    },
    CopyToFile {
        source: CopyToSource,
        path: String,
        format: Option<CopyFormat>,
        delimiter: Option<char>,
        header: bool,
    },
}

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

engine: Option<String>

Canonical engine name (e.g. "kv", "vector", "document_strict"). None means no engine= key was present.

columns: Vec<(String, String)>

(col_name, col_type) pairs from the parenthesised column list.

options: Vec<(String, String)>

Key-value pairs from the WITH (...) clause, excluding engine=.

flags: Vec<String>

Free-standing modifier keywords: APPEND_ONLY, HASH_CHAIN, BITEMPORAL.

balanced_raw: Option<String>

Raw interior of a BALANCED ON (group_key = col, ...) clause, or None.

CreateTable

CREATE TABLE <name> (<col_list>) — Postgres-style strict-default DDL. Infers strict relational mode unless overridden via WITH (engine='...'). No column list → rejected with SQLSTATE 42601.

Fields

name: String

if_not_exists: bool

engine: Option<String>

columns: Vec<(String, String)>

options: Vec<(String, String)>

flags: Vec<String>

balanced_raw: Option<String>

DropCollection

Fields

name: String

if_exists: bool

purge: bool

Skip the soft-delete step (requires superuser/tenant_admin).

cascade: bool

Recursively drop dependents (triggers, RLS, MVs, streams, schedules).

cascade_force: bool

Like cascade but also drops schedules with references_unknown = true.

UndropCollection

UNDROP COLLECTION <n> — restore a soft-deleted collection within retention window.

Fields

name: String

AlterCollection

Fields

name: String

operation: AlterCollectionOp

DescribeCollection

Fields

name: String

ShowCollections

CreateIndex

Fields

unique: bool

index_name: Option<String>

collection: String

field: String

case_insensitive: bool

where_condition: Option<String>

DropIndex

Fields

name: String

collection: Option<String>

if_exists: bool

ShowIndexes

Fields

collection: Option<String>

Reindex

Fields

collection: String

index_name: Option<String>

concurrent: bool

CreateTrigger

Fields

or_replace: bool

execution_mode: String

“ASYNC”, “SYNC”, or “DEFERRED”.

name: String

timing: String

“BEFORE”, “AFTER”, or “INSTEAD OF”.

events_insert: bool

events_update: bool

events_delete: bool

collection: String

granularity: String

“ROW” or “STATEMENT”.

when_condition: Option<String>

priority: i32

security: String

“INVOKER” or “DEFINER”.

body_sql: String

DropTrigger

Fields

name: String

collection: String

if_exists: bool

AlterTrigger

Fields

name: String

action: String

new_owner: Option<String>

ShowTriggers

Fields

collection: Option<String>

CreateSchedule

Fields

name: String

cron_expr: String

body_sql: String

scope: String

missed_policy: String

allow_overlap: bool

DropSchedule

Fields

name: String

if_exists: bool

AlterSchedule

Fields

name: String

action: String

cron_expr: Option<String>

ShowSchedules

ShowScheduleHistory

Fields

name: String

CreateSequence

Fields

name: String

if_not_exists: bool

start: Option<i64>

increment: Option<i64>

min_value: Option<i64>

max_value: Option<i64>

cycle: bool

cache: Option<i64>

format_template_raw: Option<String>

Raw FORMAT 'template' string (quotes stripped), or None.

reset_period_raw: Option<String>

Raw RESET YEARLY|MONTHLY|QUARTERLY|DAILY token, or None.

gap_free: bool

scope: Option<String>

DropSequence

Fields

name: String

if_exists: bool

AlterSequence

Fields

name: String

action: String

with_value: Option<String>

DescribeSequence

Fields

name: String

ShowSequences

CreateAlert

Fields

name: String

collection: String

where_filter: Option<String>

condition_raw: String

group_by: Vec<String>

window_raw: String

fire_after: u32

recover_after: u32

severity: String

notify_targets_raw: String

DropAlert

Fields

name: String

if_exists: bool

AlterAlert

Fields

name: String

action: String

ShowAlerts

ShowAlertStatus

Fields

name: String

CreateRetentionPolicy

Fields

name: String

collection: String

body_raw: String

eval_interval_raw: Option<String>

DropRetentionPolicy

Fields

name: String

if_exists: bool

AlterRetentionPolicy

Fields

name: String

action: String

set_key: Option<String>

set_value: Option<String>

ShowRetentionPolicies

CreateChangeStream

Fields

name: String

collection: String

with_clause_raw: String

DropChangeStream

Fields

name: String

if_exists: bool

AlterChangeStream

Fields

name: String

action: String

ShowChangeStreams

CreateConsumerGroup

Fields

group_name: String

stream_name: String

DropConsumerGroup

Fields

name: String

stream: String

if_exists: bool

ShowConsumerGroups

Fields

stream: Option<String>

CreateRlsPolicy

Fields

name: String

collection: String

policy_type: String

predicate_raw: String

is_restrictive: bool

on_deny_raw: Option<String>

tenant_id_override: Option<u64>

DropRlsPolicy

Fields

name: String

collection: String

if_exists: bool

ShowRlsPolicies

Fields

collection: Option<String>

CreateMaterializedView

Fields

name: String

source: String

query_sql: String

refresh_mode: String

DropMaterializedView

Fields

name: String

if_exists: bool

ShowMaterializedViews

CreateContinuousAggregate

Fields

name: String

source: String

bucket_raw: String

aggregate_exprs_raw: String

group_by: Vec<String>

with_clause_raw: String

DropContinuousAggregate

Fields

name: String

if_exists: bool

ShowContinuousAggregates

CreateDatabase

CREATE DATABASE [IF NOT EXISTS] <name> [WITH (...)]

Fields

name: String

if_not_exists: bool

options: Vec<(String, String)>

Key-value pairs from WITH (...), if present.

DropDatabase

DROP DATABASE [IF EXISTS] <name> [CASCADE | FORCE]

FORCE and CASCADE are accepted as synonyms by the parser and both set cascade = true. PostgreSQL’s WITH (FORCE) extension also terminates active sessions; that is a separate concern handled by the session registry at drop time and does not require a distinct AST flag.

Fields

name: String

if_exists: bool

cascade: bool

AlterDatabase

ALTER DATABASE <name> <operation>

Fields

name: String

operation: AlterDatabaseOperation

ShowDatabases

SHOW DATABASES

ShowDatabaseQuota

SHOW DATABASE QUOTA FOR <name> — quota limits for a named database.

Fields

name: String

ShowDatabaseUsage

SHOW DATABASE USAGE FOR <name> — runtime usage counters for a database.

Fields

name: String

ShowDatabaseLineage

SHOW DATABASE LINEAGE FOR <name> — walks the parent clone chain from <name> up to the root, returning one row per ancestor with (database_id, name, as_of_lsn, clone_created_at_lsn).

Fields

name: String

AlterTenant

ALTER TENANT <name> IN DATABASE <db> <operation>

New SQL surface. Sets per-tenant resource budgets within a specific database.

Fields

name: String

database: String

operation: AlterTenantOperation

ShowTenantQuotaInDatabase

SHOW TENANT QUOTA FOR <name> IN DATABASE <db>

Fields

name: String

database: String

ShowTenantUsageInDatabase

SHOW TENANT USAGE FOR <name> IN DATABASE <db>

Fields

name: String

database: String

UseDatabase

USE DATABASE <name> — session reset to a different database.

Fields

name: String

CloneDatabase

CLONE DATABASE <new> FROM <source> [AS OF SYSTEM TIME <ms> | LATEST]

Fields

new_name: String

source_name: String

as_of: CloneAsOf

The temporal anchor for this clone. Latest means “use the source’s current commit LSN at clone time”.

MirrorDatabase

MIRROR DATABASE <local_name> FROM <source_cluster>.<source_database> [MODE = sync | async]

Creates a continuously-updated read-only replica of source_database in source_cluster. The local database is initialized with MirrorStatus::Bootstrapping and transitions to Following once the initial snapshot transfer completes.

Every match on this variant must be exhaustive — no _ => arms.

Fields

local_name: String

Name of the new local mirror database.

source_cluster: String

Cluster identifier of the source cluster.

source_database: String

Name of the database in the source cluster to mirror.

mode: MirrorMode

Replication mode: Sync means the source waits for mirror ack; Async (default) means the mirror trails the source.

ShowDatabaseMirrorStatus

SHOW DATABASE MIRROR STATUS [FOR <name>]

Returns one row per mirror database (or one row if FOR <name> is given): name, source_cluster, source_database, mode, status, last_applied_lsn, last_apply_ms.

Every match on this variant must be exhaustive — no _ => arms.

Fields

name: Option<String>

Filter to a specific mirror by name, or None to show all mirrors.

MoveTenant

MOVE TENANT <tenant> FROM <db_a> TO <db_b>

Returns FEATURE_NOT_YET_IMPLEMENTED until the tenant-move subsystem lands.

Fields

tenant_name: String

from_db: String

to_db: String

BackupDatabase

BACKUP DATABASE <name> TO <uri>

Returns FEATURE_NOT_YET_IMPLEMENTED until the backup subsystem lands.

Fields

name: String

uri: String

RestoreDatabase

RESTORE DATABASE <name> FROM <uri>

Returns FEATURE_NOT_YET_IMPLEMENTED until the restore subsystem lands.

Fields

name: String

uri: String

BackupTenant

Fields

tenant_id: String

RestoreTenant

Fields

dry_run: bool

tenant_id: 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

group_id: String

action: String

node_id: String

Analyze

Fields

collection: Option<String>

Compact

Fields

collection: String

ShowStorage

Fields

collection: Option<String>

ShowCompactionStatus

CreateUser

Fields

username: String

password: String

role: Option<String>

tenant_id: Option<u64>

DropUser

Fields

username: String

AlterUser

Fields

username: String

op: AlterUserOp

ShowUsers

AlterRole

ALTER ROLE <name> GRANT/REVOKE/SET.

Fields

name: String

sub_op: AlterRoleOp

GrantRole

Fields

role: String

username: String

RevokeRole

Fields

role: String

username: String

GrantPermission

Fields

permission: String

target_type: String

target_name: String

grantee: String

GrantDatabasePermission

GRANT <privilege> ON DATABASE <name> TO <user>

Fields

permission: String

db_name: String

grantee: String

RevokePermission

Fields

permission: String

target_type: String

target_name: String

grantee: String

RevokeDatabasePermission

REVOKE <privilege> ON DATABASE <name> FROM <user>

Fields

permission: String

db_name: String

grantee: String

ShowPermissions

Fields

on_collection: Option<String>

for_grantee: Option<String>

ShowGrants

Fields

username: Option<String>

CreateOidcProvider

CREATE OIDC PROVIDER <name> ISSUER '<iss>' JWKS_URI '<uri>' [AUDIENCE '<aud>'] [CLAIM MAPPING WHEN <claim_name> = '<value>' SET DEFAULT_DATABASE = <id>, ADD DATABASES [<ids>], ADD ROLES ['<role>', ...]]

Fields

name: String

issuer: String

jwks_uri: String

audience: Option<String>

claim_mappings: Vec<OidcClaimMappingClause>

(claim_name, claim_value, default_database, add_databases, add_roles) tuples.

AlterOidcProviderClaimMapping

ALTER OIDC PROVIDER <name> SET CLAIM MAPPING WHEN <claim_name> = '<value>' SET DEFAULT_DATABASE = <id>, ADD DATABASES [<ids>], ADD ROLES ['<role>', ...]

Replaces the entire claim-mapping list for the named provider.

Fields

name: String

claim_mappings: Vec<OidcClaimMappingClause>

DropOidcProvider

DROP OIDC PROVIDER [IF EXISTS] <name>

Fields

name: String

if_exists: bool

ShowOidcProviders

SHOW OIDC PROVIDERS

ShowConflictPolicy

SHOW CONFLICT POLICY ON <collection>

Fields

collection: String

ShowTenants

ShowAuditLog

ShowConstraints

Fields

collection: String

ShowTypeGuards

Fields

collection: String

CreateEnumType

CREATE TYPE <name> AS ENUM ('label1', 'label2', ...)

Fields

name: String

labels: Vec<String>

CreateCompositeType

CREATE TYPE <name> AS (<field1> <type1>, <field2> <type2>, ...)

Fields

name: String

fields: Vec<(String, String)>

(field_name, type_name) pairs.

DropType

DROP TYPE [IF EXISTS] <name>

Fields

name: String

if_exists: bool

AlterTypeAddValue

ALTER TYPE <name> ADD VALUE 'label'

Fields

type_name: String

label: String

ShowTypes

SHOW TYPES

CreateSynonymGroup

CREATE SYNONYM GROUP <name> AS ('term1', 'term2', ...)

Fields

name: String

terms: Vec<String>

DropSynonymGroup

DROP SYNONYM GROUP [IF EXISTS] <name>

Fields

name: String

if_exists: bool

ShowSynonymGroups

SHOW SYNONYM GROUPS

GraphInsertEdge

Fields

collection: String

src: String

dst: String

label: String

properties: GraphProperties

GraphDeleteEdge

Fields

collection: String

src: String

dst: String

label: String

GraphSetLabels

Fields

node_id: String

labels: Vec<String>

remove: bool

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

edge_label: Option<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 — body forwarded verbatim to the graph pattern compiler.

Fields

body: String

GraphRagFusion

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

Fields

collection: String

params: FusionParams

CopyFromFile

COPY <collection> FROM '<path>' [WITH (FORMAT ..., DELIMITER ..., HEADER ...)]

Server-side file-path bulk import. Does not handle STDIN streaming (that is a different protocol path) or COPY … TO.

Fields

collection: String

path: String

format: Option<CopyFormat>

delimiter: Option<char>

header: bool

CopyToFile

COPY <collection> TO '<path>' [WITH (FORMAT ..., DELIMITER ..., HEADER ...)] COPY (SELECT ...) TO '<path>' [WITH (...)]

Server-side file-path bulk export. Streams scan results to a file.

Fields

source: CopyToSource

The source: either a bare collection name or a SELECT query.

path: String

format: Option<CopyFormat>

delimiter: Option<char>

header: bool

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