Struct Registry 

pub struct Registry { /* private fields */ }

Implementations

impl Registry

pub fn new() -> Self

Examples found in repository

examples/quickstart.rs (line 16)

fn main() -> Result<(), String> {
    // 1. A model is plain JSON — defined once, usable against every backend.
    let mut registry = Registry::new();
    registry.register(&json!({
        "name": "Post",
        "collection": "posts",
        "timestamps": true,
        "fields": {
            "title":  { "type": "string" },
            "status": { "type": "string", "default": "draft" },
            "views":  { "type": "int" }
        },
        "relations": {}
    }))?;

    // 2. GQL in, MongoDB command JSON out. Values are referenced by `@key`.
    let gql = "Post($condition:@c0,$sort:@s1,$limit:@l0){title, status, views}";
    let mut params = Map::new();
    params.insert("c0".to_string(), json!({ "status": "published" }));
    params.insert("s1".to_string(), json!({ "views": -1 }));
    params.insert("l0".to_string(), json!(20));

    let plan = plan_query(gql, &params, &registry, None)?;

    println!("collection = {}", plan.collection);
    println!("mode       = {}", plan.mode.as_str());

    for cmd in &plan.commands {
        println!("command    = {}", serde_json::to_string(cmd).unwrap());

        // 3. The host runs `cmd` against MongoDB — or, for a SQL backend, asks the
        //    core for parameterized SQL and binds it with its own driver.
        let sql = translate(Backend::Postgres, cmd, &registry)?;
        println!("sql        = {}", serde_json::to_string(&sql).unwrap());
    }

    Ok(())
}

pub fn register(&mut self, defn: &Value) -> Result<(), String>

注册一个 schema（含自动注册 <Name>Deleted 归档表），对应 JS register

Examples found in repository

examples/quickstart.rs (lines 17-27)

fn main() -> Result<(), String> {
    // 1. A model is plain JSON — defined once, usable against every backend.
    let mut registry = Registry::new();
    registry.register(&json!({
        "name": "Post",
        "collection": "posts",
        "timestamps": true,
        "fields": {
            "title":  { "type": "string" },
            "status": { "type": "string", "default": "draft" },
            "views":  { "type": "int" }
        },
        "relations": {}
    }))?;

    // 2. GQL in, MongoDB command JSON out. Values are referenced by `@key`.
    let gql = "Post($condition:@c0,$sort:@s1,$limit:@l0){title, status, views}";
    let mut params = Map::new();
    params.insert("c0".to_string(), json!({ "status": "published" }));
    params.insert("s1".to_string(), json!({ "views": -1 }));
    params.insert("l0".to_string(), json!(20));

    let plan = plan_query(gql, &params, &registry, None)?;

    println!("collection = {}", plan.collection);
    println!("mode       = {}", plan.mode.as_str());

    for cmd in &plan.commands {
        println!("command    = {}", serde_json::to_string(cmd).unwrap());

        // 3. The host runs `cmd` against MongoDB — or, for a SQL backend, asks the
        //    core for parameterized SQL and binds it with its own driver.
        let sql = translate(Backend::Postgres, cmd, &registry)?;
        println!("sql        = {}", serde_json::to_string(&sql).unwrap());
    }

    Ok(())
}

pub fn get(&self, name: &str) -> Result<&Schema, String>

按名称获取 schema

pub fn has(&self, name: &str) -> bool

pub fn set_require_context(&mut self, require: bool)

开关「上下文强制」（默认关闭 = fail-open，保持 JS parity）。 开启后：plan 入口遇 ctx: None 报 ERR_NO_CONTEXT（fail-secure）。 内部调用须显式传系统上下文（{"internal": true}）。

pub fn require_context(&self) -> bool

「上下文强制」开关当前值

pub fn get_by_location( &self, source: &str, namespace: Option<&str>, collection: &str, ) -> Result<&Schema, String>

按定位三元组精确获取 schema（命令路由的唯一定位入口）

(source, namespace, collection) 三元组在 Registry 内唯一（注册期校验）， 故此处零候选 = 未注册；一候选 = 精确命中。不做任何猜测回落。

pub fn get_for_command( &self, source: &str, namespace: Option<&str>, collection: &str, ) -> Result<&Schema, String>

命令结构定位（方言翻译用）：优先三元组精确命中；未命中时（route_override 改写 namespace 的多租户场景）回落 (source, collection) 定位 —— 结构 schema 与定位 namespace 正交（见 multi-datasource-routing-plan.md §6：权限/字段 校验仍按结构 schema）。

(source, collection) 恰一候选 → 命中；多候选时取 namespace = null 的 结构声明，无 null 声明 → 报错（拒绝猜测，铁律 3）。

pub fn list(&self) -> Vec<String>

pub fn schema_datasource(&self, name: &str) -> Result<Option<String>, String>

schema 声明的数据源名（未声明 → None，语义为 default）

pub fn resolve_datasource( &self, schema_name: &str, config: &Value, ) -> Result<DataSource, String>

解析 schema 绑定的数据源（config 为 { "sources": { name: kind } }）

纯逻辑：不持有连接（连接句柄留在 Host）。null / 空配置下等价单源 Mongo， 保证既有调用方与 parity fixture 零变更。见 crate::datasource。

Trait Implementations

impl Clone for Registry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Registry

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

Formats the value using the given formatter.

impl Default for Registry

fn default() -> Self

Returns the “default value” for a type.