您好,登錄后才能下訂單哦!
今天小編給大家分享一下go連接mysql的方法是什么的相關(guān)知識(shí)點(diǎn),內(nèi)容詳細(xì),邏輯清晰,相信大部分人都還太了解這方面的知識(shí),所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來(lái)了解一下吧。
創(chuàng)建user表
CREATE TABLE `user` ( `user_id` int NOT NULL AUTO_INCREMENT, `user_name` varchar(100) DEFAULT NULL, `user_code` varchar(100) NOT NULL, `password` varchar(100) NOT NULL, PRIMARY KEY (`user_id`), UNIQUE KEY `user_user_code_IDX` (`user_code`) USING BTREE ) ENGINE=InnoDB AUTO_INCREMENT=15 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
1、新建一個(gè)項(xiàng)目目錄 wms
2、打開(kāi)cmd命令窗口,進(jìn)入wms目錄
3、初始化項(xiàng)目
go mod init fa.com/wms
go mod init 初始化命令,fa.com/wms 為模塊路徑
4、下載go驅(qū)動(dòng)
go get github.com/go-sql-driver/mysql@latest
執(zhí)行g(shù)o get 命令下載最新版本的go mysql驅(qū)動(dòng)
新建mysqlutil.go,用來(lái)建立mysql連接
package db import ( "database/sql" "fmt" "time" //注冊(cè)驅(qū)動(dòng)器 _下劃線表示執(zhí)行驅(qū)動(dòng)中的init函數(shù),不使用其他函數(shù) _ "github.com/go-sql-driver/mysql" ) // 創(chuàng)建數(shù)據(jù)庫(kù)連接 func ConnMySQL() *sql.DB { // 數(shù)據(jù)源名 driverName := "mysql" // 用戶名root // 密碼1234 // tcp協(xié)議連接 // 數(shù)據(jù)庫(kù)地址 // 數(shù)據(jù)庫(kù) wms dataSourceName := "root" + ":" + "1234" + "@" + "tcp" + "(" + "127.0.0.1:3306" + ")" + "/" + "wms" db, err := sql.Open(driverName, dataSourceName) if err != nil { panic(err) } // 數(shù)據(jù)庫(kù)設(shè)置 db.SetConnMaxLifetime(time.Minute * 10) db.SetConnMaxIdleTime(time.Minute * 10) db.SetMaxOpenConns(10) db.SetMaxIdleConns(10) // 連接測(cè)試 err = db.Ping() if err != nil { fmt.Println("數(shù)據(jù)庫(kù)連接失敗") panic(err) } return db }
新建user.go
// 包名 package user import ( "log" // 引入mysql數(shù)據(jù)庫(kù)連接包 "fa.com/wms/db" ) // 定義user類型結(jié)構(gòu)體 type User struct { UserId int UserName string UserCode string Password string } // 向數(shù)據(jù)庫(kù)新增一個(gè)User數(shù)據(jù) func AddUser(u *User) { // 調(diào)用db包ConnMySQL() db := db.ConnMySQL() // 預(yù)編譯保存sql創(chuàng)建 statement stmt, err := db.Prepare("INSERT INTO `user` (user_name, user_code, password) VALUES (?, ?, ?)") // err 不等空則statement創(chuàng)建失敗 if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } // 在函數(shù)運(yùn)行結(jié)束時(shí)關(guān)閉statement defer stmt.Close() // 執(zhí)行保存sql // _下劃線 表示忽略函數(shù)返回的sql.Result值 _, err = stmt.Exec(u.UserName, u.UserCode, u.Password) if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } }
func DeleteById(userId int) { db := db.ConnMySQL() // 預(yù)編譯刪除sql創(chuàng)建 statement stmt, err := db.Prepare("delete from `user` where user_id = ?") // err 不等空則statement創(chuàng)建失敗 if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } // 在函數(shù)運(yùn)行結(jié)束時(shí)關(guān)閉statement defer stmt.Close() // 執(zhí)行刪除sql // _下劃線 表示忽略函數(shù)返回的sql.Result值 _, err = stmt.Exec(userId) if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } }
func UpdateUser(u *User) { db := db.ConnMySQL() // 預(yù)編譯更新sql創(chuàng)建 statement stmt, err := db.Prepare("UPDATE `user` SET user_name=?, user_code=?, password=? WHERE user_id=?") // err 不等空則statement創(chuàng)建失敗 if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } // 在函數(shù)運(yùn)行結(jié)束時(shí)關(guān)閉statement defer stmt.Close() // 執(zhí)行更新sql // _下劃線 表示忽略函數(shù)返回的sql.Result值 _, err = stmt.Exec(u.UserName, u.UserCode, u.Password, u.UserId) if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } }
func QueryUserByCode(code string) []User { // 調(diào)用db包ConnMySQL() db := db.ConnMySQL() // 預(yù)編譯查詢sql創(chuàng)建 statement stmt, err := db.Prepare("SELECT user_id, user_name, user_code, password FROM `user` WHERE user_code= ?") if err != nil { log.Fatal(err) panic(err) } defer stmt.Close() // 執(zhí)行查詢sql,返回查詢結(jié)果rows rows, err := stmt.Query(code) if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) } // 定義User切片 s := make([]User, 0) // 遍歷rows for rows.Next() { u := User{} // 掃描rows的每一列并保存數(shù)據(jù)到User對(duì)應(yīng)字段 err := rows.Scan(&u.UserId, &u.UserName, &u.UserCode, &u.Password) if err != nil { // 打印錯(cuò)誤信息 log.Fatal(err) // 拋出錯(cuò)誤信息,阻止程序繼續(xù)運(yùn)行 panic(err) }, // 掃描后的user加入到切片 s = append(s, u) } return s }
以上代碼使用vscode編寫(xiě),目錄結(jié)構(gòu)如下圖所示:
以上就是“go連接mysql的方法是什么”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會(huì)為大家更新不同的知識(shí),如果還想學(xué)習(xí)更多的知識(shí),請(qǐng)關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。