uqa-storage-sqlite 0.3.8

SQLite catalog, indexes, compressed storage, graph and key/value providers
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Catalog: schema versioning, migrations, and persisted table metadata.
//!
//! The catalog owns a single `_metadata` table that records the schema version
//! plus a `_tables` table holding per-table analyzer config and the lists
//! of FTS / vector fields registered on each table. Concrete data tables
//! (`_documents`, `_document_blobs`, `_posting_clusters`,
//! `_posting_documents`, `_vectors`, ...) are created by catalog migrations
//! before their respective stores are exposed.

use rusqlite::{params, OptionalExtension};

use crate::connection::{ManagedConnection, Result, SQLiteError};
use uqa_storage::backend::{StorageBackendError, StorageBackendResult};
use uqa_storage::catalog::{
    CatalogFacade, CatalogIndexRow, ColumnStatsInput, ColumnStatsRow, EdgeRow, ForeignTableRow,
    GraphSnapshot, RelationIdentity, RelationKind, SchemaRow, SequenceOptions,
    SequenceReservationResult, SequenceRow, TableAclEntry, TableSchema, VectorFieldSchema, ViewRow,
};

use super::catalog_lifecycle::{
    columns_json_references, delete_table_rows_if_exists, drop_fts_aux_tables_for_field,
    drop_fts_aux_tables_for_table, quote_sql_identifier, rename_btree_field_rows_or_keep_existing,
    rename_field_rows_or_keep_existing, rename_fts_aux_tables_for_field, renamed_columns_json,
    table_exists, update_btree_table_name_rows_if_exists, update_table_name_rows_if_exists,
};

/// Bump this every time a migration is added.
pub const CURRENT_SCHEMA_VERSION: u32 = 48;

const LEGACY_VIEWS_METADATA_KEY: &str = "sql_views_json";
const LEGACY_SEQUENCES_METADATA_KEY: &str = "sql_sequences_json";

pub struct Catalog {
    conn: ManagedConnection,
}

mod analyzers;
mod cache_revisions;
mod facade;
mod foreign_indexes;
mod graph;
mod graph_access;
mod migration;
mod models_scoring;
mod path_index_data;
mod schema_tables;
mod sequences_views;
mod stats;

use migration::{decode_catalog_id, encode_catalog_id, migration_relation};

#[cfg(test)]
mod tests;