From 516958577499727f8aa071f1fd335e83d6486649 Mon Sep 17 00:00:00 2001 From: Till Faelligen Date: Mon, 12 Oct 2020 07:19:32 +0200 Subject: [PATCH] Fix upsert statement --- roomserver/storage/sqlite3/receipt_table.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/roomserver/storage/sqlite3/receipt_table.go b/roomserver/storage/sqlite3/receipt_table.go index 8a088f29e..73108273f 100644 --- a/roomserver/storage/sqlite3/receipt_table.go +++ b/roomserver/storage/sqlite3/receipt_table.go @@ -36,18 +36,18 @@ CREATE TABLE IF NOT EXISTS roomserver_receipts ( event_id TEXT NOT NULL, receipt_ts BIGINT NOT NULL, - CONSTRAINT roomserver_receipts_unique UNIQUE (room_id, receipt_type, user_id, event_id) + CONSTRAINT roomserver_receipts_unique UNIQUE (room_id, receipt_type, user_id) ); -CREATE INDEX IF NOT EXISTS roomserver_receipts_user_id ON roomserver_receipts(user_id); +CREATE INDEX IF NOT EXISTS roomserver_receipts_user_id ON roomserver_receipts(room_id); ` const upsertReceipt = "" + "INSERT INTO roomserver_receipts" + " (room_id, receipt_type, user_id, event_id, receipt_ts)" + " VALUES ($1, $2, $3, $4, $5)" + - " ON CONFLICT (room_id, receipt_type, user_id, event_id)" + - " DO UPDATE SET receipt_ts = $5" + " ON CONFLICT (room_id, receipt_type, user_id)" + + " DO UPDATE SET event_id = $4, receipt_ts = $5" type receiptStatements struct { db *sql.DB