nodedb 0.4.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

// SPDX-License-Identifier: BUSL-1.1

//! Protocol-neutral DDL dispatch.
//!
//! Yields a protocol-neutral [`DdlResult`] / [`DdlError`] instead of pgwire
//! `Response` types, so native, http, and pgwire entrypoints share one router
//! with no pgwire dependency in the routing layer.

use crate::control::security::identity::AuthenticatedIdentity;
use crate::control::server::shared::session::DmlTxnCtx;
use crate::control::state::SharedState;
use crate::types::DatabaseId;

use super::result::{DdlError, DdlResult};

/// Try to handle a SQL statement as a Control Plane DDL command, returning a
/// protocol-neutral result.
///
/// `txn_ctx` carries the connection's session store + address so that
/// write-shaped DML reached through this router (UPSERT/INSERT, `COPY FROM`)
/// can route in-transaction writes through the same staging gate pgwire-SQL
/// and native already use.
///
/// Returns `None` when the statement is not a recognized DDL command (the
/// caller falls through to the SQL planner).
pub async fn dispatch(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    sql: &str,
    database_id: DatabaseId,
    txn_ctx: &DmlTxnCtx<'_>,
) -> Option<Result<Vec<DdlResult>, DdlError>> {
    super::neutral::try_dispatch(state, identity, sql, database_id, txn_ctx).await
}