golang 操作mysql示例（增、删、改、查、事务）
来源：SegmentFault
时间：2023-01-25 15:35:13 125浏览 收藏
亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《golang 操作mysql示例（增、删、改、查、事务）》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下MySQL、事务、go，希望所有认真读完的童鞋们，都有实质性的提高。
准备
go的系统包里是没有数据库驱动的，首先先从git上下载mysql包，golang下载资源包相当方便，打开命令行，输入命令：
go get -u github.com/go-sql-driver/mysql(使用git命令下载资源包，需要先安装git，没安装git的同学可以手动下载后放入src目录下)。!
下载完成会在GOPATH下的src里多了资源包
下载完成后，在项目里import mysql包,用下划线_是表示我们只需要用到包里的init()函数，而不需要调用里面的方法。
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql" //导入mysql包
"time"
)
准备数据表
我们来准备一张医生表doctor_tb，包含姓名、年龄、性别、添加时间等，后面我们会对这张表做增删改查的操作。建表语句如下：
CREATE TABLE `doctor_tb` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(50) DEFAULT '' COMMENT '姓名', `age` int(11) DEFAULT '0' COMMENT '年龄', `sex` int(11) DEFAULT '0' COMMENT '性别', `addTime` datetime DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='医生表';
1、打开数据库链接
db, err := sql.Open("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8&parseTime=True")mysql数据库的链接字符串组织：
用户名:密码@tcp(数据库IP:端口)/数据库名?charset=utf8&parseTime=True，如果你的表里有应用到datetime字段，记得要加上parseTime=True，不然解析不了这个类型。
//-------1、打开数据库--------
db, err := sql.Open("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8&parseTime=True")
if err != nil {
fmt.Println("数据库链接错误", err)
return
}
//延迟到函数结束关闭链接
defer db.Close()
2、查询单条数据
代码：
//-------2、查询单条数据--------
//定义接收数据的结构
var doc Doctor
//执行单条查询
rows := db.QueryRow("select * from doctor_tb where id = ?", 1)
rows.Scan(&doc.ID, &doc.Name, &doc.Age, &doc.Sex, &doc.AddTime)
fmt.Println("单条数据结果：", doc)
执行结果：
解析：
查询id=1的数据
rows := db.QueryRow("select * from doctor_tb where id = ?", 1) rows.Scan用于把读取的数据赋值到Doctor对象的属性上，要注意字段顺序。
3、查询数据列表
代码：
//-------3、查询数据列表--------
rows2, err := db.Query("select * from doctor_tb where age > ?", 18)
if err != nil {
fmt.Println("多条数据查询错误", err)
return
}
//定义对象数组,用于接收数据
var docList []Doctor
for rows2.Next() {
var doc2 Doctor
rows2.Scan(&doc2.ID, &doc2.Name, &doc2.Age, &doc2.Sex, &doc2.AddTime)
//加入数组
docList = append(docList, doc2)
}
fmt.Println("多条数据查询结果", docList)
执行结果：
解析：
查询年龄age大于18岁的成年医生
rows2, err := db.Query("select * from doctor_tb where age > ?", 18)迭代数据查询
rows2.Next()
赋值
rows2.Scan(&doc2.ID, &doc2.Name, &doc2.Age, &doc2.Sex, &doc2.AddTime)
加入数组
docList = append(docList, doc2)
4、新增数据
代码：
//-------4、新增数据--------
result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)
if err != nil {
fmt.Println("新增数据错误", err)
return
}
newID, _ := result.LastInsertId() //新增数据的ID
i, _ := result.RowsAffected() //受影响行数
fmt.Printf("新增的数据ID：%d , 受影响行数：%d \n", newID, i)
执行结果：
解析：
新增一位40岁的女性林医生
result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)新增数据的ID
result.LastInsertId()
受影响行数
result.RowsAffected()
5、修改数据
代码：
//-------5、修改数据--------
result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)
if err != nil {
fmt.Println("修改数据错误", err)
return
}
i2, _ := result2.RowsAffected() //受影响行数
fmt.Printf("受影响行数：%d \n", i2)
执行结果：
解析：
编号为1的医生年龄变为20岁
result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)
6、删除数据
代码：
//-------6、删除数据--------
result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")
if err != nil {
fmt.Println("删除数据错误", err)
return
}
i3, _ := result3.RowsAffected()
fmt.Printf("受影响行数：%d \n", i3)
执行结果：
解析：
删除姓名叫叶子的医生
result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")
7、事务
代码:
//-------7、事务\--------
tx, _ := db.Begin()
result4, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "钟南山")
result5, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "叶子")
//影响行数，为0则失败
i4, _ := result4.RowsAffected()
i5, _ := result5.RowsAffected()
if i4 > 0 && i5 > 0 {
//2条数据都更新成功才提交事务
err = tx.Commit()
if err != nil {
fmt.Println("事务提交失败", err)
return
}
fmt.Println("事务提交成功")
} else {
//否则回退事务
err = tx.Rollback()
if err != nil {
fmt.Println("回退事务失败", err)
return
}
fmt.Println("回退事务成功")
}
执行结果：
解析：
准备事务
tx, _ := db.Begin()
钟南山年龄加1岁
result4, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "钟南山")叶子年龄加1岁
result5, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "叶子")如果2条数据更新能成功则提交事务
err = tx.Commit()
否则回退事务,一切就当没发生过
tx.Rollback()
完整demo代码
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql" //导入mysql包
"time"
)
type Doctor struct {
ID int64
Name string
Age int
Sex int
AddTime time.Time
}
func main() {
//-------1、打开数据库--------
db, err := sql.Open("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8&parseTime=True")
if err != nil {
fmt.Println("数据库链接错误", err)
return
}
//延迟到函数结束关闭链接
defer db.Close()
//-------2、查询单条数据--------
//定义接收数据的结构
var doc Doctor
//执行单条查询
rows := db.QueryRow("select * from doctor_tb where id = ?", 1)
rows.Scan(&doc.ID, &doc.Name, &doc.Age, &doc.Sex, &doc.AddTime)
fmt.Println("单条数据结果：", doc)
//-------3、查询数据列表--------
rows2, err := db.Query("select * from doctor_tb where age > ?", 18)
if err != nil {
fmt.Println("多条数据查询错误", err)
return
}
//定义对象数组,用于接收数据
var docList []Doctor
for rows2.Next() {
var doc2 Doctor
rows2.Scan(&doc2.ID, &doc2.Name, &doc2.Age, &doc2.Sex, &doc2.AddTime)
//加入数组
docList = append(docList, doc2)
}
fmt.Println("多条数据查询结果", docList)
//-------4、新增数据--------
result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)
if err != nil {
fmt.Println("新增数据错误", err)
return
}
newID, _ := result.LastInsertId() //新增数据的ID
i, _ := result.RowsAffected() //受影响行数
fmt.Printf("新增的数据ID：%d , 受影响行数：%d \n", newID, i)
//-------5、修改数据--------
result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)
if err != nil {
fmt.Println("修改数据错误", err)
return
}
i2, _ := result2.RowsAffected() //受影响行数
fmt.Printf("受影响行数：%d \n", i2)
//-------6、删除数据--------
result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")
if err != nil {
fmt.Println("删除数据错误", err)
return
}
i3, _ := result3.RowsAffected()
fmt.Printf("受影响行数：%d \\n", i3)
//-------7、事务--------
tx, _ := db.Begin()
result4, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "钟南山")
result5, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "叶子")
//影响行数，为0则失败
i4, _ := result4.RowsAffected()
i5, _ := result5.RowsAffected()
if i4 > 0 && i5 > 0 {
//2条数据都更新成功才提交事务
err = tx.Commit()
if err != nil {
fmt.Println("事务提交失败", err)
return
}
fmt.Println("事务提交成功")
} else {
//否则回退事务
err = tx.Rollback()
if err != nil {
fmt.Println("回退事务失败", err)
return
}
fmt.Println("回退事务成功")
}
}
总结
到这里，我们也就讲完了《golang 操作mysql示例（增、删、改、查、事务）》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于mysql的知识点！
声明：本文转载于：SegmentFault 如有侵犯，请联系study_golang@163.com删除
相关阅读
更多>
-
499 收藏
-
244 收藏
-
235 收藏
-
157 收藏
-
101 收藏
最新阅读
更多>
-
117 收藏
-
411 收藏
-
420 收藏
-
264 收藏
-
266 收藏
-
392 收藏
-
333 收藏
-
234 收藏
-
448 收藏
-
416 收藏
-
225 收藏
-
145 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。
- 立即学习 485次学习