Query
CREATE TABLE stream_cursors (
stream TEXT NOT NULL DEFAULT 'events',
reducer TEXT NOT NULL,
cursor INTEGER NOT NULL,
updated_at TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%fZ','now')),
PRIMARY KEY (stream, reducer)
)
CREATE TABLE stream_cursors (
stream TEXT NOT NULL DEFAULT 'events',
reducer TEXT NOT NULL,
cursor INTEGER NOT NULL,
updated_at TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%fZ','now')),
PRIMARY KEY (stream, reducer)
)