今天小编给大家分享一下go连接mysql的方法是什么的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。
一、mysql建表
创建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驱动下载
新建一个项目目录 wms
打开cmd命令窗口，进入wms目录
初始化项目
go mod init fa.com/wmsgo mod init 初始化命令，fa.com/wms 为模块路径
下载go驱动
go get github.com/go-sql-driver/mysql@latest执行go get 命令下载最新版本的go mysql驱动
三、mysql连接参数配置
新建mysqlutil.go，用来建立mysql连接
package dbimport ("database/sql""fmt""time"//注册驱动器 _下划线表示执行驱动中的init函数，不使用其他函数_ "github.com/go-sql-driver/mysql")// 创建数据库连接func ConnMySQL() *sql.DB {// 数据源名driverName := "mysql"// 用户名root// 密码1234// tcp协议连接// 数据库地址// 数据库 wmsdataSourceName := "root" + ":" + "1234" + "@" + "tcp" + "(" + "127.0.0.1:3306" + ")" + "/" + "wms"db, err := sql.Open(driverName, dataSourceName)if err != nil {panic(err)}// 数据库设置db.SetConnMaxLifetime(time.Minute * 10)db.SetConnMaxIdleTime(time.Minute * 10)db.SetMaxOpenConns(10)db.SetMaxIdleConns(10)// 连接测试err = db.Ping()if err != nil {fmt.Println("数据库连接失败")panic(err)}return db}四、mysql新增数据
新建user.go
// 包名package userimport ("log"// 引入mysql数据库连接包"fa.com/wms/db")// 定义user类型结构体type User struct {UserId intUserName stringUserCode stringPassword string}// 向数据库新增一个User数据func AddUser(u *User) {// 调用db包ConnMySQL()db := db.ConnMySQL()// 预编译保存sql创建 statementstmt, err := db.Prepare("INSERT INTO `user`(user_name, user_code, password) VALUES (?, ?, ?)")// err 不等空则statement创建失败if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}// 在函数运行结束时关闭statementdefer stmt.Close()// 执行保存sql// _下划线 表示忽略函数返回的sql.Result值_, err = stmt.Exec(u.UserName, u.UserCode, u.Password)if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}}五、mysql删除数据
func DeleteById(userId int) {db := db.ConnMySQL()// 预编译删除sql创建 statementstmt, err := db.Prepare("delete from `user` where user_id = ?")// err 不等空则statement创建失败if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}// 在函数运行结束时关闭statementdefer stmt.Close()// 执行删除sql// _下划线 表示忽略函数返回的sql.Result值_, err = stmt.Exec(userId)if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}}六、mysql修改数据
func UpdateUser(u *User) {db := db.ConnMySQL()// 预编译更新sql创建 statementstmt, err := db.Prepare("UPDATE `user` SET user_name=?, user_code=?, password=? WHERE user_id=?")// err 不等空则statement创建失败if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}// 在函数运行结束时关闭statementdefer stmt.Close()// 执行更新sql// _下划线 表示忽略函数返回的sql.Result值_, err = stmt.Exec(u.UserName, u.UserCode, u.Password, u.UserId)if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}}七、mysql查询数据
func QueryUserByCode(code string) []User {// 调用db包ConnMySQL()db := db.ConnMySQL()// 预编译查询sql创建 statementstmt, 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()// 执行查询sql，返回查询结果rowsrows, err := stmt.Query(code)if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}// 定义User切片s := make([]User, 0)// 遍历rowsfor rows.Next() {u := User{}// 扫描rows的每一列并保存数据到User对应字段err := rows.Scan(&u.UserId, &u.UserName, &u.UserCode, &u.Password)if err != nil {// 打印错误信息log.Fatal(err)// 抛出错误信息，阻止程序继续运行panic(err)}，// 扫描后的user加入到切片s = append(s, u)}return s}以上代码使用vscode编写，目录结构如下图所示：
以上就是“go连接mysql的方法是什么”这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注编程网行业资讯频道。
