diff options
Diffstat (limited to 'federationsender/storage/postgres/room_table.go')
| -rw-r--r-- | federationsender/storage/postgres/room_table.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/federationsender/storage/postgres/room_table.go b/federationsender/storage/postgres/room_table.go index a64424b4..c945475b 100644 --- a/federationsender/storage/postgres/room_table.go +++ b/federationsender/storage/postgres/room_table.go @@ -19,7 +19,7 @@ import ( "context" "database/sql" - "github.com/matrix-org/dendrite/common" + "github.com/matrix-org/dendrite/internal" ) const roomSchema = ` @@ -71,7 +71,7 @@ func (s *roomStatements) prepare(db *sql.DB) (err error) { func (s *roomStatements) insertRoom( ctx context.Context, txn *sql.Tx, roomID string, ) error { - _, err := common.TxStmt(txn, s.insertRoomStmt).ExecContext(ctx, roomID) + _, err := internal.TxStmt(txn, s.insertRoomStmt).ExecContext(ctx, roomID) return err } @@ -82,7 +82,7 @@ func (s *roomStatements) selectRoomForUpdate( ctx context.Context, txn *sql.Tx, roomID string, ) (string, error) { var lastEventID string - stmt := common.TxStmt(txn, s.selectRoomForUpdateStmt) + stmt := internal.TxStmt(txn, s.selectRoomForUpdateStmt) err := stmt.QueryRowContext(ctx, roomID).Scan(&lastEventID) if err != nil { return "", err @@ -95,7 +95,7 @@ func (s *roomStatements) selectRoomForUpdate( func (s *roomStatements) updateRoom( ctx context.Context, txn *sql.Tx, roomID, lastEventID string, ) error { - stmt := common.TxStmt(txn, s.updateRoomStmt) + stmt := internal.TxStmt(txn, s.updateRoomStmt) _, err := stmt.ExecContext(ctx, roomID, lastEventID) return err } |