1. MySQL事务

mysql事务特性：

  1.     1) 原子性
  2.     2) 一致性
  3.     3) 隔离性
  4.     4) 持久性

golang MySQL事务应用：

  1.     1） import (“github.com/jmoiron/sqlx")
  2.     2)  Db.Begin()        开始事务
  3.     3)  Db.Commit()        提交事务
  4.     4)  Db.Rollback()     回滚事务
  1. package main
  3.     import (
  4.         "fmt"
  6.         _ "github.com/go-sql-driver/mysql"
  7.         "github.com/jmoiron/sqlx"
  8.     )
  10.     type Person struct {
  11.         UserId   int    `db:"user_id"`
  12.         Username string `db:"username"`
  13.         Sex      string `db:"sex"`
  14.         Email    string `db:"email"`
  15.     }
  17.     type Place struct {
  18.         Country string `db:"country"`
  19.         City    string `db:"city"`
  20.         TelCode int    `db:"telcode"`
  21.     }
  23.     var Db *sqlx.DB
  25.     func init() {
  26.         database, err := sqlx.Open("mysql", "root:root@tcp(127.0.0.1:3306)/test")
  27.         if err != nil {
  28.             fmt.Println("open mysql failed,", err)
  29.             return
  30.         }
  31.         Db = database
  32.     }
  34.     func main() {
  35.         conn, err := Db.Begin()
  36.         if err != nil {
  37.             fmt.Println("begin failed :", err)
  38.             return
  39.         }
  41.         r, err := conn.Exec("insert into person(username, sex, email)values(?, ?, ?)", "stu001", "man", "stu01@qq.com")
  42.         if err != nil {
  43.             fmt.Println("exec failed, ", err)
  44.             conn.Rollback()
  45.             return
  46.         }
  47.         id, err := r.LastInsertId()
  48.         if err != nil {
  49.             fmt.Println("exec failed, ", err)
  50.             conn.Rollback()
  51.             return
  52.         }
  53.         fmt.Println("insert succ:", id)
  55.         r, err = conn.Exec("insert into person(username, sex, email)values(?, ?, ?)", "stu001", "man", "stu01@qq.com")
  56.         if err != nil {
  57.             fmt.Println("exec failed, ", err)
  58.             conn.Rollback()
  59.             return
  60.         }
  61.         id, err = r.LastInsertId()
  62.         if err != nil {
  63.             fmt.Println("exec failed, ", err)
  64.             conn.Rollback()
  65.             return
  66.         }
  67.         fmt.Println("insert succ:", id)
  69.         conn.Commit()
  70.     }

输出结果：

  1.     insert succ: 2
  2.     insert succ: 3

查看MySQL：

  1.     mysql> select * from person;
  2.     +---------+----------+------+--------------+
  3.     | user_id | username | sex  | email        |
  4.     +---------+----------+------+--------------+
  5.     |       2 | stu001   | man  | stu01@qq.com |
  6.     |       3 | stu001   | man  | stu01@qq.com |
  7.     +---------+----------+------+--------------+
  8.     2 rows in set (0.00 sec)