一.需求分析

  • 商品修改涉及到两个表的修改:tb_item和tb_item_desc的修改
  • 本小节使用事务完成数据的修改
  • 需要改写DBUtils.go中代码,改写后Dao层代码直接调用PrepareWithTx()函数,在Service层中开启事务,提交事务

二.代码演示

  • 在DBUtils.go中添加代码
  1. //数据库操作的三个对象
  2. var (
  3.     db   *sql.DB
  4.     stmt *sql.Stmt
  5.     rows *sql.Rows
  6.     tx *sql.Tx
  7. )
  9. //打开数据库连接,不要忘记导入驱动包
  10. func OpenConnWithTx()(err error){
  11.     //此处为等号,否则创建局部变量
  12.     db,err=sql.Open("mysql","root:smallming@tcp(localhost:3306)/ego")
  13.     if err!=nil{
  14.         fmt.Println("连接失败",err)
  15.         return
  16.     }
  17.     //开启事务
  18.     tx,err=db.Begin()
  19.     if err!=nil{
  20.         fmt.Println(err)
  21.         return
  22.     }
  23.     return nil
  24. }
  25. //判断返回值是否大于1
  26. func PrepareWithTx(sql string ,args ... interface{}) int{
  27.     result,err:=tx.Exec(sql,args...)
  28.     if err!=nil{
  29.         fmt.Println(err)
  30.         return -1
  31.     }
  32.     count,err:=result.RowsAffected()
  33.     if err!=nil{
  34.         fmt.Println(err)
  35.         return -1
  36.     }
  37.     return int(count)
  38. }
  39. //提交事务
  40. func CloseConnWithTx(result bool){
  41.     if result{
  42.         tx.Commit()//提交事务
  43.     }else{
  44.         tx.Rollback()//回滚事务
  45.     }
  46.     if rows!=nil{
  47.         rows.Close()
  48.     }
  49.     if stmt!=nil{
  50.         stmt.Close()
  51.     }
  52.     if db!=nil{
  53.         db.Close()
  54.     }
  55. }