diff options
| author | Markus Grüneis <gimpf@gimpf.org> | 2014-10-25 14:10:21 +0200 |
|---|---|---|
| committer | Markus Grüneis <gimpf@gimpf.org> | 2014-10-25 14:10:21 +0200 |
| commit | b150ad00ba56e9a467f42d7c8abd5a188804663e (patch) | |
| tree | 54496e41b3942d797fdeaf18a2ab7dfd85170cae | |
| parent | hub: fix MySQLDialect initialization (diff) | |
hub: Fix missing abort transaction.
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5store.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5store.go b/src/hub/src/spreadspace.org/sfive/s5store.go index a79325d..e8f63d3 100644 --- a/src/hub/src/spreadspace.org/sfive/s5store.go +++ b/src/hub/src/spreadspace.org/sfive/s5store.go @@ -9,7 +9,6 @@ import ( "github.com/coopernurse/gorp" _ "github.com/go-sql-driver/mysql" _ "github.com/mattn/go-sqlite3" - _ "github.com/ziutek/mymysql/godrv" ) type sqliteStore struct { @@ -328,6 +327,7 @@ func (s sqliteStore) Append(update StatisticsData) (err error) { du, cd, src, tags := updateFromStatisticsData(update) err = s.appendItem(du, cd, src, tags) if err != nil { + tx.Rollback() return } @@ -344,6 +344,7 @@ func (s sqliteStore) AppendMany(updates []StatisticsData) (err error) { du, cd, src, tags := updateFromStatisticsData(update) err = s.appendItem(du, cd, src, tags) if err != nil { + tx.Rollback() return } } |