go連接mysql的項(xiàng)目實(shí)踐

更新時間：2023年03月29日 09:39:52 作者：星星火光

本文主要介紹了go連接mysql的項(xiàng)目實(shí)踐，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一、mysql建表

創(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;

二、mysql驅(qū)動下載

1、新建一個項(xiàng)目目錄 wms

2、打開cmd命令窗口，進(jìn)入wms目錄

在這里插入圖片描述

3、初始化項(xiàng)目

go mod init fa.com/wms

go mod init 初始化命令，fa.com/wms 為模塊路徑

在這里插入圖片描述

4、下載go驅(qū)動

go get github.com/go-sql-driver/mysql@latest

執(zhí)行g(shù)o get 命令下載最新版本的go mysql驅(qū)動

在這里插入圖片描述

三、mysql連接參數(shù)配置

新建mysqlutil.go，用來建立mysql連接

package db

import (
	"database/sql"
	"fmt"
	"time"

	//注冊驅(qū)動器 _下劃線表示執(zhí)行驅(qū)動中的init函數(shù)，不使用其他函數(shù)
	_ "github.com/go-sql-driver/mysql"
)
// 創(chuàng)建數(shù)據(jù)庫連接
func ConnMySQL() *sql.DB {
	// 數(shù)據(jù)源名
	driverName := "mysql"
	// 用戶名root
	// 密碼1234
	// tcp協(xié)議連接
	// 數(shù)據(jù)庫地址
	// 數(shù)據(jù)庫 wms
	dataSourceName := "root" + ":" + "1234" + "@" + "tcp" + "(" + "127.0.0.1:3306" + ")" + "/" + "wms"
	db, err := sql.Open(driverName, dataSourceName)
	if err != nil {
		panic(err)
	}

	// 數(shù)據(jù)庫設(shè)置
	db.SetConnMaxLifetime(time.Minute * 10)
	db.SetConnMaxIdleTime(time.Minute * 10)
	db.SetMaxOpenConns(10)
	db.SetMaxIdleConns(10)

	// 連接測試
	err = db.Ping()
	if err != nil {
		fmt.Println("數(shù)據(jù)庫連接失敗")
		panic(err)
	}
	return db
}

四、mysql新增數(shù)據(jù)

新建user.go

// 包名
package user

import (
	"log"
	// 引入mysql數(shù)據(jù)庫連接包
	"fa.com/wms/db"
)
// 定義user類型結(jié)構(gòu)體
type User struct {
	UserId   int
	UserName string
	UserCode string
	Password string
}

// 向數(shù)據(jù)庫新增一個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 {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
	// 在函數(shù)運(yùn)行結(jié)束時關(guān)閉statement
	defer stmt.Close()
	// 執(zhí)行保存sql
	// _下劃線 表示忽略函數(shù)返回的sql.Result值
	_, err = stmt.Exec(u.UserName, u.UserCode, u.Password)
	if err != nil {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
}

五、mysql刪除數(shù)據(jù)

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 {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
	// 在函數(shù)運(yùn)行結(jié)束時關(guān)閉statement
	defer stmt.Close()
	// 執(zhí)行刪除sql
	// _下劃線 表示忽略函數(shù)返回的sql.Result值
	_, err = stmt.Exec(userId)
	if err != nil {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
}

六、mysql修改數(shù)據(jù)

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 {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
	// 在函數(shù)運(yùn)行結(jié)束時關(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 {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
}

七、mysql查詢數(shù)據(jù)

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 {
		// 打印錯誤信息
		log.Fatal(err)
		// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
		panic(err)
	}
	// 定義User切片
	s := make([]User, 0)
	// 遍歷rows
	for rows.Next() {
		u := User{}
		// 掃描rows的每一列并保存數(shù)據(jù)到User對應(yīng)字段
		err := rows.Scan(&u.UserId, &u.UserName, &u.UserCode, &u.Password)
		if err != nil {
			// 打印錯誤信息
			log.Fatal(err)
			// 拋出錯誤信息，阻止程序繼續(xù)運(yùn)行
			panic(err)
		}，
		// 掃描后的user加入到切片
		s = append(s, u)
	}
	return s
}

以上代碼使用vscode編寫，目錄結(jié)構(gòu)如下圖所示：

在這里插入圖片描述