go连接Mysql

环境

go version:go1.14.4
go-mysql-driver:github.com/go-sql-driver/mysql

首先使用go mod init初始化项目的模块文件并做相关操作，关于go module可详见此链接

go测试Mysql连接

声明，以下代码中引用自博客:https://blog.csdn.net/naiwenw/article/details/79281220

1. import相关依赖:

import (
	"database/sql"
	_"github.com/go-sql-driver/mysql"
)

备注:database/sql提供一些操作SQL数据库的接口，它必须与某特定数据库的driver一起使用，第二项即引入mysql的drive。github.com/go-sql-driver/mysql前的下划线代表只是调用包的init函数，因为github.com/go-sql-driver/mysql只是作为驱动，我们不会调用它的函数，所以加下划线不会提示包未引用的错误

2. 本地开启数据库，使用代码测试连通性
   定义相关常量:

const (
	userName = "root" //登录Mysql的用户名
	password = "passwd" //对应用户名的密码
	ip = "127.0.0.1" //ip地址
	port = "3306" //端口
	dbName = "dbName" //数据库名字
)

创建一个DB对象

var DB *sql.DB

将DB变量与数据库关联

func InitDB()  {
	//构建连接："用户名:密码@tcp(IP:端口)/数据库?charset=utf8"
	path := strings.Join([]string{userName, ":", password, "@tcp(",ip, ":", port, ")/", dbName, "?charset=utf8"}, "")

	//打开数据库,前者是驱动名，所以要导入： _ "github.com/go-sql-driver/mysql"
	DB, _ = sql.Open("mysql", path)
	//设置数据库最大连接数
	DB.SetConnMaxLifetime(100)
	//设置上数据库最大闲置连接数
	DB.SetMaxIdleConns(10)
	//验证连接
	if err := DB.Ping(); err != nil{
		fmt.Println("opon database fail")
		return
	}
	fmt.Println("connnect success")
}

如果运行之后打印connect success，则代表连接mysql成功

插入操作

1. 使用上一部分中与数据库关联的DB变量，构造事务

tx, err := DB.Begin()
	if err != nil {
		fmt.Println("tx fail")
		return false
	}

2. 传入sql语句，并执行

	stmt,err := tx.Prepare("insert into auth_group(`col1Name`,`col2Name`) values (?,?)")//?用于后面传参
	if err !=nil {
		fmt.Println("prepare fail")
		return false
	}
	res,err := stmt.Exec(user.Id,user.Name)
	if err != nil{
		fmt.Println("resut fail")
		return false
	}

3. 提交事务，并打印插入的id号

	tx.Commit()
	fmt.Println(res.LastInsertId())

完整代码:

type group struct{
	Id int
	Name string
}
func Insert(user group )  bool{
	tx, err := DB.Begin()
	if err != nil {
		fmt.Println("tx fail")
		return false
	}
	stmt,err := tx.Prepare("insert into auth_group(`id`,`name`) values (?,?)")
	if err !=nil {
		fmt.Println("prepare fail")
		return false
	}
	res,err := stmt.Exec(user.Id,user.Name)
	if err != nil{
		fmt.Println("resut fail")
		return false
	}
	tx.Commit()
	fmt.Println(res.LastInsertId())
	return true
}

查询操作

• 查询单行

DB.QueryRow("SELECT * FROM auth_group where id = ?",id).Scan(&user.Id,&user.Name)

QueryRow:最多返回一行,查询不到结果或查询结果多于一行都将产生错误。
Scan:将结果存入某个结构体，以便返回给查询者
完整代码：

func Select(id int)  group{
	var user group
	err := DB.QueryRow("SELECT * FROM auth_group where id in (1,2)",id).Scan(&user.Id,&user.Name)
	if err !=nil{
		fmt.Println("查询出错11")
	}
	return user
}

• 查询多行

1. 得到查询结果集合

rows,err := DB.Query("SELECT * from auth_group")

Query:执行查询语句，并返回Rows对象

2. 遍历rows

	for rows.Next(){
		var user group
		err := rows.Scan(&user.Id,&user.Name)//此行的结果
		if err != nil {
			fmt.Println("rows fail")
		}
		users=append(users,user)//将此次扫描的结果放入users集合
	}

完整代码:

func SelectAll() []group {
	rows,err := DB.Query("SELECT * from auth_group")
	if err !=nil{
		fmt.Println("查询出错")
	}
	var users []group
	for rows.Next(){
		var user group
		err := rows.Scan(&user.Id,&user.Name)
		if err != nil {
			fmt.Println("rows fail")
		}
		users=append(users,user)
	}
	return users
}

Delete操作

与insert操作类似，首先通过DB.Begin()获取事务实例，然后通过tx执行删除语句，最后执行事务的提交
完整代码：

func Delete(id int)  bool{
	tx,err :=DB.Begin()
	if err!=nil{
		fmt.Println("delete tx fail")
		return false
	}
	stmt,err :=tx.Prepare("delete from auth_group where id =?")
	if err !=nil{
		fmt.Println("delete stmt fail")
		return false
	}
	res,err := stmt.Exec(id)
	if err!=nil{
		fmt.Println("delete res fail")
		return false
	}
	tx.Commit()
	fmt.Println(res.RowsAffected())
	return true
}

Update操作

与insert操作类似，首先通过DB.Begin()获取事务实例，然后通过tx执行update语句，最后执行事务的提交
完整代码:

func Update(id int,name string)  bool{
	tx, err := DB.Begin()
	if err != nil{
		fmt.Println("tx fail")
	}
	//准备sql语句
	stmt, err := tx.Prepare("UPDATE auth_group SET name = ? WHERE id = ?")
	if err != nil{
		fmt.Println("Prepare fail")
		return false
	}
	//设置参数以及执行sql语句
	_, err = stmt.Exec(name, id)
	if err != nil{
		fmt.Println("Exec fail")
		return false
	}
	//提交事务
	tx.Commit()
	return true
}

最后：
database/sql API官方文档:https://golang.org/pkg/database/sql/#DB.Query

本文地址：https://blog.csdn.net/qq_44025685/article/details/107134529