dbstore: rename Tx to Begin, add Tx which accepts callback and handles commit/rollback

1 files changed, 5 insertions, 5 deletions

diff --git a/dbstore/tx_test.go b/dbstore/tx_test.go
index df15f9e..0e3ed23 100644
--- a/dbstore/tx_test.go
+++ b/dbstore/tx_test.go
@@ -33,13 +33,13 @@ func TestNewTxDupTx(t *testing.T) {
   }
 
   // create first transaction
-  if _, err = db.Tx(ctx, []string{}); err != nil {
+  if _, err = db.Begin(ctx, []string{}); err != nil {
     t.Error(err)
     return
   }
 
   // create second transaction
-  got, err := db.Tx(ctx, []string{})
+  got, err := db.Begin(ctx, []string{})
   if err != nil { // FIXME
     t.Errorf("got %v, exp error", got)
     return
@@ -72,7 +72,7 @@ func TestNewTxBadQueries(t *testing.T) {
   }
 
   // create first transaction
-  if got, err := db.Tx(ctx, badQueryIds); err == nil {
+  if got, err := db.Begin(ctx, badQueryIds); err == nil {
     t.Errorf("got %v, exp error", got)
     return
   }
@@ -96,7 +96,7 @@ func TestNewTxPrepareFail(t *testing.T) {
   }
 
   // create transaction
-  if got, err := db.Tx(ctx, []string { "test/junk" }); err == nil {
+  if got, err := db.Begin(ctx, []string { "test/junk" }); err == nil {
     t.Errorf("got %v, exp error", got)
   }
 }
@@ -125,7 +125,7 @@ func TestTxExecFail(t *testing.T) {
   }
 
   // create transaction
-  tx, err := db.Tx(ctx, []string { "init" })
+  tx, err := db.Begin(ctx, []string { "init" })
   if err != nil {
     t.Error(err)
     return