summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarkus Grüneis <gimpf@gimpf.org>2014-10-25 14:10:21 +0200
committerMarkus Grüneis <gimpf@gimpf.org>2014-10-25 14:10:21 +0200
commitb150ad00ba56e9a467f42d7c8abd5a188804663e (patch)
tree54496e41b3942d797fdeaf18a2ab7dfd85170cae
parenthub: fix MySQLDialect initialization (diff)
hub: Fix missing abort transaction.
-rw-r--r--src/hub/src/spreadspace.org/sfive/s5store.go3
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
}
}