Adding missing calls to tx.Close().

mysql/benchmark_test.go

@@ -324,6 +324,7 @@ func BenchmarkUpperAppendTransaction(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -366,6 +367,7 @@ func BenchmarkUpperAppendTransactionWithMap(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -766,6 +768,8 @@ func BenchmarkUpperCommitManyTransactions(b *testing.B) {
 		if err = tx.Commit(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }
 
@@ -808,5 +812,7 @@ func BenchmarkUpperRollbackManyTransactions(b *testing.B) {
 		if err = tx.Rollback(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }

postgresql/benchmark_test.go

@@ -336,6 +336,7 @@ func BenchmarkUpperAppendTransaction(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -378,6 +379,7 @@ func BenchmarkUpperAppendTransactionWithMap(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -778,6 +780,8 @@ func BenchmarkUpperCommitManyTransactions(b *testing.B) {
 		if err = tx.Commit(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }
 
@@ -820,5 +824,7 @@ func BenchmarkUpperRollbackManyTransactions(b *testing.B) {
 		if err = tx.Rollback(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }

ql/benchmark_test.go

@@ -402,6 +402,7 @@ func BenchmarkUpperAppendTransaction(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -444,6 +445,7 @@ func BenchmarkUpperAppendTransactionWithMap(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -873,6 +875,8 @@ func BenchmarkUpperCommitManyTransactions(b *testing.B) {
 		if err = tx.Commit(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }
 
@@ -915,5 +919,7 @@ func BenchmarkUpperRollbackManyTransactions(b *testing.B) {
 		if err = tx.Rollback(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }

sqlite/benchmark_test.go

@@ -324,6 +324,7 @@ func BenchmarkUpperAppendTransaction(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -366,6 +367,7 @@ func BenchmarkUpperAppendTransactionWithMap(b *testing.B) {
 	if tx, err = sess.Transaction(); err != nil {
 		b.Fatal(err)
 	}
+	defer tx.Close()
 
 	var artist db.Collection
 	if artist, err = tx.Collection("artist"); err != nil {
@@ -766,6 +768,8 @@ func BenchmarkUpperCommitManyTransactions(b *testing.B) {
 		if err = tx.Commit(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }
 
@@ -808,5 +812,7 @@ func BenchmarkUpperRollbackManyTransactions(b *testing.B) {
 		if err = tx.Rollback(); err != nil {
 			b.Fatal(err)
 		}
+
+		tx.Close()
 	}
 }