Struct CatalogSnapshotBuilder 

pub struct CatalogSnapshotBuilder { /* private fields */ }

Stable, offline builder for Oracle dictionary rows.

The builder accepts already-fetched OracleRow values and applies the same normalization used by the live loader. It performs no network or database I/O; callers such as oraclemcp own extraction and feed rows into this crate through CatalogRowSet.

use chrono::Utc;
use plsql_catalog::{
    CatalogCapabilities, CatalogRowSet, CatalogSnapshotBuilder, CatalogSource,
    CatalogSourceKind, ObjectType, OracleRow,
};
use plsql_core::AnalysisProfile;

fn row(columns: &[(&str, &str, Option<&str>)]) -> OracleRow {
    let mut row = OracleRow::default();
    for (name, oracle_type, value) in columns {
        row.insert(*name, *oracle_type, value.map(String::from));
    }
    row
}

let mut builder = CatalogSnapshotBuilder::new(
    AnalysisProfile::default(),
    CatalogCapabilities::default(),
    CatalogSource {
        kind: CatalogSourceKind::LiveConnection,
        description: Some("synthetic rows from an external extractor".to_string()),
        ..CatalogSource::default()
    },
    Utc::now(),
);

builder.apply_row(
    CatalogRowSet::Objects,
    &row(&[
        ("OWNER", "VARCHAR2(128)", Some("BILLING")),
        ("OBJECT_NAME", "VARCHAR2(128)", Some("INVOICES")),
        ("OBJECT_TYPE", "VARCHAR2(30)", Some("TABLE")),
        ("STATUS", "VARCHAR2(7)", Some("VALID")),
    ]),
)?;

let snapshot = builder.finish()?;
let report = snapshot.doctor_report();
assert_eq!(report.totals.schemas_observed, 1);
assert_eq!(
    report.object_counts.first().map(|count| count.object_type),
    Some(ObjectType::Table),
);

Implementations

impl CatalogSnapshotBuilder

pub fn new( profile: AnalysisProfile, capabilities: CatalogCapabilities, source: CatalogSource, generated_at: DateTime<Utc>, ) -> Self

pub fn from_snapshot(snapshot: CatalogSnapshot) -> Self

pub fn snapshot(&self) -> &CatalogSnapshot

pub fn snapshot_mut(&mut self) -> &mut CatalogSnapshot

pub fn apply_row( &mut self, row_set: CatalogRowSet, row: &OracleRow, ) -> Result<&mut Self, CatalogError>

pub fn apply_rows<'a, I>( &mut self, row_set: CatalogRowSet, rows: I, ) -> Result<&mut Self, CatalogError>

where I: IntoIterator<Item = &'a OracleRow>,

pub fn finish(self) -> Result<CatalogSnapshot, CatalogError>

Trait Implementations

impl Default for CatalogSnapshotBuilder

fn default() -> Self

Returns the “default value” for a type.