go语言 与MySQL数据库详解

导入 ​​github.com/go-sql-driver/mysql​​

查询 插入 跟新 删除

package main

import (
"database/sql"
"fmt"

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

func main() {
//连接数据库
db, err := sql.Open("mysql", "root:wangshubo@/test?charset=utf8")
checkErr(err)

//插入操作
// insert
stmt, err := db.Prepare("INSERT user_info SET id=?,name=?")
checkErr(err)

res, err := stmt.Exec(1, "wangshubo")
checkErr(err)

//更新操作
// update
stmt, err = db.Prepare("update user_info set name=? where id=?")
checkErr(err)

res, err = stmt.Exec("wangshubo_update", 1)
checkErr(err)

affect, err := res.RowsAffected()
checkErr(err)

fmt.Println(affect)

//查询操作
// query
rows, err := db.Query("SELECT * FROM user_info")
checkErr(err)

for rows.Next() {
var uid int
var username string

err = rows.Scan(&uid, &username)
checkErr(err)
fmt.Println(uid)
fmt.Println(username)
}


//删除操作
// delete
stmt, err = db.Prepare("delete from user_info where id=?")
checkErr(err)

res, err = stmt.Exec(1)
checkErr(err)

// query
rows, err = db.Query("SELECT * FROM user_info")
checkErr(err)

for rows.Next() {
var uid int
var username string

err = rows.Scan(&uid, &username)
checkErr(err)
fmt.Println(uid)
fmt.Println(username)
}

db.Close()

}

func checkErr(err error) {
if err != nil {
panic(err)
}
}