From 50e9c625be7fd38feae084b1eb55207ac88fe019 Mon Sep 17 00:00:00 2001 From: thomashamburg Date: Wed, 29 Oct 2025 12:14:07 +0100 Subject: [PATCH] result in db transactions added --- mvwa/sqlite/database.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/mvwa/sqlite/database.go b/mvwa/sqlite/database.go index c3943a7..76acd55 100644 --- a/mvwa/sqlite/database.go +++ b/mvwa/sqlite/database.go @@ -21,6 +21,7 @@ type Database struct { type Transaction struct { tx *sql.Tx + res Record err error } @@ -287,7 +288,8 @@ func (d *Database) UserVersion() (int64, error) { func (d *Database) Begin() *Transaction { tx, err := d.database.Begin() - return &Transaction{tx, err} + res := Record{} + return &Transaction{tx, res, err} } func (t *Transaction) Next(action Action) *Transaction { @@ -298,17 +300,17 @@ func (t *Transaction) Next(action Action) *Transaction { return t } -func (t *Transaction) End() error { +func (t *Transaction) End() (Record, error) { if t.err != nil { err := t.tx.Rollback() if err != nil { t.err = errors.Join(t.err, err) } - return t.err + return t.res, t.err } t.err = t.tx.Commit() - return t.err + return t.res, t.err } func (t *Transaction) GetRecord(tablename string, idfield string, key any, output Record) *Transaction {