当前位置： 首页 > news >正文

golang学习笔记18——golang 访问 mysql 数据库全解析

news 2025/6/24 16:07:31
  • 推荐学习文档
    • golang应用级os框架，欢迎star
    • 基于golang开发的一款超有个性的旅游计划app经历
    • golang实战大纲
    • golang优秀开发常用开源库汇总
    • golang学习笔记01——基本数据类型
    • golang学习笔记02——gin框架及基本原理
    • golang学习笔记03——gin框架的核心数据结构
    • golang学习笔记04——如何真正写好Golang代码？
    • golang学习笔记05——golang协程池，怎么实现协程池？
    • golang学习笔记06——怎么实现本地文件及目录监控-fsnotify
    • golang学习笔记07——使用gzip压缩字符减少redis等存储占用的实现
    • golang学习笔记08——如何调用阿里oss sdk实现访问对象存储？
    • golang学习笔记09——golang优秀开发常用开源库汇总
    • golang学习笔记10——golang 的 Gin 框架，快速构建高效 Web 应用
    • golang学习笔记11——Go 语言的并发与同步实现详解
    • golang学习笔记12——Go 语言内存管理详解
    • golang学习笔记13——golang的错误处理深度剖析
    • golang学习笔记14——golang性能问题的处理方法
    • golang学习笔记15——golang依赖管理方法
    • golang学习笔记16——golang部署与运维全攻略
    • golang学习笔记17——golang使用go-kit框架搭建微服务详解

文章目录

    • 准备工作
      • 1.安装 MySQL 驱动
      • 2.导入必要的包
    • 建立数据库连接
      • 1.连接字符串
      • 2.建立连接
    • 执行 SQL 查询
      • 1.简单查询示例（查询单条记录）
      • 2.查询多条记录
    • 执行 SQL 更新操作（插入、更新、删除）
      • 1.插入数据示例
      • 2.更新数据示例
      • 3.删除数据示例
    • 事务处理
      • 1.事务的概念
      • 2.示例代码

在现代软件开发中，数据存储和访问是至关重要的环节。MySQL 作为一款流行的关系型数据库，经常需要与各种编程语言进行交互。Golang 以其高效、简洁的特性，在数据库访问方面也有着出色的表现。本文将详细介绍 Golang 如何访问 MySQL 数据库，并配合代码示例进行说明。

准备工作

1.安装 MySQL 驱动

  • 在 Golang 中，要访问 MySQL 数据库，首先需要安装相应的数据库驱动。Go - SQL - Driver 是一个广泛使用的 MySQL 驱动，我们可以使用go get命令来安装它：
     go get -u github.com/go - sql - driver/mysql

2.导入必要的包

  • 在 Go 代码中，我们需要导入database/sql包和刚刚安装的 MySQL 驱动包：
     import ("database/sql""fmt""github.com/go - sql - driver/mysql")

建立数据库连接

1.连接字符串

  • 连接 MySQL 数据库需要构建一个连接字符串，它包含了数据库的相关信息，如用户名、密码、主机地址、端口号和数据库名等。连接字符串的格式如下：
     user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local
  • 其中，user是 MySQL 的用户名，password是对应的密码，tcp(127.0.0.1:3306)表示数据库的主机地址（这里是本地地址和默认端口），your_database是要连接的数据库名称，charset=utf8mb4指定字符集，parseTime=True用于自动解析时间类型，loc = Local设置时区。

2.建立连接

  • 使用sql.Open函数来打开一个数据库连接，它返回一个*sql.DB对象和一个可能的错误：
     func main() {db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()}
  • 这里的defer db.Close()语句确保在函数结束时关闭数据库连接，以释放资源。

执行 SQL 查询

1.简单查询示例（查询单条记录）

  • 以下是一个查询数据库中一条记录的示例。假设我们有一个名为users的表，包含id、name和age列：
     func main() {// 建立数据库连接db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()// 查询语句var name stringvar age interr = db.QueryRow("SELECT name, age FROM users WHERE id = 1").Scan(&name, &age)if err!= nil {fmt.Println("查询失败:", err)return}fmt.Printf("姓名: %s, 年龄: %d\n", name, age)}
  • 在这个示例中，我们使用QueryRow函数执行查询语句，它返回一个*sql.Row对象。然后使用Scan方法将查询结果映射到我们定义的变量name和age上。

2.查询多条记录

  • 当需要查询多条记录时，我们使用Query函数。以下是一个查询users表中所有记录的示例：
     func main() {db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()rows, err := db.Query("SELECT name, age FROM users")if err!= nil {fmt.Println("查询失败:", err)return}defer rows.Close()for rows.Next() {var name stringvar age interr = rows.Scan(&name, &age)if err!= nil {fmt.Println("扫描结果失败:", err)return}fmt.Printf("姓名: %s, 年龄: %d\n", name, age)}if err = rows.Err(); err!= nil {fmt.Println("迭代结果集时出错:", err)}}
  • 这里我们首先使用Query函数得到一个*sql.Rows对象，然后使用Next方法遍历结果集，通过Scan方法获取每一行的数据。最后，我们使用rows.Err()检查在遍历过程中是否出现错误。

执行 SQL 更新操作（插入、更新、删除）

1.插入数据示例

  • 假设我们要向users表中插入一条新记录：
     func main() {db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()// 插入语句result, err := db.Exec("INSERT INTO users (name, age) VALUES ('John', 25)")if err!= nil {fmt.Println("插入失败:", err)return}id, err := result.LastInsertId()if err!= nil {fmt.Println("获取插入的ID失败:", err)return}fmt.Printf("插入成功, 新记录的ID: %d\n", id)}
  • 在这个示例中，我们使用Exec函数执行插入语句，它返回一个sql.Result对象。我们可以通过LastInsertId方法获取新插入记录的自增 ID。

2.更新数据示例

  • 以下是更新users表中一条记录的示例：
     func main() {db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()// 更新语句result, err := db.Exec("UPDATE users SET age = 26 WHERE id = 1")if err!= nil {fmt.Println("更新失败:", err)return}rowsAffected, err := result.RowsAffected()if err!= nil {fmt.Println("获取受影响的行数失败:", err)return}fmt.Printf("更新成功, 受影响的行数: %d\n", rowsAffected)}
  • 这里使用Exec函数执行更新语句，通过RowsAffected方法获取更新操作影响的行数。

3.删除数据示例

  • 假设要删除users表中的一条记录：
     func main() {db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()// 删除语句result, err := db.Exec("DELETE FROM users WHERE id = 1")if err!= nil {fmt.Println("删除失败:", err)return}rowsAffected, err := result.RowsAffected()if err!= nil {fmt.Println("获取受影响的行数失败:", err)return}fmt.Printf("删除成功, 受影响的行数: %d\n", rowsAffected)}
  • 同样使用Exec函数执行删除语句，并通过RowsAffected方法获取受影响的行数。

事务处理

1.事务的概念

  • 事务是一组数据库操作，这些操作要么全部成功执行，要么全部失败回滚。在 Golang 中，我们可以方便地使用Begin、Commit和Rollback方法来处理事务。

2.示例代码

  • 以下是一个事务处理的示例，假设我们要向users表中插入两条记录，如果其中一条插入失败，则回滚整个操作：
     func main() {db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/your_database?charset=utf8mb4&parseTime=True&loc=Local")if err!= nil {fmt.Println("数据库连接失败:", err)return}defer db.Close()tx, err := db.Begin()if err!= nil {fmt.Println("开始事务失败:", err)return}// 插入第一条记录_, err = tx.Exec("INSERT INTO users (name, age) VALUES ('Alice', 22)")if err!= nil {// 如果插入失败，回滚事务tx.Rollback()fmt.Println("插入第一条记录失败:", err)return}// 插入第二条记录_, err = tx.Exec("INSERT INTO users (name, age) VALUES ('Bob', 23)")if err!= nil {// 如果插入失败，回滚事务tx.Rollback()fmt.Println("插入第二条记录失败:", err)return}// 提交事务tx.Commit()fmt.Println("两条记录插入成功")}
  • 在这个示例中，我们首先使用Begin方法开始一个事务，得到一个*sql.Tx对象。然后执行两条插入语句，如果其中任何一条出现错误，我们使用Rollback方法回滚事务。如果两条插入语句都成功执行，我们使用Commit方法提交事务。

通过以上步骤，我们可以在 Golang 中有效地访问 MySQL 数据库，进行各种查询和操作。在实际应用中，我们可以根据具体的业务需求灵活运用这些方法，构建强大而高效的数据库应用程序。

关注我看更多有意思的文章哦！👉👉

http://www.lryc.cn/news/435840.html

相关文章：

  • 苹果账号登录后端验证两种方式 python2
  • FlinkCDC 3.2.0 新增优点 Pattern Replacement in routing rules
  • 《 C++ 修炼全景指南：六 》深入探索 C++ 标准库中的 stack 与 queue 容器适配器
  • 高级java每日一道面试题-2024年9月07日-JVM篇-说一下类加载的执行过程?
  • 笔试强训day09
  • 软件测试中的黑盒测试方法，包括其定义、目的及主要步骤。
  • Shell脚本计算π的近似值
  • 进程间通信之消息队列
  • 人生苦短我用Python 5-xlwings自动调整表格
  • 移动跨平台框架Flutter详细介绍和学习线路分享
  • 线性代数基础：向量、矩阵、张量及其在机器学习中的应用详解
  • Dockerfile中的RUN、CMD、ENTRYPOINT指令区别
  • css grid布局属性详解
  • Tranformer分布式特辑
  • 【Moveit2官方教程】使用 MoveIt Task Constructor (MTC) 框架来定义和执行一个机器人任务
  • 使用docker配置wordpress
  • JVM字节码
  • python访问mysql
  • Java工具插件
  • Class3——Esp32|Thonny——网络连接主机-wifi连接（源代码带教程）
  • 特效【生日视频制作】小车汽车黄金色版悍马车身AE模板修改文字软件生成器教程特效素材【AE模板】
  • 如何利用Java进行快速的足球大小球及亚盘数据处理与分析
  • 代码随想录打卡Day29
  • 图分类！！！
  • 高防IP是如何防御攻击
  • Kubernetes 系列 | k8s入门运维
  • yolov8+deepsort+botsort+bytetrack车辆检测和测速系统
  • 基于准静态自适应环型缓存器(QSARC)的taskBus万兆吞吐实现
  • C++笔记---指针常量和常量指针
  • Python习题 177：设计银行账户类并实现存取款功能