Golang 學習筆記（10）—— mysql操作

Golang

go-sql-driver/mysql

go操作mysql的驅動包很多，這里講解當下比較流行的go-sql-driver/mysql

安裝

執(zhí)行下面兩個命令：

go get github.com/go-sql-driver/mysql  //下載
go install github.com/go-sql-driver/mysql //安裝

安裝完成以后的文件截圖

安裝完成

使用

package

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

數(shù)據庫

在mysql中建一張測試的表璧疗，sql如下：

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

連接

db, err := sql.Open("mysql", "用戶名:密碼@tcp(IP:端口)/數(shù)據庫?charset=utf8")

insert

有2種方法皆的。

直接使用Exec函數(shù)添加

result, err := db.Exec("INSERT INTO userinfo (username, departname, created) VALUES (?, ?, ?)","chain","dev","2018-01-04")

首先使用Prepare獲得stmt，然后調用Exec添加

stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
res, err := stmt.Exec("iris", "test", "2018-01-04")

另一個經常用到的功能究恤，獲得剛剛添加數(shù)據的自增ID

id, err := res.LastInsertId()

示例

package main

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

var (
    dbhost = "xxx.xxx.xxx.xxx:3306"
    dbusername = "xxxx"
    dbpassword = "xxxx"
    dbname = "xxx"
)


func main(){
    Insert("chain", "dev", "1")
    Insert("chain", "dev", "2")
    Insert("iris", "test", "1")
    Insert("iris", "test", "2")
}
/*
  獲取sql.DB對象
*/
func GetDB() *sql.DB{
    db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8", dbusername, dbpassword, dbhost, dbname))
    CheckErr(err)
    return db
}

/*
  插入數(shù)據
*/
func Insert(username, departname, method string)bool{
    db := GetDB()
    defer db.Close()

    if method == "1"{
        _, err := db.Exec("insert into userinfo(username,departname,created) values(?,?,?)",username,departname,time.Now())
        if err != nil{
            fmt.Println("insert err: ", err.Error())
            return false
        }
        fmt.Println("insert success!")
        return true
    }else if method == "2"{
        stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
        if err != nil{
            fmt.Println("insert prepare error: ", err.Error())
            return false
        }
        _, err = stmt.Exec(username, departname, time.Now())
        if err != nil{
            fmt.Println("insert exec error: ", err.Error())
            return false
        }
        fmt.Println("insert success!")
        return true
    }
    return false
}

運行結果

數(shù)據庫結果

delete

與insert所用的方法一致俭令，只是將sql語句改為對應的功能就行。

func main(){
    Delete(15)
}
/*
  根據id刪除數(shù)據
*/
func Delete(id int) bool {
    db := GetDB()
    defer db.Close()

    stmt, err := db.Prepare("delete from userinfo where uid=?")
    if err != nil{
        fmt.Println("delete prepare error: ", err.Error())
        return false
    }
    _, err = stmt.Exec(id)
    if err != nil{
        fmt.Println("delete exec error: ", err.Error())
        return false
    }
    fmt.Println("delete success!")
    return true
}

運行結果

數(shù)據庫結果

update

與insert所用的方法一致部宿，只是將sql語句改為對應的功能就行抄腔。

func main(){
    UpdateName(13,"chairis")
}
/*
  根據id瓢湃，修改名稱
*/
func UpdateName(id int, name string)bool{
    db := GetDB()
    defer db.Close()

    stmt, err := db.Prepare("update userinfo set username=? where uid=?")
    if err != nil{
        fmt.Println("update name prepare error: ", err.Error())
        return false
    }
    _, err = stmt.Exec(name, id)
    if err != nil{
        fmt.Println("update name exec error: ", err.Error())
        return false
    }
    fmt.Println("update name success!")
    return true
}

運行結果

數(shù)據庫結果

select

查詢單條數(shù)據，QueryRow 函數(shù)

func main(){
    GetOne(13)
}
func GetOne(id int){
    db := GetDB()
    defer db.Close()
    var username, departname, created string
    err := db.QueryRow("select username, departname, created from userinfo where uid=?",id).Scan(&username, &departname, &created)
    if err != nil{
        fmt.Println("get one error: ", err.Error())
        return
    }
    fmt.Println("username: ", username, "departname: ", departname, "created: ", created)
}

運行結果

查詢多條數(shù)據赫蛇，并遍歷
Query 獲取數(shù)據绵患，for xxx.Next() 遍歷數(shù)據

func main(){
    GetAll()
}
func GetAll(){
    db := GetDB()
    defer db.Close()
    rows, err := db.Query("select username, departname, created from userinfo")
    if err != nil{
        fmt.Println("get all error: ", err.Error())
        return
    }
    for rows.Next(){
        var username, departname, created string
        if err := rows.Scan(&username, &departname, &created); err == nil{
            fmt.Println("username: ", username, "departname: ", departname, "created: ", created)
        }
    }
}

運行結果

事務

在操作數(shù)據庫之前執(zhí)行，db.Begin()
例：tx, err := db.Begin()
保存到數(shù)據庫：err := tx.Commit()
回滾：err := tx.Rollback()
注意設置事務以后操作數(shù)據庫就不是db了悟耘，而是tx
請看以下示例：

func main(){
    Trans()
}

func Trans(){
    db := GetDB()
    defer db.Close();

    tx, err := db.Begin()
    if err != nil{
        fmt.Println("db.Begin error: ", err.Error())
        return
    }
    isCommit := true
    defer func(){
        if isCommit{
            tx.Commit()
            fmt.Println("commit")
        }else{
            tx.Rollback()
            fmt.Println("Rollback")
        }
    }()
    _, err = tx.Exec("insert into userinfo(username,departname,created) values(?,?,?)","username","departname",time.Now())
    if err != nil{
        isCommit = false
    }
    _, err = tx.Exec("insert into userinfo(username,departname,created) values(?,?,?)","username","departname",time.Now())
    if err != nil{
        isCommit = false
    }
    _, err = tx.Exec("insert into userinfo(username,departname,created) values(?,?,?)","username","departname",time.Now())
    if err != nil{
        isCommit = false
    }
}

運行結果

全部代碼

package main

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

var (
    dbhost = "xxx.xxx.xxx.xxx:3306"
    dbusername = "xxxxxx"
    dbpassword = "xxxxxx"
    dbname = "xxxxxx"
)


func main(){
    Trans()
}

func Trans(){
    db := GetDB()
    defer db.Close();

    tx, err := db.Begin()
    if err != nil{
        fmt.Println("db.Begin error: ", err.Error())
        return
    }
    isCommit := true
    defer func(){
        if isCommit{
            tx.Commit()
            fmt.Println("commit")
        }else{
            tx.Rollback()
            fmt.Println("Rollback")
        }
    }()
    _, err = tx.Exec("insert into userinfo(username,departname,created) values(?,?,?)","username","departname",time.Now())
    if err != nil{
        isCommit = false
    }
    _, err = tx.Exec("insert into userinfo(username,departname,created) values(?,?,?)","username","departname",time.Now())
    if err != nil{
        isCommit = false
    }
    _, err = tx.Exec("insert into userinfo(username,departname,created) values(?,?,?)","username","departname",time.Now())
    if err != nil{
        isCommit = false
    }
}

/*
  獲取sql.DB對象
*/
func GetDB() *sql.DB{
    db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8", dbusername, dbpassword, dbhost, dbname))
    CheckErr(err)
    return db
}

/*
  插入數(shù)據
*/
func Insert(username, departname, method string)bool{
    db := GetDB()
    defer db.Close()

    if method == "1"{
        _, err := db.Exec("insert into userinfo(username,departname,created) values(?,?,?)",username,departname,time.Now())
        if err != nil{
            fmt.Println("insert err: ", err.Error())
            return false
        }
        fmt.Println("insert success!")
        return true
    }else if method == "2"{
        stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
        if err != nil{
            fmt.Println("insert prepare error: ", err.Error())
            return false
        }
        _, err = stmt.Exec(username, departname, time.Now())
        if err != nil{
            fmt.Println("insert exec error: ", err.Error())
            return false
        }
        fmt.Println("insert success!")
        return true
    }
    return false
}

/*
  根據id落蝙，修改名稱
*/
func UpdateName(id int, name string)bool{
    db := GetDB()
    defer db.Close()

    stmt, err := db.Prepare("update userinfo set username=? where uid=?")
    if err != nil{
        fmt.Println("update name prepare error: ", err.Error())
        return false
    }
    _, err = stmt.Exec(name, id)
    if err != nil{
        fmt.Println("update name exec error: ", err.Error())
        return false
    }
    fmt.Println("update name success!")
    return true
}

/*
  根據id刪除數(shù)據
*/
func Delete(id int) bool {
    db := GetDB()
    defer db.Close()

    stmt, err := db.Prepare("delete from userinfo where uid=?")
    if err != nil{
        fmt.Println("delete prepare error: ", err.Error())
        return false
    }
    _, err = stmt.Exec(id)
    if err != nil{
        fmt.Println("delete exec error: ", err.Error())
        return false
    }
    fmt.Println("delete success!")
    return true
}

func GetOne(id int){
    db := GetDB()
    defer db.Close()
    var username, departname, created string
    err := db.QueryRow("select username, departname, created from userinfo where uid=?",id).Scan(&username, &departname, &created)
    if err != nil{
        fmt.Println("get one error: ", err.Error())
        return
    }
    fmt.Println("username: ", username, "departname: ", departname, "created: ", created)
}

func GetAll(){
    db := GetDB()
    defer db.Close()
    
    rows, err := db.Query("select username, departname, created from userinfo")
    if err != nil{
        fmt.Println("get all error: ", err.Error())
        return
    }
    for rows.Next(){
        var username, departname, created string
        if err := rows.Scan(&username, &departname, &created); err == nil{
            fmt.Println("username: ", username, "departname: ", departname, "created: ", created)
        }
    }
    
}

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

源碼

github 源碼地址

完

轉載請注明出處：
Golang 學習筆記（10）—— mysql操作

目錄
 上一節(jié)：Golang 學習筆記（09）—— json和xml解析
 下一節(jié)：Golang 學習筆記（11）—— 反射

最后編輯于：2018.01.14 12:41:41

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者

人面猴
序言：七十年代末，一起剝皮案震驚了整個濱河市暂幼，隨后出現(xiàn)的幾起案子筏勒，更是在濱河造成了極大的恐慌，老刑警劉巖旺嬉，帶你破解...
沈念sama閱讀 219,270評論 6贊 508
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件管行，死亡現(xiàn)場離奇詭異，居然都是意外死亡邪媳，警方通過查閱死者的電腦和手機捐顷，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 93,489評論 3贊 395
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來悲酷，“玉大人套菜，你說我怎么就攤上這事∩枰祝” “怎么了逗柴？”我有些...
開封第一講書人閱讀 165,630評論 0贊 356
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵，是天一觀的道長顿肺。經常有香客問我戏溺，道長，這世上最難降的妖魔是什么屠尊？我笑而不...
開封第一講書人閱讀 58,906評論 1贊 295
?港島之戀（遺憾婚禮）
正文為了忘掉前任旷祸，我火速辦了婚禮，結果婚禮上讼昆，老公的妹妹穿的比我還像新娘托享。我一直安慰自己，他們只是感情好浸赫，可當我...
茶點故事閱讀 67,928評論 6贊 392
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布闰围。她就那樣靜靜地躺著，像睡著了一般既峡。火紅的嫁衣襯著肌膚如雪羡榴。梳的紋絲不亂的頭發(fā)上，一...
開封第一講書人閱讀 51,718評論 1贊 305
城市分裂傳說
那天运敢，我揣著相機與錄音校仑，去河邊找鬼忠售。笑死，一個胖子當著我的面吹牛迄沫，可吹牛的內容都是我干的稻扬。我是一名探鬼主播，決...
沈念sama閱讀 40,442評論 3贊 420
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼邢滑，長吁一口氣：“原來是場噩夢啊……” “哼腐螟！你這毒婦竟也來了？” 一聲冷哼從身側響起困后，我...
開封第一講書人閱讀 39,345評論 0贊 276
萬榮殺人案實錄
序言：老撾萬榮一對情侶失蹤乐纸，失蹤者是張志新（化名）和其女友劉穎，沒想到半個月后摇予，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體汽绢，經...
沈念sama閱讀 45,802評論 1贊 317
?護林員之死
正文獨居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內容為張勛視角年9月15日...
茶點故事閱讀 37,984評論 3贊 337
?白月光啟示錄
正文我和宋清朗相戀三年侧戴，在試婚紗的時候發(fā)現(xiàn)自己被綠了宁昭。大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
茶點故事閱讀 40,117評論 1贊 351
活死人
序言：一個原本活蹦亂跳的男人離奇死亡酗宋，死狀恐怖积仗，靈堂內的尸體忽然破棺而出，到底是詐尸還是另有隱情蜕猫，我是刑警寧澤寂曹，帶...
沈念sama閱讀 35,810評論 5贊 346
?日本核電站爆炸內幕
正文年R本政府宣布，位于F島的核電站回右，受9級特大地震影響隆圆，放射性物質發(fā)生泄漏。R本人自食惡果不足惜翔烁，卻給世界環(huán)境...
茶點故事閱讀 41,462評論 3贊 331
男人毒藥：我在死后第九天來索命
文/蒙蒙一渺氧、第九天我趴在偏房一處隱蔽的房頂上張望。院中可真熱鬧蹬屹，春花似錦侣背、人聲如沸。這莊子的主人今日做“春日...
開封第一講書人閱讀 32,011評論 0贊 22
一樁弒父案秃踩，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽。三九已至业筏，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間鸟赫，已是汗流浹背蒜胖。一陣腳步聲響...
開封第一講書人閱讀 33,139評論 1贊 272
情欲美人皮
我被黑心中介騙來泰國打工消别，沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留，地道東北人台谢。一個月前我還...
沈念sama閱讀 48,377評論 3贊 373
代替公主和親
正文我出身青樓寻狂，卻偏偏與公主長得像，于是被迫代替她去往敵國和親朋沮。傳聞我的和親對象是個殘疾皇子蛇券，可洞房花燭夜當晚...
茶點故事閱讀 45,060評論 2贊 355

Golang 學習筆記（10）—— mysql操作

go-sql-driver/mysql

安裝

使用

package

數(shù)據庫

連接

insert

delete

update

select

事務

全部代碼

源碼

完

推薦閱讀更多精彩內容