From 88685be9d2f8383dfe6d507204c16276c4570337 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Fri, 11 Dec 2020 12:59:41 +0000 Subject: [PATCH] Reset sequences --- syncapi/storage/postgres/deltas/20201211125500_sequences.go | 1 + syncapi/storage/sqlite3/deltas/20201211125500_sequences.go | 1 + 2 files changed, 2 insertions(+) diff --git a/syncapi/storage/postgres/deltas/20201211125500_sequences.go b/syncapi/storage/postgres/deltas/20201211125500_sequences.go index 013ddca7c..a51df26f3 100644 --- a/syncapi/storage/postgres/deltas/20201211125500_sequences.go +++ b/syncapi/storage/postgres/deltas/20201211125500_sequences.go @@ -39,6 +39,7 @@ func UpFixSequences(tx *sql.Tx) error { -- Use the new syncapi_receipts_id sequence. CREATE SEQUENCE IF NOT EXISTS syncapi_receipt_id; + ALTER SEQUENCE IF EXISTS syncapi_receipt_id RESTART WITH 1; ALTER TABLE syncapi_receipts ALTER COLUMN id SET DEFAULT nextval('syncapi_receipt_id'); `) if err != nil { diff --git a/syncapi/storage/sqlite3/deltas/20201211125500_sequences.go b/syncapi/storage/sqlite3/deltas/20201211125500_sequences.go index 7211d96f4..649050135 100644 --- a/syncapi/storage/sqlite3/deltas/20201211125500_sequences.go +++ b/syncapi/storage/sqlite3/deltas/20201211125500_sequences.go @@ -36,6 +36,7 @@ func UpFixSequences(tx *sql.Tx) error { -- will be wrong, and we'll get primary key violations if we try to -- reuse existing stream IDs from a different sequence. DELETE FROM syncapi_receipts; + UPDATE syncapi_stream_id SET stream_id=1 WHERE stream_name="receipt"; `) if err != nil { return fmt.Errorf("failed to execute upgrade: %w", err)