mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-23 14:53:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix upsert statement

Browse source
This commit is contained in:
Till Faelligen 2020-10-12 07:19:32 +02:00
parent 75010468a5
commit 5169585774
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
roomserver/storage/sqlite3/receipt_table.go
View file

@ -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