internal/syncer/syncer.go

@@ -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.ID, &kvRow.Key, &kvRow.Value, &kvRow.Updated)
+			err := row.Scan(&kvRow.Key, &kvRow.Value, &kvRow.Updated)
 			return kvRow, err
 		})
 		if err != nil {

queries.sql

@@ -1,11 +1,8 @@
 --name: extract-entries
-SELECT id, key, value, updated FROM kv_vise
+SELECT 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)
-
--- 202b3235343732343934323039370013
--- 202b3235343731313030303132330013
+UPDATE ussd_sync SET last_sync = ($1)