memory_core/store/
schema.rs

1use rusqlite_migration::{M, Migrations};
2
3use crate::Error;
4
5pub fn migrations() -> Migrations<'static> {
6    Migrations::new(vec![
7        M::up(include_str!("migrations/001_initial.sql")),
8        M::up(include_str!("migrations/002_metrics.sql")),
9        M::up(include_str!("migrations/003_relations.sql")),
10        M::up(include_str!("migrations/004_cascade_fks.sql")),
11        M::up(include_str!("migrations/005_cleanup_orphans.sql")),
12    ])
13}
14
15pub const SCHEMA_VERSION: i64 = 5;
16
17pub fn check_version(conn: &rusqlite::Connection) -> crate::Result<()> {
18    let current: i64 = conn.pragma_query_value(None, "user_version", |r| r.get(0))?;
19    if current > SCHEMA_VERSION {
20        return Err(Error::SchemaVersionTooNew {
21            found: current,
22            supported: SCHEMA_VERSION,
23        });
24    }
25    Ok(())
26}
memory_core/store/schema.rs

memory_core/store/
schema.rs
