transaction-correctness
How WAL mechanics, checkpointing, concurrency rules, recovery work in tursodb
By tursodatabase · 1,150 installs
npx skills add tursodatabase/turso --skill transaction-correctness
Source repository · Upstream listing
Transaction Correctness Guide
Turso uses WAL (Write Ahead Logging) mode exclusively.
Files: .db , .db wal (no .db shm Turso uses in memory WAL index)
WAL Mechanics
Write Path
1. Writer appends frames (page data) to WAL file (sequential I/O)
2. COMMIT = frame with non zero db size in header (marks transaction end)
3. Original DB unchanged until checkpoint
Read Path
1. Reader acquires read mark (mxFrame = last valid commit frame)
2. For each page: check WAL up to mxFrame, fall back to main DB
3. Reader sees consistent snapshot at its read mark
Checkpointing
Transfers WAL content back to main DB.
Checkpoint types:
PASSIVE : Non blocking, stops at pages needed by active readers
FULL : Waits for readers, checkpoints everything
RESTART : Like FULL, also resets WAL to beginning
TRUNCATE : Like RESTART, also truncates WAL file to zero length
WAL Index
SQLite uses a shared memory file ( shm ) for WAL index. Turso does not it uses in memory data structures ( frame cache hashmap, atomic read marks) since multi process access is not supported.
Concurrency Rules
One writer at a time
Readers don't block writer, writer doesn't block readers
Checkpoint must stop at pages needed by active readers
Recovery
On crash:
1. First connection acquires exclusive lock
2. Replays valid commits from WAL
3. Releases lock, normal operation resumes
Turso Implementation
Key files:
[WAL implementation](../../../core/storage/wal.rs) WAL implementation
[Page management, transactions](../../../core/storage/pager.rs)
Connection Private vs Shared
Per Connection (private):
Pager page cache, dirty pages, savepoints, commit state
WalFile connection's snapshot view:
max frame / min frame frame range for this connection's snapshot
max frame read lock index which read lock slot this connection holds
last checksum rolling checksum state
Shared across connections:
WalFileShared global WAL state:
frame cache page to frame index (replaces .shm file)
max frame / nbackfills global WAL progress
read locks[5] read mark slots (TursoRwLock with embedded frame values)
write lock exclusive writer lock
checkpoint lock checkpoint serialization
file WAL file handle
DatabaseStorage main .db file
BufferPool shared memory allocation
Correctness Invariants
1. Durability : COMMIT record must be fsynced before returning success
2. Atomicity : Partial transactions never visible to readers
3. Isolation : Each reader sees consistent snapshot
4. No lost updates : Checkpoint can't overwrite uncommitted changes
References
[SQLite WAL](https://sqlite.org/wal.html)
[WAL File Format](https://sqlite.org/walformat.html)