Adding End and Begin statements. Closing #23.

db.go

@@ -310,6 +310,16 @@ type Database interface {
 		Returns the name of the active database.
 	*/
 	Name() string
+
+	/*
+		Starts a transaction block.
+	*/
+	Begin() error
+
+	/*
+		Ends a transaction block.
+	*/
+	End() error
 }
 
 // Collection methods.

mongo/README.md

 # gosexy/db/mongo
 
-Please read the full docs, acknowledgements and examples at [http://gosexy.org/db/wrappers/mongo](http://gosexy.org/db/wrappers/mongo).
+Please read the full docs, acknowledgements and examples at
+[https://menteslibres.net/gosexy/db/wrappers/mongo][1].
+
+[1]: https://menteslibres.net/gosexy/db/wrappers/mongo

mongo/mongo.go

@@ -72,6 +72,24 @@ func (self *Source) Use(database string) error {
 	return nil
 }
 
+/*
+	Starts a transaction block.
+*/
+func (self *Source) Begin() error {
+	// TODO:
+	// MongoDB does not supports something like BEGIN and END statements.
+	return nil
+}
+
+/*
+	Ends a transaction block.
+*/
+func (self *Source) End() error {
+	// TODO:
+	// MongoDB does not supports something like BEGIN and END statements.
+	return nil
+}
+
 // Returns a collection from the current database.
 func (self *Source) Collection(name string) (db.Collection, error) {
 	var err error

mysql/mysql.go

@@ -237,6 +237,22 @@ func (self *Source) Use(database string) error {
 	return err
 }
 
+/*
+	Starts a transaction block.
+*/
+func (self *Source) Begin() error {
+	_, err := self.session.Exec(`BEGIN`)
+	return err
+}
+
+/*
+	Ends a transaction block.
+*/
+func (self *Source) End() error {
+	_, err := self.session.Exec(`END`)
+	return err
+}
+
 /*
 	Drops the currently active database.
 */

postgresql/postgresql.go

@@ -240,6 +240,22 @@ func (self *Source) Use(database string) error {
 	return self.Open()
 }
 
+/*
+	Starts a transaction block.
+*/
+func (self *Source) Begin() error {
+	_, err := self.session.Exec(`BEGIN`)
+	return err
+}
+
+/*
+	Ends a transaction block.
+*/
+func (self *Source) End() error {
+	_, err := self.session.Exec(`END`)
+	return err
+}
+
 /*
 	Drops the currently active database.
 */

sqlite/sqlite.go

@@ -223,6 +223,22 @@ func (self *Source) Use(database string) error {
 	return err
 }
 
+/*
+	Starts a transaction block.
+*/
+func (self *Source) Begin() error {
+	_, err := self.session.Exec(`BEGIN`)
+	return err
+}
+
+/*
+	Ends a transaction block.
+*/
+func (self *Source) End() error {
+	_, err := self.session.Exec(`END`)
+	return err
+}
+
 /*
 	Drops the currently active database.
 */

sqlite/sqlite_test.go

@@ -797,10 +797,7 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) {
 	people := sess.ExistentCollection("people")
 	people.Truncate()
 
-	driver := sess.Driver().(*sql.DB)
-
-	b.ResetTimer()
-	_, err = driver.Exec(`BEGIN`)
+	err = sess.Begin()
 	if err != nil {
 		b.Fatalf(err.Error())
 	}
@@ -812,7 +809,7 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) {
 		}
 	}
 
-	_, err = driver.Exec(`END`)
+	err = sess.End()
 	if err != nil {
 		b.Fatalf(err.Error())
 	}