diff options
Diffstat (limited to 'roomserver/storage/sqlite3/transactions_table.go')
| -rw-r--r-- | roomserver/storage/sqlite3/transactions_table.go | 20 |
1 files changed, 8 insertions, 12 deletions
diff --git a/roomserver/storage/sqlite3/transactions_table.go b/roomserver/storage/sqlite3/transactions_table.go index 65c18a8a..029122c5 100644 --- a/roomserver/storage/sqlite3/transactions_table.go +++ b/roomserver/storage/sqlite3/transactions_table.go @@ -45,15 +45,13 @@ const selectTransactionEventIDSQL = ` type transactionStatements struct { db *sql.DB - writer *sqlutil.TransactionWriter insertTransactionStmt *sql.Stmt selectTransactionEventIDStmt *sql.Stmt } -func NewSqliteTransactionsTable(db *sql.DB, writer *sqlutil.TransactionWriter) (tables.Transactions, error) { +func NewSqliteTransactionsTable(db *sql.DB) (tables.Transactions, error) { s := &transactionStatements{ - db: db, - writer: writer, + db: db, } _, err := db.Exec(transactionsSchema) if err != nil { @@ -72,14 +70,12 @@ func (s *transactionStatements) InsertTransaction( sessionID int64, userID string, eventID string, -) (err error) { - return s.writer.Do(s.db, txn, func(txn *sql.Tx) error { - stmt := sqlutil.TxStmt(txn, s.insertTransactionStmt) - _, err := stmt.ExecContext( - ctx, transactionID, sessionID, userID, eventID, - ) - return err - }) +) error { + stmt := sqlutil.TxStmt(txn, s.insertTransactionStmt) + _, err := stmt.ExecContext( + ctx, transactionID, sessionID, userID, eventID, + ) + return err } func (s *transactionStatements) SelectTransactionEventID( |