Skip to main content

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        M::up(include_str!("migrations/006_activity_tokens.sql")),
13        M::up(include_str!("migrations/007_fix_fts_update_trigger.sql")),
14    ])
15}
16
17pub const SCHEMA_VERSION: i64 = 7;
18
19pub fn check_version(conn: &rusqlite::Connection) -> crate::Result<()> {
20    let current: i64 = conn.pragma_query_value(None, "user_version", |r| r.get(0))?;
21    if current > SCHEMA_VERSION {
22        return Err(Error::SchemaVersionTooNew {
23            found: current,
24            supported: SCHEMA_VERSION,
25        });
26    }
27    Ok(())
28}