22 lines
780 B
SQL
22 lines
780 B
SQL
CREATE TABLE IF NOT EXISTS execution_facts (
|
|
fact_id TEXT PRIMARY KEY,
|
|
tenant_id TEXT NOT NULL,
|
|
tenant_key TEXT NOT NULL,
|
|
execution_id TEXT NOT NULL,
|
|
content_sha256 TEXT NOT NULL,
|
|
kind INTEGER NOT NULL,
|
|
binding_json BLOB NOT NULL,
|
|
payload_json BLOB NOT NULL,
|
|
observed_at TEXT NOT NULL,
|
|
source_boot_id TEXT NOT NULL,
|
|
source_sequence INTEGER NOT NULL,
|
|
event_id TEXT NOT NULL,
|
|
event_type TEXT NOT NULL,
|
|
aggregate_type TEXT NOT NULL,
|
|
aggregate_id TEXT NOT NULL,
|
|
aggregate_version INTEGER NOT NULL,
|
|
received_at TEXT NOT NULL
|
|
);
|
|
CREATE INDEX IF NOT EXISTS execution_facts_execution_idx ON execution_facts (execution_id, observed_at);
|
|
CREATE INDEX IF NOT EXISTS execution_facts_event_idx ON execution_facts (event_id);
|