diff options
Diffstat (limited to 'roomserver/storage/sqlite3/published_table.go')
| -rw-r--r-- | roomserver/storage/sqlite3/published_table.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/roomserver/storage/sqlite3/published_table.go b/roomserver/storage/sqlite3/published_table.go index 96575241..85f1e0a4 100644 --- a/roomserver/storage/sqlite3/published_table.go +++ b/roomserver/storage/sqlite3/published_table.go @@ -71,7 +71,8 @@ func (s *publishedStatements) UpsertRoomPublished( ctx context.Context, roomID string, published bool, ) (err error) { return s.writer.Do(s.db, nil, func(txn *sql.Tx) error { - _, err := s.upsertPublishedStmt.ExecContext(ctx, roomID, published) + stmt := sqlutil.TxStmt(txn, s.upsertPublishedStmt) + _, err := stmt.ExecContext(ctx, roomID, published) return err }) } |