dsn := "username:password@tcp(127.0.0.1:3306)/dbname"

stmt, err := tx.Prepare("INSERT INTO table1 (column1, column2) VALUES(?, ?)")  
if err != nil {  
    fmt.Printf("準備預(yù)處理語句失敗：%v\n", err)  
    return  
}  
defer stmt.Close()  
// 第一次執(zhí)行  
_, err = stmt.Exec("f", "g")  
if err != nil {  
    tx.Rollback()  
    fmt.Printf("執(zhí)行預(yù)處理語句第一次失?。?v\n", err)  
    return  
}  
// 第二次執(zhí)行  
_, err = stmt.Exec("h", "i")  
if err != nil {  
    tx.Rollback()  
    fmt.Printf("執(zhí)行預(yù)處理語句第二次失?。?v\n", err)  
    return  
}  

package main  
import (  
    "database/sql"  
    "fmt"  
    _ "github.com/go-sql-driver/mysql"  
)  
const (  
    dsn = "username:password@tcp(localhost:3306)/test"  
)  
func main() {  
    db, err := sql.Open("mysql", dsn)  
    if err != nil {  
        fmt.Printf("打開數(shù)據(jù)庫連接失?。?v\n", err)  
        return  
    }  
    defer db.Close()  
    if err := db.Ping(); err != nil {  
        fmt.Printf("數(shù)據(jù)庫連接不可用：%v\n", err)  
        return  
    }  
    transactionExample(db)  
}  
func transactionExample(db *sql.DB) {  
    tx, err := db.Begin()  
    if err != nil {  
        fmt.Printf("開始事務(wù)失?。?v\n", err)  
        return  
    }  
    defer func() {  
        if err != nil {  
            fmt.Println("事務(wù)回滾中...")  
            rollbackErr := tx.Rollback()  
            if rollbackErr != nil && rollbackErr != sql.ErrTxDone {  
                fmt.Printf("事務(wù)回滾失?。?v\n", rollbackErr)  
            }  
        }  
    }()  
    // 創(chuàng)建表  
    fmt.Println("創(chuàng)建表...")  
    err = createTable(tx)  
    if err != nil {  
        return  
    }  
    // 插入數(shù)據(jù)  
    fmt.Println("插入數(shù)據(jù)到table1...")  
    err = insertData(tx)  
    if err != nil {  
        return  
    }  
    // 更新數(shù)據(jù)  
    fmt.Println("更新table1的值...")  
    err = updateData(tx)  
    if err != nil {  
        return  
    }  
    // 刪除數(shù)據(jù)  
    fmt.Println("刪除數(shù)據(jù)...")  
    err = deleteData(tx)  
    if err != nil {  
        return  
    }  
    // 查詢多行數(shù)據(jù)  
    fmt.Println("查詢多行數(shù)據(jù)...")  
    err = queryMultiRows(tx)  
    if err != nil {  
        return  
    }  
    // 查詢單行數(shù)據(jù)  
    fmt.Println("查詢單行數(shù)據(jù)...")  
    err = querySingleRow(tx)  
    if err != nil {  
        return  
    }  
    // 預(yù)處理語句插入數(shù)據(jù)  
    fmt.Println("使用預(yù)處理語句插入數(shù)據(jù)...")  
    err = insertWithPrepare(tx)  
    if err != nil {  
        return  
    }  
    // 提交事務(wù)  
    fmt.Println("提交事務(wù)...")  
    err = tx.Commit()  
    if err != nil {  
        fmt.Printf("提交事務(wù)失?。?v\n", err)  
        return  
    }  
    fmt.Println("事務(wù)處理成功。")  
}  
func createTable(tx *sql.Tx) error {  
    _, err := tx.Exec("create table if not exists table1 (column1 nchar(10), column2 nchar(10))")  
    return err  
}  
func insertData(tx *sql.Tx) error {  
    _, err := tx.Exec("insert into table1 (column1, column2) values ('a','b'), ('c','d'), ('e','f')")  
    return err  
}  
func updateData(tx *sql.Tx) error {  
    _, err := tx.Exec("update table1 set column1 = 'c' where column1 = 'a'")  
    return err  
}  
func deleteData(tx *sql.Tx) error {  
    _, err := tx.Exec("delete from table1 where column1 = 'b'")  
    return err  
}  
func queryMultiRows(tx *sql.Tx) error {  
    rows, err := tx.Query("select * from table1")  
    if err != nil {  
        return err  
    }  
    defer rows.Close()  
    for rows.Next() {  
        var s1, s2 string  
        err := rows.Scan(&s1, &s2)  
        if err != nil {  
            return fmt.Errorf("掃描失?。?v", err)  
        }  
        fmt.Printf("table1數(shù)據(jù)：%s, %s\n", s1, s2)  
    }  
    if err := rows.Err(); err != nil {  
        return fmt.Errorf("遍歷table1失?。?v", err)  
    }  
    return nil  
}  
func querySingleRow(tx *sql.Tx) error {  
    var c string  
    err := tx.QueryRow("select column1 from table1 where column1 = 'e'").Scan(&c)  
    if err != nil {  
        if err == sql.ErrNoRows {  
            fmt.Println("沒有找到匹配的行。")  
        } else {  
            return fmt.Errorf("查詢單行數(shù)據(jù)失敗：%v", err)  
        }  
        return nil  
    }  
    fmt.Printf("單行數(shù)據(jù)：%s\n", c)  
    return nil  
}  
func insertWithPrepare(tx *sql.Tx) error {  
    stmt, err := tx.Prepare("insert into table1 (column1, column2) values(?, ?)")  
    if err != nil {  
        return fmt.Errorf("準備預(yù)處理語句失?。?v", err)  
    }  
    defer stmt.Close()  
    _, err = stmt.Exec("f", "g")  
    if err != nil {  
        return fmt.Errorf("執(zhí)行預(yù)處理語句失?。?v", err)  
    }  
    return nil  
}