durable_workflow_sqlite #

Korean README

SQLite implementation of CheckpointStore for the durable_workflow library. Uses sqlite3 FFI for high-performance local persistence.

Features #

• SQLite3 FFI -- direct native access via package:sqlite3, no platform channels
• WAL journal mode -- concurrent reads and writes for optimal performance
• Automatic schema migration -- PRAGMA user_version based versioning
• ACID transactions -- all writes use BEGIN IMMEDIATE for consistency
• File and in-memory modes -- file-based for production, in-memory for testing

Getting Started #

import 'package:durable_workflow/durable_workflow.dart';
import 'package:durable_workflow_sqlite/durable_workflow_sqlite.dart';

// File-based (production)
final store = SqliteCheckpointStore.file('workflows.db');
final engine = DurableEngineImpl(store: store);

final result = await engine.run<String>('my_workflow', (ctx) async {
  return await ctx.step('greet', () async => 'Hello!');
});

engine.dispose();
store.close();

// In-memory (testing)
final store = SqliteCheckpointStore.inMemory();

Installation #

Add to your pubspec.yaml:

dependencies:
  durable_workflow: ^0.1.0
  durable_workflow_sqlite: ^0.1.0

SQLite Schema #

5 tables with 5 indexes:

PRAGMA Configuration #

PRAGMA journal_mode = WAL;       -- Read/write concurrency
PRAGMA foreign_keys = ON;        -- Referential integrity
PRAGMA synchronous = NORMAL;     -- Write performance (safe with WAL)
PRAGMA busy_timeout = 5000;      -- 5s retry wait for concurrent access

API #

SqliteCheckpointStore #

All CheckpointStore interface methods are implemented:

• saveCheckpoint / loadCheckpoints -- step checkpoint persistence
• saveExecution / loadExecution / loadExecutionsByStatus -- execution state
• saveTimer / loadPendingTimers -- durable timer persistence
• saveSignal / loadPendingSignals -- signal persistence

Schema Utilities #

Tests #

SQLite store tests: 59 ✅

Covers CRUD operations, PRAGMA verification, schema migration, foreign key constraints, and edge cases.

License #

See the repository root for license information.