DAPP智能合约系统开发代码部署方案介绍

Go实现 MySQL 的事务
开启事务处理，会有回滚机制，全部成功了，且提交成功，才算事务处理成功
func (db DB) Begin() (Tx, error) 事务开始
func (tx *Tx) Commit() error 事务提交
func (tx *Tx) Rollback() error 事务回滚

func trasaction(db *sql.DB) {

//开启一个事务

tx, err := db.Begin()
if err != nil {
    if tx != nil {
        tx.Rollback()
    }
    fmt.Printf("Begin err :%v", err)
    return
}

sqlStr := "update user set name='xxx' where id=?"
_, err = tx.Exec(sqlStr, 9)
if err != nil {
    if tx != nil {
        tx.Rollback()
    }
    fmt.Printf("Exec err :%v", err)
    return
}

sqlStr = "update user set name='xxx' where id=?"
_, err = tx.Exec(sqlStr, 6)
if err != nil {
    if tx != nil {
        tx.Rollback()
    }
    fmt.Printf("Exec err :%v", err)
    return
}

//提交事务
err = tx.Commit()
if err != nil {
    if tx != nil {
        tx.Rollback()
    }
    fmt.Printf("Commit err :%v", err)
    return
}

fmt.Println("commit success ")

}
sqlx使用
咱们还可以使用第三方库 sqlx

安装第三方库 sqlx ，go get github.com/jmoiron/sqlx
第三方库可以提交高开发效率，简化开发操作

package main

import (

"fmt"
"github.com/jmoiron/sqlx"
_ "github.com/go-sql-driver/mysql" // 注释掉后异常 _ 调用初始化函数

)

var db *sqlx.DB

func insertInfo() {

sqlStr := "insert into user(name,age)values(?,?)"
res, err := db.Exec(sqlStr, "xxx", 2)
if err != nil {
    fmt.Printf("Exec err : %v", err)
    return
}
id, err := res.LastInsertId()
if err != nil {
    fmt.Printf("LastInsertId err : %v", err)
    return
}
fmt.Printf("id == %d", id)

rows, err := res.RowsAffected()
if err != nil {
    fmt.Printf("RowsAffected err : %v", rows)
    return
}
fmt.Printf("rows == %d", rows)
return

}

func main() {

var err error
dsn := "root:123456@tcp(127.0.0.1:3306)/go_test?charset=utf8mb4"
db, err = sqlx.Connect("mysql", dsn)
if err != nil {
    fmt.Printf("Connect err : %v\n", err)
    return
}
db.SetMaxOpenConns(20)
db.SetMaxIdleConns(10)

//插入数据
insertInfo()

}