Revert "Test double transact"

This reverts commit 2e928284b3f931e3e293781878df594b40db711f.
This commit is contained in:
Kegan Dougal 2023-07-12 17:58:11 +01:00
parent 2e928284b3
commit 0fa136f32d

View File

@ -75,8 +75,7 @@ func (s *SnapshotTable) Insert(txn *sqlx.Tx, row *SnapshotRow) error {
if row.OtherEvents == nil {
row.OtherEvents = []int64{}
}
// OH NO, NOT USING THE TXN!
err := s.db.QueryRow(
err := txn.QueryRow(
`INSERT INTO syncv3_snapshots(room_id, events, membership_events) VALUES($1, $2, $3) RETURNING snapshot_id`,
row.RoomID, row.OtherEvents, row.MembershipEvents,
).Scan(&id)