在進(jìn)行開(kāi)發(fā)之前首先要使用git下載mysql的驅(qū)動(dòng)，github上面的mysql驅(qū)動(dòng)有好幾個(gè)，我在這里選擇的https://github.com/go-sql-driver/mysql，
執(zhí)行命令：go get -u github.com/go-sql-driver/mysql
在正式開(kāi)發(fā)之前先創(chuàng)建對(duì)應(yīng)的數(shù)據(jù)庫(kù)和表

CREATE TABLE `userinfo` (
    `autid` INT(10) NOT NULL AUTO_INCREMENT,
    `username` VARCHAR(64) NULL DEFAULT NULL,
    `departname` VARCHAR(64) NULL DEFAULT NULL,
    `password` VARCHAR(64) NULL DEFAULT NULL,
    `uid` VARCHAR(64) NULL DEFAULT NULL,
    `created` DATE NULL DEFAULT NULL,
    PRIMARY KEY (`uid`)
);

導(dǎo)入基本類庫(kù)

import (
    "crypto/md5"
    "database/sql"
    "encoding/hex"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    "strconv"
    "time"
)

下面主要從增刪查改四個(gè)方面介紹go語(yǔ)言中mysql的使用

一、注冊(cè)數(shù)據(jù)庫(kù)驅(qū)動(dòng)

使用sql.Open()函數(shù)打開(kāi)注冊(cè)一個(gè)注冊(cè)過(guò)的驅(qū)動(dòng)，第一個(gè)參數(shù)是數(shù)據(jù)庫(kù)類型，第二個(gè)參數(shù)是，第二個(gè)參數(shù)是DSN(Data Source Name)，它是go-sql-driver定義的一些數(shù)據(jù)庫(kù)鏈接和配置信息,DSN有以下格式：
user@unix(/path/to/socket)/dbname?charset=utf8
user:password@tcp(localhost:5555)/dbname?charset=utf8
user:password@/dbname
user:password@tcp([de:ad:be:ef::ca:fe]:80)/dbname

代碼如下：

const (
    DB_Driver = "root:meddeex@tcp(127.0.0.1:3306)/medex?charset=utf8"
)

func OpenDB() (success bool, db *sql.DB) {
    var isOpen bool
    db, err := sql.Open("mysql", DB_Driver)
    if err != nil {
        isOpen = false
    } else {
        isOpen = true
    }
    CheckErr(err)
    return isOpen, db
}

二、插入

func insertToDB(db *sql.DB) {
    uid := GetNowtimeMD5()
    nowTimeStr := GetTime()
    stmt, err := db.Prepare("insert userinfo set username=?,departname=?,created=?,password=?,uid=?")
    CheckErr(err)
    res, err := stmt.Exec("wangbiao", "研發(fā)中心", nowTimeStr, "123456", uid)
    CheckErr(err)
    id, err := res.LastInsertId()
    CheckErr(err)
    if err != nil {
        fmt.Println("插入數(shù)據(jù)失敗")
    } else {
        fmt.Println("插入數(shù)據(jù)成功：", id)
    }
}

三、查詢

func QueryFromDB(db *sql.DB) {
    rows, err := db.Query("SELECT * FROM userinfo")
    CheckErr(err)
    if err != nil {
        fmt.Println("error:", err)
    } else {
    }
    for rows.Next() {
        var uid string
        var username string
        var departmentname string
        var created string
        var password string
        var autid string
        CheckErr(err)
        err = rows.Scan(&uid, &username, &departmentname, &created, &password, &autid)
        fmt.Println(autid)
        fmt.Println(username)
        fmt.Println(departmentname)
        fmt.Println(created)
        fmt.Println(password)
        fmt.Println(uid)
    }
}

四、更新

func UpdateDB(db *sql.DB, uid string) {
    stmt, err := db.Prepare("update userinfo set username=? where uid=?")
    CheckErr(err)
    res, err := stmt.Exec("zhangqi", uid)
    affect, err := res.RowsAffected()
    fmt.Println("更新數(shù)據(jù)：", affect)
    CheckErr(err)
}

五、刪除

func DeleteFromDB(db *sql.DB, autid int) {
    stmt, err := db.Prepare("delete from userinfo where autid=?")
    CheckErr(err)
    res, err := stmt.Exec(autid)
    affect, err := res.RowsAffected()
    fmt.Println("刪除數(shù)據(jù)：", affect)
}

開(kāi)發(fā)過(guò)程中用到的一些工具類方法

func CheckErr(err error) {
    if err != nil {
        panic(err)
        fmt.Println("err:", err)
    }
}

func GetTime() string {
    const shortForm = "2006-01-02 15:04:05"
    t := time.Now()
    temp := time.Date(t.Year(), t.Month(), t.Day(), t.Hour(), t.Minute(), t.Second(), t.Nanosecond(), time.Local)
    str := temp.Format(shortForm)
    fmt.Println(t)
    return str
}

func GetMD5Hash(text string) string {
    haser := md5.New()
    haser.Write([]byte(text))
    return hex.EncodeToString(haser.Sum(nil))
}

func GetNowtimeMD5() string {
    t := time.Now()
    timestamp := strconv.FormatInt(t.UTC().UnixNano(), 10)
    return GetMD5Hash(timestamp)
}

調(diào)用

func main() {
    opend, db := OpenDB()
    if opend {
        fmt.Println("open success")
    } else {
        fmt.Println("open faile:")
    }
    DeleteFromDB(db, 10)
    //QueryFromDB(db)
    //DeleteFromDB(db, 1)
    //UpdateDB(db, 5)
    //insertToDB(db)
    //UpdateUID(db, 5)
    //UpdateTime(db, 4)

}

寫(xiě)在最后：

本篇文章主要介紹mysql在go語(yǔ)言開(kāi)發(fā)中的基本使用，其實(shí)真正開(kāi)發(fā)過(guò)程中還是主要使用orm相關(guān)第三方框架，但是底層原理還是要學(xué)的。