Function memtable_flush_remaps_pk

nodedb-columnar/src/mutation/tests.rs:118–148

()

#[test]
fn memtable_flush_remaps_pk() {
    let mut engine = MutationEngine::new("test".into(), test_schema());

    for i in 0..5 {
        engine
            .insert(&[
                Value::Integer(i),
                Value::String(format!("u{i}")),
                Value::Null,
            ])
            .expect("insert");
    }

    // Simulate flush: memtable becomes segment 1.
    let result = engine.on_memtable_flushed(1).expect("flush");
    assert_eq!(result.wal_records.len(), 1);
    assert!(matches!(
        &result.wal_records[0],
        ColumnarWalRecord::MemtableFlushed {
            segment_id: 1,
            row_count: 5,
            ..
        }
    ));

    // PK index entries should now point to segment 1.
    let pk = encode_pk(&Value::Integer(3));
    let loc = engine.pk_index().get(&pk).expect("pk exists");
    assert_eq!(loc.segment_id, 1);
    assert_eq!(loc.row_index, 3);
}

#[test]
fn multiple_inserts_and_deletes() {