在golang中学习使用事务操作mysql数据库

• 2017-06-30
• 4387 View

//usage:在golang中学习使用事务操作数据库

//    @author     Mr.Luo
//    @time    2015年2月13日15:09:26

package main

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

var (
    driverName     string
    dataSourceName string
)

func init() {
    driverName = "mysql"
    dataSourceName = "root:123456@/godb"
}

func main() {
    db := Conn()
    //开启事务
    tx, err := db.Begin()
    if err != nil {
        log.Fatal(err)
    }
    //使用tx
    stmt, err := tx.Prepare("update tab_user set name=? where id = ?")
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(stmt)
    // _, err = tx.Exec("测试事务", 4)
     _, err = stmt.Exec("测试事务", 4) //注意别调用错了 tx.Exec

    //出异常回滚
    defer tx.Rollback()

    //提交事务
    tx.Commit()

}

func Conn() *sql.DB {
    db, err := sql.Open(driverName, dataSourceName)
    if err != nil {
        log.Fatal(err)
    }
    return db

}