aboutsummaryrefslogtreecommitdiff
path: root/roomserver/storage/sqlite3/state_snapshot_table.go
diff options
context:
space:
mode:
Diffstat (limited to 'roomserver/storage/sqlite3/state_snapshot_table.go')
-rw-r--r--roomserver/storage/sqlite3/state_snapshot_table.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/roomserver/storage/sqlite3/state_snapshot_table.go b/roomserver/storage/sqlite3/state_snapshot_table.go
index 01df31e9..1f5e9ee3 100644
--- a/roomserver/storage/sqlite3/state_snapshot_table.go
+++ b/roomserver/storage/sqlite3/state_snapshot_table.go
@@ -113,11 +113,12 @@ func (s *stateSnapshotStatements) BulkSelectStateBlockNIDs(
nids[k] = v
}
selectOrig := strings.Replace(bulkSelectStateBlockNIDsSQL, "($1)", sqlutil.QueryVariadic(len(nids)), 1)
- selectStmt, err := s.db.Prepare(selectOrig)
+ selectPrep, err := s.db.Prepare(selectOrig)
if err != nil {
return nil, err
}
- selectStmt = sqlutil.TxStmt(txn, selectStmt)
+ defer selectPrep.Close() // nolint:errcheck
+ selectStmt := sqlutil.TxStmt(txn, selectPrep)
rows, err := selectStmt.QueryContext(ctx, nids...)
if err != nil {