Skip to main content

UPSERT_WAITPOINT_PENDING_ACTIVE_SQL

Constant UPSERT_WAITPOINT_PENDING_ACTIVE_SQL 

Source
pub const UPSERT_WAITPOINT_PENDING_ACTIVE_SQL: &str = "INSERT INTO ff_waitpoint_pending \
     (partition_key, waitpoint_id, execution_id, token_kid, token, \
      created_at_ms, expires_at_ms, waitpoint_key, \
      state, required_signal_names, activated_at_ms) \
     VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8, 'active', ?9, ?6) \
     ON CONFLICT (partition_key, waitpoint_id) DO UPDATE SET \
       token_kid = excluded.token_kid, token = excluded.token, \
       waitpoint_key = excluded.waitpoint_key, \
       state = excluded.state, \
       required_signal_names = excluded.required_signal_names, \
       activated_at_ms = excluded.activated_at_ms";
Expand description

Insert-or-overwrite a waitpoint row. required_signal_names goes in as a JSON-encoded TEXT column (SQLite has no native text[]). Binds: 1=partition_key, 2=waitpoint_id, 3=execution_id, 4=token_kid, 5=token, 6=created_at_ms, 7=expires_at_ms, 8=waitpoint_key, 9=required_signal_names_json.