go get -u github.com/go-sql-driver/mysql

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

Open(driverName, dataSourceName string) (*DB, error)

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    "time"
)
func main() {
    // 連接數(shù)據(jù)庫
    open, err := sql.Open("mysql", "root:root@tcp(127.0.0.1:3306)/test?charset=utf8")
    checkError(err)
  //插入數(shù)據(jù)
    //add(open)
    // 更新數(shù)據(jù)
    //update(open)
    // 刪除數(shù)據(jù)
    del(open)
}
//插入數(shù)據(jù)
func add(open *sql.DB)  {
    //插入數(shù)據(jù)
    prepare, err := open.Prepare("insert user set username=?,password=?,mobile=?,createtime=?")
    checkError(err)
    exec, err := prepare.Exec("李四", "123456", "17600000000", time.Now().Unix())
    checkError(err)
    id, err := exec.LastInsertId()
    checkError(err)
    fmt.Printf("插入數(shù)據(jù)ID: %d \n",id)
}
// 更新
func update(open *sql.DB)  {
    prepare, err := open.Prepare("update user set username=? where id =?")
    checkError(err)
    exec, err := prepare.Exec("王五", "18")
    checkError(err)
    rows, err := exec.RowsAffected()
    checkError(err)
    fmt.Printf("更新數(shù)據(jù)成功,影響條數(shù) %d \n",rows)
}
// 刪除數(shù)據(jù)
func del(open *sql.DB)  {
    prepare, err := open.Prepare("delete from user  where id =?")
    checkError(err)
    exec, err := prepare.Exec( "8")
    checkError(err)
    rows, err := exec.RowsAffected()
    checkError(err)
    fmt.Printf("刪除數(shù)據(jù)成功,影響條數(shù) %d \n",rows)
}
//檢測錯誤
func checkError(err error)  {
    if err != nil {
        panic("操作失敗:"+err.Error())
    }
}

package main
import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
)
func main() {
    // 連接數(shù)據(jù)庫
    db, err := sql.Open("mysql", "root:root@tcp(127.0.0.1:3306)/nsbd_app?charset=utf8")
    checkError(err)
    //查詢多條數(shù)據(jù)
    rows := queryRows(db)
    fmt.Printf("多條返回: \n%+v\n",rows)
    // 查詢單條數(shù)據(jù)
    row := queryRow(db)
    fmt.Printf("單條返回: \n%+v\n",row)
}

// 創(chuàng)建表的映射對象
type User struct {
    Uid        int
    UserName   string
    CreateTime int
    Birthday   sql.NullString //有的值可能為NULL
}

//查詢多條數(shù)據(jù)
func queryRows(db *sql.DB) []User {
    stmt, err := db.Prepare("select id,username,createtime,birthday from nsbd_user where id < ?")
    checkError(err)
    rows, err := stmt.Query(30)
    // 延遲關(guān)閉
    defer rows.Close()
    checkError(err)
    user := new(User)
    //users := make([]User,5)
    var users []User
    for rows.Next() {
        // rows.Scan()方法的參數(shù)順序很重要，必須和查詢結(jié)果的column相對應(yīng)（數(shù)量和順序都需要一致）
        err := rows.Scan(&user.Uid, &user.UserName, &user.CreateTime, &user.Birthday)
        checkError(err)
        users = append(users, *user)
    }
    return users
}
// 查詢單條數(shù)據(jù)
func queryRow(db *sql.DB) User {
    stmt, err := db.Prepare("select id,username,createtime,birthday from nsbd_user where id = ?")
    checkError(err)
    user := new(User)
    err = stmt.QueryRow(4).Scan(&user.Uid, &user.UserName, &user.CreateTime, &user.Birthday)
    checkError(err)
    return *user
}
//檢測錯誤
func checkError(err error) {
    if err != nil {
        panic("操作失敗:" + err.Error())
    }
}