當(dāng)前位置：首頁 > 运维知识 > 数据库 >内容正文

数据库

golang学习之旅：使用go语言操作mysql数据库(自己测试了)

發(fā)布時(shí)間：2024/9/20 数据库 29 豆豆

生活随笔收集整理的這篇文章主要介紹了 golang学习之旅：使用go语言操作mysql数据库(自己测试了) 小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

1.下載并導(dǎo)入數(shù)據(jù)庫驅(qū)動(dòng)包

官方不提供實(shí)現(xiàn)，先下載第三方的實(shí)現(xiàn)，點(diǎn)擊這里查看各種各樣的實(shí)現(xiàn)版本。
這里選擇了Go-MySQL-Driver這個(gè)實(shí)現(xiàn)。地址是：https://github.com/go-sql-driver/mysql/。

然后按照里面的說明下載驅(qū)動(dòng)包：

$ go get github.com/go-sql-driver/mysql(個(gè)人感覺是讓這個(gè)地址生效的語句)

最后導(dǎo)入包即可：

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

2.連接至數(shù)據(jù)庫

db, err := sql.Open("mysql", "root:root@/uestcbook")

3.執(zhí)行查詢

（1）Exec?

result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)","gopher",27, )

（2）Query?

rows, err := db.Query("SELECT name FROM users WHERE age = ?", age) if err != nil {log.Fatal(err) } for rows.Next() {var name stringif err := rows.Scan(&name); err != nil {log.Fatal(err)}fmt.Printf("%s is %d\n", name, age) } if err := rows.Err(); err != nil {log.Fatal(err) }

（3）QueryRow

var age int64 row := db.QueryRow("SELECT age FROM users WHERE name = ?", name) err := row.Scan(&age)

（4）Prepared statements?

age := 27 stmt, err := db.Prepare("SELECT name FROM users WHERE age = ?") if err != nil {log.Fatal(err) } rows, err := stmt.Query(age) // process rows

4. 事務(wù)

tx, err := db.Begin() if err != nil {log.Fatal(err) }

5. 各種方式效率分析

問題：db.exec和statement.exec和tx.exec的區(qū)別？

實(shí)例如下：

package mainimport ("strconv""database/sql"_ "github.com/go-sql-driver/mysql""fmt""time""log" )var db = &sql.DB{}func init(){db,_ = sql.Open("mysql", "root:root@/book") } func main() {insert()query()update()query()delete() }func update(){//方式1 updatestart := time.Now()for i := 1001;i<=1100;i++{db.Exec("UPdate user set age=? where uid=? ",i,i)}end := time.Now()fmt.Println("方式1 update total time:",end.Sub(start).Seconds())//方式2 updatestart = time.Now()for i := 1101;i<=1200;i++{stm,_ := db.Prepare("UPdate user set age=? where uid=? ")stm.Exec(i,i)stm.Close()}end = time.Now()fmt.Println("方式2 update total time:",end.Sub(start).Seconds())//方式3 updatestart = time.Now()stm,_ := db.Prepare("UPdate user set age=? where uid=?")for i := 1201;i<=1300;i++{stm.Exec(i,i)}stm.Close()end = time.Now()fmt.Println("方式3 update total time:",end.Sub(start).Seconds())//方式4 updatestart = time.Now()tx,_ := db.Begin()for i := 1301;i<=1400;i++{tx.Exec("UPdate user set age=? where uid=?",i,i)}tx.Commit()end = time.Now()fmt.Println("方式4 update total time:",end.Sub(start).Seconds())//方式5 updatestart = time.Now()for i := 1401;i<=1500;i++{tx,_ := db.Begin()tx.Exec("UPdate user set age=? where uid=?",i,i)tx.Commit()}end = time.Now()fmt.Println("方式5 update total time:",end.Sub(start).Seconds())}func delete(){//方式1 deletestart := time.Now()for i := 1001;i<=1100;i++{db.Exec("DELETE FROM USER WHERE uid=?",i)}end := time.Now()fmt.Println("方式1 delete total time:",end.Sub(start).Seconds())//方式2 deletestart = time.Now()for i := 1101;i<=1200;i++{stm,_ := db.Prepare("DELETE FROM USER WHERE uid=?")stm.Exec(i)stm.Close()}end = time.Now()fmt.Println("方式2 delete total time:",end.Sub(start).Seconds())//方式3 deletestart = time.Now()stm,_ := db.Prepare("DELETE FROM USER WHERE uid=?")for i := 1201;i<=1300;i++{stm.Exec(i)}stm.Close()end = time.Now()fmt.Println("方式3 delete total time:",end.Sub(start).Seconds())//方式4 deletestart = time.Now()tx,_ := db.Begin()for i := 1301;i<=1400;i++{tx.Exec("DELETE FROM USER WHERE uid=?",i)}tx.Commit()end = time.Now()fmt.Println("方式4 delete total time:",end.Sub(start).Seconds())//方式5 deletestart = time.Now()for i := 1401;i<=1500;i++{tx,_ := db.Begin()tx.Exec("DELETE FROM USER WHERE uid=?",i)tx.Commit()}end = time.Now()fmt.Println("方式5 delete total time:",end.Sub(start).Seconds())}func query(){//方式1 querystart := time.Now()rows,_ := db.Query("SELECT uid,username FROM USER")defer rows.Close()for rows.Next(){var name stringvar id intif err := rows.Scan(&id,&name); err != nil {log.Fatal(err)}//fmt.Printf("name:%s ,id:is %d\n", name, id) }end := time.Now()fmt.Println("方式1 query total time:",end.Sub(start).Seconds())//方式2 querystart = time.Now()stm,_ := db.Prepare("SELECT uid,username FROM USER")defer stm.Close()rows,_ = stm.Query()defer rows.Close()for rows.Next(){var name stringvar id intif err := rows.Scan(&id,&name); err != nil {log.Fatal(err)}// fmt.Printf("name:%s ,id:is %d\n", name, id) }end = time.Now()fmt.Println("方式2 query total time:",end.Sub(start).Seconds())//方式3 querystart = time.Now()tx,_ := db.Begin()defer tx.Commit()rows,_ = tx.Query("SELECT uid,username FROM USER")defer rows.Close()for rows.Next(){var name stringvar id intif err := rows.Scan(&id,&name); err != nil {log.Fatal(err)}//fmt.Printf("name:%s ,id:is %d\n", name, id) }end = time.Now()fmt.Println("方式3 query total time:",end.Sub(start).Seconds()) }func insert() {//方式1 insert//strconv,int轉(zhuǎn)string:strconv.Itoa(i)start := time.Now()for i := 1001;i<=1100;i++{//每次循環(huán)內(nèi)部都會(huì)去連接池獲取一個(gè)新的連接，效率低下db.Exec("INSERT INTO user(uid,username,age) values(?,?,?)",i,"user"+strconv.Itoa(i),i-1000)}end := time.Now()fmt.Println("方式1 insert total time:",end.Sub(start).Seconds())//方式2 insertstart = time.Now()for i := 1101;i<=1200;i++{//Prepare函數(shù)每次循環(huán)內(nèi)部都會(huì)去連接池獲取一個(gè)新的連接，效率低下stm,_ := db.Prepare("INSERT INTO user(uid,username,age) values(?,?,?)")stm.Exec(i,"user"+strconv.Itoa(i),i-1000)stm.Close()}end = time.Now()fmt.Println("方式2 insert total time:",end.Sub(start).Seconds())//方式3 insertstart = time.Now()stm,_ := db.Prepare("INSERT INTO user(uid,username,age) values(?,?,?)")for i := 1201;i<=1300;i++{//Exec內(nèi)部并沒有去獲取連接，為什么效率還是低呢？stm.Exec(i,"user"+strconv.Itoa(i),i-1000)}stm.Close()end = time.Now()fmt.Println("方式3 insert total time:",end.Sub(start).Seconds())//方式4 insertstart = time.Now()//Begin函數(shù)內(nèi)部會(huì)去獲取連接tx,_ := db.Begin()for i := 1301;i<=1400;i++{//每次循環(huán)用的都是tx內(nèi)部的連接，沒有新建連接，效率高tx.Exec("INSERT INTO user(uid,username,age) values(?,?,?)",i,"user"+strconv.Itoa(i),i-1000)}//最后釋放tx內(nèi)部的連接 tx.Commit()end = time.Now()fmt.Println("方式4 insert total time:",end.Sub(start).Seconds())//方式5 insertstart = time.Now()for i := 1401;i<=1500;i++{//Begin函數(shù)每次循環(huán)內(nèi)部都會(huì)去連接池獲取一個(gè)新的連接，效率低下tx,_ := db.Begin()tx.Exec("INSERT INTO user(uid,username,age) values(?,?,?)",i,"user"+strconv.Itoa(i),i-1000)//Commit執(zhí)行后連接也釋放了 tx.Commit()}end = time.Now()fmt.Println("方式5 insert total time:",end.Sub(start).Seconds()) }

程序輸出結(jié)果：

方式1 insert total time: 3.7952171
方式2 insert total time: 4.3162468
方式3 insert total time: 4.3392482
方式4 insert total time: 0.3970227
方式5 insert total time: 7.3894226
方式1 query total time: 0.0070004
方式2 query total time: 0.0100006
方式3 query total time: 0.0100006
方式1 update total time: 7.3394198
方式2 update total time: 7.8464488
方式3 update total time: 6.0053435
方式4 update total time: 0.6630379000000001
方式5 update total time: 4.5402597
方式1 query total time: 0.0070004
方式2 query total time: 0.0060004
方式3 query total time: 0.008000400000000001
方式1 delete total time: 3.8652211000000003
方式2 delete total time: 3.8582207
方式3 delete total time: 3.6972114
方式4 delete total time: 0.43202470000000004
方式5 delete total time: 3.7972172

6. 深入內(nèi)部分析原因分析

（1）sql.Open("mysql", "username:pwd@/databasename")

功能：返回一個(gè)DB對(duì)象，DB對(duì)象對(duì)于多個(gè)goroutines并發(fā)使用是安全的，DB對(duì)象內(nèi)部封裝了連接池。

實(shí)現(xiàn)：open函數(shù)并沒有創(chuàng)建連接，它只是驗(yàn)證參數(shù)是否合法。然后開啟一個(gè)單獨(dú)goroutines去監(jiān)聽是否需要建立新的連接，當(dāng)有請(qǐng)求建立新連接時(shí)就創(chuàng)建新連接。

注意：open函數(shù)應(yīng)該被調(diào)用一次，通常是沒必要close的。

（2）DB.Exec()

功能：執(zhí)行不返回行（row）的查詢，比如INSERT，UPDATE，DELETE

實(shí)現(xiàn)：DB交給內(nèi)部的exec方法負(fù)責(zé)查詢。exec會(huì)首先調(diào)用DB內(nèi)部的conn方法從連接池里面獲得一個(gè)連接。然后檢查內(nèi)部的driver.Conn實(shí)現(xiàn)了Execer接口沒有，如果實(shí)現(xiàn)了該接口，會(huì)調(diào)用Execer接口的Exec方法執(zhí)行查詢；否則調(diào)用Conn接口的Prepare方法負(fù)責(zé)查詢。

（3）DB.Query()

功能：用于檢索（retrieval），比如SELECT

實(shí)現(xiàn)：DB交給內(nèi)部的query方法負(fù)責(zé)查詢。query首先調(diào)用DB內(nèi)部的conn方法從連接池里面獲得一個(gè)連接，然后調(diào)用內(nèi)部的queryConn方法負(fù)責(zé)查詢。

（4）DB.QueryRow()

功能：用于返回單行的查詢

實(shí)現(xiàn)：轉(zhuǎn)交給DB.Query()查詢

（5）db.Prepare()

功能：返回一個(gè)Stmt。Stmt對(duì)象可以執(zhí)行Exec,Query,QueryRow等操作。

實(shí)現(xiàn)：DB交給內(nèi)部的prepare方法負(fù)責(zé)查詢。prepare首先調(diào)用DB內(nèi)部的conn方法從連接池里面獲得一個(gè)連接，然后調(diào)用driverConn的prepareLocked方法負(fù)責(zé)查詢。

Stmt相關(guān)方法：

st.Exec()

st.Query()

st.QueryRow()

st.Close()

（6）db.Begin()

功能：開啟事務(wù)，返回Tx對(duì)象。調(diào)用該方法后，這個(gè)TX就和指定的連接綁定在一起了。一旦事務(wù)提交或者回滾，該事務(wù)綁定的連接就還給DB的連接池。

實(shí)現(xiàn)：DB交給內(nèi)部的begin方法負(fù)責(zé)處理。begin首先調(diào)用DB內(nèi)部的conn方法從連接池里面獲得一個(gè)連接，然后調(diào)用Conn接口的Begin方法獲得一個(gè)TX。

TX相關(guān)方法：

//內(nèi)部執(zhí)行流程和上面那些差不多，只是沒有先去獲取連接的一步，因?yàn)檫@些操作是和TX關(guān)聯(lián)的，Tx建立的時(shí)候就和一個(gè)連接綁定了，所以這些操作內(nèi)部共用一個(gè)TX內(nèi)部的連接。

tx.Exec()?

tx.Query()

tx.QueryRow()

tx.Prepare()

tx.Commit()

tx.Rollback()

tx.Stmt()//用于將一個(gè)已存在的statement和tx綁定在一起。一個(gè)statement可以不和tx關(guān)聯(lián)，比如db.Prepare()返回的statement就沒有和TX關(guān)聯(lián)。

例子：

updateMoney, err := db.Prepare("UPDATE balance SET money=money+? WHERE id=?")...tx, err := db.Begin()...res, err := tx.Stmt(updateMoney).Exec(123.45, 98293203)

?（7）源碼中Stmt的定義

// Stmt is a prepared statement. Stmt is safe for concurrent use by multiple goroutines. type Stmt struct {// Immutable: db *DB // where we came from query string // that created the Stmt stickyErr error // if non-nil, this error is returned for all operations closemu sync.RWMutex // held exclusively during close, for read otherwise.// If in a transaction, else both nil: tx *Txtxsi *driverStmtmu sync.Mutex // protects the rest of the fields closed bool// css is a list of underlying driver statement interfaces// that are valid on particular connections. This is only// used if tx == nil and one is found that has idle// connections. If tx != nil, txsi is always used. css []connStmt}

（7）幾個(gè)主要struct的內(nèi)部主要的數(shù)據(jù)結(jié)構(gòu)

參考資料

https://github.com/golang/go/wiki/SQLInterface

https://github.com/go-sql-driver/mysql/

http://golang.org/pkg/database/sql/

來源:https://www.cnblogs.com/tsiangleo/p/4483657.html

總結(jié)

以上是生活随笔為你收集整理的golang学习之旅：使用go语言操作mysql数据库(自己测试了)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

上一篇： MySQL: Starting MySQ
下一篇： Redis与RabbitMQ作为消息队列