transaction.go

package main

import (
	"database/sql"
	_ "github.com/go-sql-driver/mysql"
)

func main() {
	db, _ := sql.Open("mysql", "user:password@tcp(host:port)/dbname")

	tx, _ := db.Begin()

	// 何かクエリを発行する

	// 何かの処理で問題が起こったとき
	if err != nil {
		tx.Rollback()
	} else {
		tx.Commit()
	}
}