go连接mysql的项目实践

 更新时间:2023年03月29日 09:39:52   作者:星星火光  
本文主要介绍了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驱动下载

1、新建一个项目目录 wms

2、打开cmd命令窗口,进入wms目录

在这里插入图片描述

3、初始化项目

go mod init fa.com/wms

go mod init 初始化命令,fa.com/wms 为模块路径

在这里插入图片描述

4、下载go驱动

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

执行go get 命令下载最新版本的go mysql驱动

在这里插入图片描述

三、mysql连接参数配置

新建mysqlutil.go,用来建立mysql连接

package db

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

	//注册驱动器 _下划线表示执行驱动中的init函数,不使用其他函数
	_ "github.com/go-sql-driver/mysql"
)
// 创建数据库连接
func ConnMySQL() *sql.DB {
	// 数据源名
	driverName := "mysql"
	// 用户名root
	// 密码1234
	// tcp协议连接
	// 数据库地址
	// 数据库 wms
	dataSourceName := "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 user

import (
	"log"
	// 引入mysql数据库连接包
	"fa.com/wms/db"
)
// 定义user类型结构体
type User struct {
	UserId   int
	UserName string
	UserCode string
	Password string
}

// 向数据库新增一个User数据
func AddUser(u *User) {
	// 调用db包ConnMySQL()
	db := db.ConnMySQL()
	// 预编译保存sql创建 statement
	stmt, err := db.Prepare("INSERT INTO `user`	(user_name, user_code, password) VALUES (?, ?, ?)")
	// err 不等空则statement创建失败
	if err != nil {
		// 打印错误信息
		log.Fatal(err)
		// 抛出错误信息,阻止程序继续运行
		panic(err)
	}
	// 在函数运行结束时关闭statement
	defer 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创建 statement
	stmt, err := db.Prepare("delete from `user`  where user_id = ?")
	// err 不等空则statement创建失败
	if err != nil {
		// 打印错误信息
		log.Fatal(err)
		// 抛出错误信息,阻止程序继续运行
		panic(err)
	}
	// 在函数运行结束时关闭statement
	defer 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创建 statement
	stmt, err := db.Prepare("UPDATE `user` SET user_name=?, user_code=?, password=? WHERE user_id=?")
	// err 不等空则statement创建失败
	if err != nil {
		// 打印错误信息
		log.Fatal(err)
		// 抛出错误信息,阻止程序继续运行
		panic(err)
	}
	// 在函数运行结束时关闭statement
	defer 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创建 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()
	// 执行查询sql,返回查询结果rows
	rows, err := stmt.Query(code)
	if err != nil {
		// 打印错误信息
		log.Fatal(err)
		// 抛出错误信息,阻止程序继续运行
		panic(err)
	}
	// 定义User切片
	s := make([]User, 0)
	// 遍历rows
	for 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的项目实践的文章就介绍到这了,更多相关go连接mysql内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Go-Web框架中AOP方案的实现方式

    Go-Web框架中AOP方案的实现方式

    本文主要介绍了Go-Web框架中AOP方案的实现方式,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-06-06
  • Go并发编程sync.Cond的具体使用

    Go并发编程sync.Cond的具体使用

    Go 标准库提供 Cond 原语的目的是,为等待 / 通知场景下的并发问题提供支持,本文主要介绍了Go并发编程sync.Cond的具体使用,具有一定的参考价值,感兴趣的可以了解一下
    2022-05-05
  • Go语言使用GORM操作数据库使用指南

    Go语言使用GORM操作数据库使用指南

    GORM(全称为Go Object Relational Mapping)是一个在Go语言中使用的轻量级的对象关系映射(ORM)库,本文主要为大家介绍了GORM操作数据库具体方法,需要的可以参考一下
    2023-05-05
  • 浅谈Go Slice 高级实践

    浅谈Go Slice 高级实践

    这篇文章主要介绍了浅谈Go Slice 高级实践,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-08-08
  • golang的匿名函数和普通函数的区别解析

    golang的匿名函数和普通函数的区别解析

    匿名函数是不具名的函数,可以在不定义函数名的情况下直接使用,通常用于函数内部的局部作用域中,这篇文章主要介绍了golang的匿名函数和普通函数的区别,需要的朋友可以参考下
    2023-03-03
  • go语言版的ip2long函数实例

    go语言版的ip2long函数实例

    这篇文章主要介绍了go语言版的ip2long函数,实例分析了Go语言实现的ip2long函数技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-02-02
  • Go gRPC服务proto数据验证进阶教程

    Go gRPC服务proto数据验证进阶教程

    这篇文章主要为大家介绍了Go gRPC服务proto数据验证进阶教程示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-06-06
  • Go语言中实现Unix风格的进程管道方法实例

    Go语言中实现Unix风格的进程管道方法实例

    这篇文章主要为大家介绍了Go语言中实现Unix风格的进程管道方法实例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12
  • 如何在Golang中运行JavaScript

    如何在Golang中运行JavaScript

    最近写一个程序,接口返回的数据是js格式的,需要通过golang来解析js,所以下面这篇文章主要给大家介绍了关于如何在Golang中运行JavaScript的相关资料,需要的朋友可以参考下
    2022-01-01
  • Go语言基础反射示例详解

    Go语言基础反射示例详解

    这篇文章主要为大家介绍了Go语言基础关于反射示例的内容详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加薪
    2021-11-11

最新评论