Compare commits

..

2 Commits

Author SHA1 Message Date
ad4963e5a0
(temp): fix extract entries query
Some checks failed
release / docker (push) Has been cancelled
2025-03-24 12:23:53 +03:00
fbd5f28d54
(temp): fix missing ID scan
Some checks failed
release / docker (push) Has been cancelled
2025-03-24 12:21:00 +03:00
2 changed files with 6 additions and 3 deletions

View File

@ -74,7 +74,7 @@ func (s *Syncer) Process(ctx context.Context) error {
kvRows, err := pgx.CollectRows(rows, func(row pgx.CollectableRow) (KVRow, error) {
var kvRow KVRow
err := row.Scan(&kvRow.Key, &kvRow.Value, &kvRow.Updated)
err := row.Scan(&kvRow.ID, &kvRow.Key, &kvRow.Value, &kvRow.Updated)
return kvRow, err
})
if err != nil {

View File

@ -1,8 +1,11 @@
--name: extract-entries
SELECT key, value, updated FROM kv_vise
SELECT id, key, value, updated FROM kv_vise
WHERE updated > (SELECT last_sync FROM ussd_sync LIMIT 1)
ORDER BY updated DESC
--name: update-cursor
-- $1: timestamp
UPDATE ussd_sync SET last_sync = ($1)
UPDATE ussd_sync SET last_sync = ($1)
-- 202b3235343732343934323039370013
-- 202b3235343731313030303132330013