Function test_existing_schema_detection

tests/migration_test.rs:82–139

()

#[test]
fn test_existing_schema_detection() {
    let temp_dir = TempDir::new().unwrap();
    let db_path = temp_dir.path().join("test.db");
    
    // Create a database with the old schema (pre-migration)
    let conn = Connection::open(&db_path).unwrap();
    conn.execute(
        "CREATE TABLE __pgsqlite_schema (
            table_name TEXT NOT NULL,
            column_name TEXT NOT NULL,
            pg_type TEXT NOT NULL,
            sqlite_type TEXT NOT NULL,
            PRIMARY KEY (table_name, column_name)
        )",
        []
    ).unwrap();
    drop(conn);
    
    // Check should fail on pre-migration database
    let conn = Connection::open(&db_path).unwrap();
    let runner = MigrationRunner::new(conn);
    let check_result = runner.check_schema_version();
    assert!(check_result.is_err());
    assert!(check_result.unwrap_err().to_string().contains("Database schema is outdated"));
    
    // Run migrations
    let conn = runner.into_connection();
    let mut runner = MigrationRunner::new(conn);
    let applied = runner.run_pending_migrations().unwrap();
    
    // Should recognize existing schema as version 1 and only apply versions 2-27
    assert_eq!(applied.len(), 26);
    assert_eq!(applied[0], 2);
    assert_eq!(applied[1], 3);
    assert_eq!(applied[2], 4);
    assert_eq!(applied[3], 5);
    assert_eq!(applied[4], 6);
    assert_eq!(applied[5], 7);
    assert_eq!(applied[6], 8);
    assert_eq!(applied[7], 9);
    assert_eq!(applied[8], 10);
    assert_eq!(applied[9], 11);
    assert_eq!(applied[10], 12);
    assert_eq!(applied[25], 27);
    
    // Verify final version
    let conn = runner.into_connection();
    let version: String = conn.query_row(
        "SELECT value FROM __pgsqlite_metadata WHERE key = 'schema_version'",
        [],
        |row| row.get(0)
    ).unwrap();
    assert_eq!(version, "27");
    
    // Now check should pass
    let runner2 = MigrationRunner::new(conn);
    assert!(runner2.check_schema_version().is_ok());
}