Test double transact

This commit is contained in:
Kegan Dougal 2023-07-12 17:53:11 +01:00
parent ea805f7a1c
commit 2e928284b3

View File

@ -75,7 +75,8 @@ func (s *SnapshotTable) Insert(txn *sqlx.Tx, row *SnapshotRow) error {
if row.OtherEvents == nil {
row.OtherEvents = []int64{}
}
err := txn.QueryRow(
// OH NO, NOT USING THE TXN!
err := s.db.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)