7.事务操作

1. 使用db.Begin()进行开启
2. 操作数据库
3. 开启成功之后，进行事务操作

操作-Exec

查询-Query

func main(){//连接数据库db,err := sql.Open("mysql","ims:123456@tcp(192.168.0.26:3306)/ibcf")if err != nil{log.Fatal("连接数据库失败:",err)    }//关闭连接defer db.Close()//验证是否连接成功err = db.Ping()if err != nil{log.Fatal("验证失败:",err)    }fmt.Println("连接成功!")//开启事务tx,err := db.Begin()if err != nil{log.Fatal("开启事务失败:",err)    }//操作数据库if _,err := tx.Exec("UPDATE user0 SET server_port = ? WHERE id = ?","1111",1);err != nil{tx.Rollback()//事务回滚log.Fatal("更新失败:",err)    }_,err := tx.Query("SELECT id,server_ip,server_port FROM user0")if err != nil{tx.Rollback()//事务回滚log.Fatal("查询失败!")    }if _,err := tx.Exec("INSERT INTO user0(id,server_ip,server_port) VALUES(?,?,?)",2,"192.168.0.0",9090);err != nil{tx.Rollback()//事务回滚log.Fatal("插入数据失败:",err)    }//关闭if err := tx.Commit();err != nil{tx.Rollback()//事务回滚log.Fatal("关闭失败:",err)    }}