Golang中如何对MySQL进行操作详解

import (
 "database/sql"
 _ "github.com/go-sql-driver/mysql"
)

err = db.Ping()
if err != nil {
 // 错误处理
}

/*
 查询操作
*/
stmt, err := db.Prepare("SELECT `user_name` FROM `users` WHERE `id` = ")
defer stmt.Close()
if err != nil {
 //错误处理
}
var userName string
//Scan() 将结果复制到userName
err = stmt.QueryRow(1).Scan(&userName)

fmt.Println(userName)

/*
 多行结果
*/
stmt, err := db.Prepare("SELECT `user_name` FROM `users` WHERE `age` = ")
defer stmt.Close()
if err != nil {
 //错误处理
}

rows, err := stmt.Query(年龄)
if err != nil {
 //错误处理
}

for rows.Next() {
 var userName string
 if err := rows.Scan(&userName); err != nil {
  //错误处理
 }
}

/*
 插入操作
*/
stmt, err := db.Prepare("INSERT INTO `users` (`user_name`, `age`) VALUES(")
defer stmt.Close()
if err != nil {
 //错误处理
}
stmt.Exec("名字"，年龄)

/*
 事务
*/
tx, err := db.Begin()
if err != nil {
 //错误处理
}
defer tx.Rollback()

stmt, err := db.Prepare("")
defer stmt.Close()
if err != nil {
 //错误处理
}

stmt.Exec()
err = tx.Commit()
if err != nil {
 //错误处理
}