From 4198adfab824a06b206824618e083f033e8cdd2a Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Mon, 19 Apr 2021 14:49:18 +0100 Subject: [PATCH] Print number of events --- .../postgres/deltas/20210416150927_state_blocks_refactor.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go b/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go index cc1b27d9..27b85e77 100644 --- a/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go +++ b/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go @@ -58,7 +58,7 @@ func UpStateBlocksRefactor(tx *sql.Tx) error { _, err = tx.Exec(` CREATE SEQUENCE IF NOT EXISTS roomserver_state_snapshot_nid_seq; CREATE TABLE IF NOT EXISTS roomserver_state_snapshots ( - state_snapshot_nid bigint PRIMARY KEY DEFAULT nextval('roomserver_state_snapshot_nid_seq'), + state_snapshot_nid bigserial PRIMARY KEY, room_nid bigint NOT NULL, state_block_nids bigint[] NOT NULL, UNIQUE (room_nid, state_block_nids) @@ -152,7 +152,7 @@ func UpStateBlocksRefactor(tx *sql.Tx) error { RETURNING state_block_nid `, eventsarray).Scan(&blocknid) if err != nil { - return fmt.Errorf("tx.QueryRow.Scan (insert new block): %w", err) + return fmt.Errorf("tx.QueryRow.Scan (insert new block with %d events): %w", len(eventsarray), err) } newblocks = append(newblocks, blocknid)