Go語(yǔ)言操作Mysql語(yǔ)言基礎(chǔ)知識(shí)
回復(fù)“Go語(yǔ)言”即可獲贈(zèng)從入門到進(jìn)階共10本電子書
前言
通常情況下，我們程序員和數(shù)據(jù)庫(kù)打交道是最多的。要然我們?cè)趺磿?huì)被稱為碼農(nóng)呢。
存用戶信息需要數(shù)據(jù)庫(kù)，存訂單需要數(shù)據(jù)庫(kù)，等等等等，現(xiàn)在真是數(shù)據(jù)驅(qū)動(dòng)著發(fā)展。
但是數(shù)據(jù)庫(kù)種類有很多，有Mysql，Oracle，SQL Server。
本篇就示例如何Go操作Mysql。
準(zhǔn)備工作
本次使用的是go mod進(jìn)行包依賴管理，還不會(huì)使用的向上爬梯子，找go mod用法。
使用的庫(kù)是第三方庫(kù)go-sql-driver/mysql。
準(zhǔn)備工作之連接數(shù)據(jù)庫(kù)
代碼
func main() {var username = "root"var password = "rootroot"var ip = "127.0.0.1"var port = "3306"var data = "go_mysql_demo"var dsn = fmt.Sprintf("%s:%s@tcp(%s:%s)/%s"， username， password， ip， port， data)//Open只會(huì)驗(yàn)證dsb的格式是否正確，不會(huì)驗(yàn)證是否連接成功，同理，密碼是否正確也不知道db， err := sql.Open("mysql"， dsn)if err != nil {panic(err)}//關(guān)閉連接在 err 之后，因?yàn)榭赡苤苯泳痛蜷_(kāi)不成功，關(guān)閉一個(gè)沒(méi)有打開(kāi)的連接???defer db.Close()// 此時(shí)嘗試連接數(shù)據(jù)庫(kù)，會(huì)判斷用戶，密碼，ip地址，端口是否正確err = db.Ping()if err != nil {fmt.Println("連接數(shù)據(jù)庫(kù)失敗，"，err)return}//設(shè)置與數(shù)據(jù)庫(kù)建立連接的最大數(shù)目，一般不管db.SetMaxOpenConns(100)//設(shè)置連接池中的最大閑置連接數(shù)，一般不管db.SetMaxIdleConns(50)}
注意
sql.Open只會(huì)驗(yàn)證格式是否正確，不會(huì)連接數(shù)據(jù)庫(kù)。db.Close在err之后，是因?yàn)榭赡艽蜷_(kāi)不成功，關(guān)閉一個(gè)沒(méi)有打開(kāi)的連接。db.Ping會(huì)連接數(shù)據(jù)庫(kù)，判斷用戶，密碼，ip地址，端口是否正確。
準(zhǔn)備工作之創(chuàng)建表
我們創(chuàng)建一個(gè)簡(jiǎn)單的用戶表。
CREATE TABLE `userinfo` (`id` int(11) NOT NULL AUTO_INCREMENT，`name` varchar(10) DEFAULT NULL，`phone` char(11) DEFAULT NULL，`address` varchar(64) DEFAULT NULL，PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
準(zhǔn)備工作之創(chuàng)建結(jié)構(gòu)體
假設(shè)上述工作都完成了啊。
不知道有沒(méi)有想過(guò)，我們查詢的數(shù)據(jù)，存成啥？，字符串?map?切片？，似乎都不是太好。
只有結(jié)構(gòu)體是最清晰的，最好認(rèn)識(shí)的。
結(jié)構(gòu)體
type Userinfo struct {Id int64 `json:"id"`Name string `json:"name"`Phone string `json:"phone"`Address string `json:"address"`}
查詢單條
單條查詢使用QueryRow方法。
代碼
//查詢單條sqlStr := "SELECT id，`name`，phone，address from userinfo where id = ?;"var user Userinfo/*QueryRow 第二個(gè)參數(shù)可以接收多個(gè)參數(shù)，同理，sqlStr可以有多個(gè) ?占位符 進(jìn)行匹配QueryRow 之后必須調(diào)用Scan方法進(jìn)行數(shù)據(jù)綁定，進(jìn)行數(shù)據(jù)庫(kù)鏈接釋放*/err = db.QueryRow(sqlStr， 1).Scan(&user.Id， &user.Name， &user.Phone， &user.Address)if err != nil {fmt.Println("查詢失敗"， err)return}fmt.Println(user)
執(zhí)行結(jié)果
查詢多條
多行查詢使用Query。
代碼
//查詢多條sqlStr := "SELECT id，`name`，phone，address from userinfo where id >= ?"//參數(shù)同 QueryRowrows， err := db.Query(sqlStr， 1)if err != nil {fmt.Println("查詢失敗:"， err)return}// 此處使用rows釋放所有鏈接defer rows.Close()//循環(huán)整理所有數(shù)據(jù)var userList = make([]Userinfo， 0， 10)for rows.Next() {var user Userinfoerr = rows.Scan(&user.Id， &user.Name， &user.Phone， &user.Address)if err != nil {fmt.Println("綁定數(shù)據(jù)失敗"， err)return}userList = append(userList， user)}fmt.Println(userList)
執(zhí)行結(jié)果
插入數(shù)據(jù)
插入數(shù)據(jù)需要用到Exec。
代碼
//插入數(shù)據(jù)sqlStr := "INSERT into userinfo(name，phone，address) values(?，?，?);"result， err := db.Exec(sqlStr， "吳彥祖"， 555， "不知道哪的")if err != nil {fmt.Println("插入失敗"， err)return}//受影響的行數(shù)row_affect， err := result.RowsAffected()if err != nil {fmt.Println("受影響行數(shù)獲取失敗:"， err)return}fmt.Println("受影響的行數(shù):"， row_affect)lastId， err := result.LastInsertId()if err != nil {fmt.Println("新增行id獲取失敗:"， err)return}fmt.Println("新增行id:"， lastId)fmt.Println("插入成功")
執(zhí)行結(jié)果
Mysql
更新數(shù)據(jù)
更新和添加差不多，用的都是Exec。
代碼
//更新數(shù)據(jù)sqlStr := `UPDATE userinfo set name=? where id=?;`result， err := db.Exec(sqlStr， "吳彥祖666"， 3)if err != nil {fmt.Println("更新失敗"， err)return}//受影響的行數(shù)row_affect， err := result.RowsAffected()if err != nil {fmt.Println("受影響行數(shù)獲取失敗:"， err)return}fmt.Println("受影響的行數(shù):"， row_affect)fmt.Println("更新成功")
執(zhí)行結(jié)果
Mysql
刪除數(shù)據(jù)
刪除數(shù)據(jù)用的還是Exec。
代碼
//刪除數(shù)據(jù)sqlStr := "delete from userinfo where id = ?;"result， err := db.Exec(sqlStr， 3)if err != nil {fmt.Println("刪除失敗"， err)return}//受影響的行數(shù)row_affect， err := result.RowsAffected()if err != nil {fmt.Println("受影響行數(shù)獲取失敗:"， err)return}fmt.Println("受影響的行數(shù):"， row_affect)fmt.Println("刪除成功")
執(zhí)行結(jié)果
Mysql
事物
事物，這個(gè)用的就比較多了，通常用在關(guān)鍵的場(chǎng)景。
尤其是轉(zhuǎn)賬，張三-10塊，李四+10塊，這個(gè)動(dòng)作動(dòng)作是要在一起完成的。
如果任何一個(gè)失敗了，就要恢復(fù)上一次的狀態(tài)。
我們通常也叫這個(gè)操作叫做原子操作，要成功，都成功，要完蛋，都完蛋。
新建表
CREATE TABLE `bill` (`id` int(11) NOT NULL AUTO_INCREMENT，`name` varchar(8) NOT NULL，`money` int(11) NOT NULL，PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4;
表數(shù)據(jù)
張三和李四都剩余100塊
Go Mysql 關(guān)于事物相關(guān)方法
Go 關(guān)于事物有三個(gè)方法
Begin()開(kāi)始事物。Commit()提交事物。Rollback()失敗回滾。
模擬轉(zhuǎn)賬:張三-10塊，李四+十塊
代碼
func main() {//事物//開(kāi)啟事物tx， err := db.Begin()if err != nil {//釋放事物if tx != nil {tx.Rollback()}fmt.Println("事物開(kāi)啟失敗")return}張三減10塊Sql := `UPDATE bill set money=money - 10 where name = ?;`result， err := tx.Exec(張三減10塊Sql， "張三")if err != nil {//有錯(cuò)誤表示更是失敗，回滾原來(lái)狀態(tài)tx.Rollback()fmt.Println(err)return}張三受影響行數(shù)， err := result.RowsAffected()if err != nil {tx.Rollback() // 回滾return}李四加10塊Sql := `UPDATE bill set money=money + 10 where name = ?;`result， err = tx.Exec(李四加10塊Sql， "李四")if err != nil {//有錯(cuò)誤表示更是失敗，回滾原來(lái)狀態(tài)tx.Rollback()fmt.Println(err)return}李四受影響行數(shù)， err := result.RowsAffected()if err != nil {tx.Rollback() // 回滾return}//都等于1表示成功，可以提交事務(wù)，修改數(shù)據(jù)if 張三受影響行數(shù)==1 && 李四受影響行數(shù)==1{//提交事務(wù)fmt.Println("提交事務(wù)")tx.Commit()}else{//有一個(gè)!=1表示沒(méi)有更新成功，可能用戶不存在fmt.Println("失敗了，事物回滾了")tx.Rollback()}fmt.Println("事物執(zhí)行成功")}
執(zhí)行結(jié)果
Mysql
一加一減
假如出錯(cuò)了
Mysql
如果使用事物，出錯(cuò)了數(shù)據(jù)還是沒(méi)變。
總結(jié)
本次主要講述了Go如何操作Mysql，如何進(jìn)行增刪改查，最后還講了以下什么是事物，如何操作事物。
當(dāng)然，這種是最原始的方法，過(guò)程有些繁瑣，了解入門就好，后面還有更方便的方法。
如果在操作過(guò)程中有任何問(wèn)題，記得下面留言，我們看到會(huì)第一時(shí)間解決問(wèn)題。
如果你覺(jué)得文章還可以，記得點(diǎn)贊留言支持我們哈。感謝你的閱讀，有問(wèn)題請(qǐng)記得在下方留言噢~
想學(xué)習(xí)更多關(guān)于Python的知識(shí)，可以參考學(xué)習(xí)網(wǎng)址：http://pdcfighting.com/，點(diǎn)擊閱讀原文，可以直達(dá)噢~
-------------------?End?-------------------
往期精彩文章推薦：
歡迎大家點(diǎn)贊，留言，轉(zhuǎn)發(fā)，轉(zhuǎn)載，感謝大家的相伴與支持
想加入Go學(xué)習(xí)群請(qǐng)?jiān)诤笈_(tái)回復(fù)【入群】
萬(wàn)水千山總是情，點(diǎn)個(gè)【在看】行不行