速成GO访问sql，个人笔记

更多个人笔记：（仅供参考，非盈利）
gitee： https://gitee.com/harryhack/it_note
github： https://github.com/ZHLOVEYY/IT_note

本文是基于原生的库 database/sql进行初步学习
基于ORM等更多操作可以关注我的博客和笔记仓库

连接 MySQL 和基本 CRUD 操作

需要 go get -u github.com/go-sql-driver/mysql获取sql驱动
自己先连接到sql的root数据库，然后创建/fortest数据库

package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql" // 添加 MySQL 驱动。没有直接使用包的对象所以加_"log"
)func main() {db, err := sql.Open("mysql", "root:1234@tcp(127.0.0.1:3306)/fortest") //这里是user:password@tcp(location)/database的形式，我的密码是1234if err != nil {log.Fatal("连接失败", err)}defer db.Close()//测试连接err = db.Ping()if err != nil {log.Fatal("连接失败", err)}fmt.Println("连接成功")//创建表  注意用if no exists避免重复创建_, err = db.Exec(`CREATE TABLE IF NOT EXISTS gameusers (id INT AUTO_INCREMENT PRIMARY KEY,name VARCHAR(50),age INT)`)if err != nil {log.Fatal("创建表失败:", err)}//插入数据result, err := db.Exec(`INSERT INTO gameusers (name, age) VALUES (?, ?)`, "Alice", 25)if err != nil {log.Fatal(err)}id, _ := result.LastInsertId() //用于获取最新插入的IDfmt.Printf("插入成功,ID:%d\n", id)//再插入一条_, err = db.Exec(`INSERT INTO gameusers (name, age) VALUES (?, ?)`, "Alice2", 26)if err != nil {log.Fatal(err)}//查询单条数据var name stringvar age int //方便查询然后存储进来err = db.QueryRow("SELECT name, age FROM gameusers WHERE id = ?", id).Scan(&name, &age)if err != nil {log.Fatal(err)}fmt.Printf("查询结果: name=%s, age=%d\n", name, age)//查询多条记录rows, err := db.Query("SELECT * FROM gameusers") //*就是所有列的了// rows, err := db.Query("SELECT id,name,age from gameusers") //显示指定列if err != nil {log.Fatal("查询失败", err)}defer rows.Close()//rows 是一个数据库结果集，会占用数据库连接和内存资源，如果不关闭，可能会导致资源泄露for rows.Next() { //类似于迭代器var userID interr := rows.Scan(&userID, &name, &age) //将当前行的数据读取到指定的变量中if err != nil {log.Fatal("扫描失败", err)}fmt.Printf("ID:%d ,姓名:%s,年龄:%d\n", userID, name, age)}//更新数据_, err = db.Exec("UPDATE gameusers SET age = ? WHERE id = ?", 26, id)if err != nil {log.Fatal("更新失败", err)}fmt.Println("更新成功")//删除数据_, err = db.Exec("DELETE FROM gameusers WHERE id =?", id)if err != nil {log.Fatal("删除失败", err)}fmt.Println("删除成功")}

总结：

  • open()：用于建立连接
    • 需要defer关闭数据库连接防止浪费资源
  • ping()：用于测试是否建立连接
  • exec()：用于执行创建表，CRUD等操作
  • QueryRow()：用于查询单条数据
  • Query()：用于多行查询
    • 注意结合.Next迭代和Scan写入
    • 需要defer关闭防止查询一直连接浪费资源

事务和结构体映射

事务的特点：

  • 原子性：要么全部成功，要么全部失败
  • 一致性：数据库从一个一致状态转换到另一个一致状态
  • 隔离性：事务执行不受其他事务影响
  • 持久性：一旦提交，修改就是永久的
    例子理解：
  • 假设你要给 A 转账 100 元给 B
  • 需要两个操作：A 减 100，B 加 100
  • 如果 A 减 100 成功，但 B 加 100 失败
  • 这时就需要 Rollback，撤销 A 减 100 的操作
  • 确保账户金额不会出错
package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql" // 添加 MySQL 驱动。没有直接使用包的对象所以加_"log"
)// User 结构体映射 users 表
type GameUser struct {ID   intName stringAge  int
}func main() {db, err := sql.Open("mysql", "root:1234@tcp(127.0.0.1:3306)/fortest")if err != nil {log.Fatal("连接失败", err)}defer db.Close()//测试连接err = db.Ping()if err != nil {log.Fatal("连接失败", err)}fmt.Println("连接成功")//创建表_, err = db.Exec(`CREATE TABLE IF NOT EXISTS gameusers (id INT AUTO_INCREMENT PRIMARY KEY,name VARCHAR(50),age INT)`)if err != nil {log.Fatal("创建表失败:", err)}// 开启事务tx, err := db.Begin()if err != nil {log.Fatal("事务开启失败", err)}//插入用户result, err := tx.Exec("INSERT INTO gameusers (name, age) VALUES (?, ?)", "Bob", 30)if err != nil {tx.Rollback()log.Fatal("插入失败", err)}id, _ := result.LastInsertId()fmt.Println("插入成功，用户ID:", id)//更新用户_, err = tx.Exec("UPDATE users SET age = ? WHERE id = ?", 31, id)if err != nil {tx.Rollback()log.Fatal("更新失败:", err)}// 提交事务err = tx.Commit() //通过commit进行提交if err != nil {log.Fatal("事务提交失败:", err)}fmt.Println("事务完成")//查询并映射到结构体var user GameUsererr = db.QueryRow("SELECT id, name, age FROM gameusers WHERE id =?", id).Scan(&user.ID, &user.Name, &user.Age) //将查询结果映射到user结构体if err != nil {log.Fatal("查询失败", err)}fmt.Printf("用户信息: %+v\n", user)}

执行完会发现报错：

连接成功
插入成功，用户ID: 5
2025/04/25 10:12:03 更新失败:Error 1146 (42S02): Table 'fortest.users' doesn't exist

（这个用户id我插入很多次，会自己不断增加的）
这时候检查数据库会发现，bob并没有被插入，这是因为回滚了。那么接下来只要把上面代码中更新部分的users改为gameusers就可以了

如果不希望总是写tx.Rollback()
也可以增加：

    // 定义一个函数，确保在出错时回滚事务defer func() {if err != nil {tx.Rollback()return}}()

这样就会在最后进行统一的判断

批量插入和预处理语句

预处理可以防sql注入，通过永远使用 ? 占位符，避免直接拼接 SQL 语句

func main() {db, err := sql.Open("mysql", "root:1234@tcp(127.0.0.1:3306)/fortest")if err != nil {log.Fatal("连接错误", err)}defer db.Close()//准备预处理stmt, err := db.Prepare("INSERT INTO gameusers (name,age) values (?,?)")if err != nil {log.Fatal("预处理失败", err)}defer stmt.Close()//批量插入users := []struct {   //定义结构体列表的同时初始化name stringage  int}{{"Charlie", 22},{"David", 28},{"Eve", 19},}for _, u := range users {_, err := stmt.Exec(u.name, u.age) //通过Exec传递参数进去if err != nil {log.Fatal("批量插入失败", err)}}fmt.Println("批量插入完成")//查询所有用户rows, err := db.Query("SELECT id,name,age FROM gameusers")if err != nil {log.Fatal("查询失败", err)}defer rows.Close()for rows.Next() { //读取数据var id intvar name stringvar age interr = rows.Scan(&id, &name, &age)if err != nil {log.Fatal("读取是吧", err)}fmt.Printf("id:%d,name:%s,age:%d\n", id, name, age)}
}

还有比如查询大数据时，限制返回行数（如 LIMIT），以及设置连接数和空闲连接数SetMaxOpenConns、SetMaxIdleConns等等，可以进一步拓展学习

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/bicheng/78299.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【C++指南】告别C字符串陷阱：如何实现封装string？

【C++指南】告别C字符串陷阱：如何实现封装string？

🌟 各位看官好，我是egoist2023！ 🌍 种一棵树最好是十年前，其次是现在！ 💬 注意：本章节只详讲string中常用接口及实现，有其他需求查阅文档介绍。 🚀 今天通过了…
阅读更多...
系统架构师2025年论文《论软件架构评估2》

系统架构师2025年论文《论软件架构评估2》

论软件系统架构评估 v2.0 摘要： 某市医院预约挂号系统建设推广应用项目是我市卫生健康委员会 2019 年发起的一项医疗卫生行业便民惠民信息化项目，目的是实现辖区内患者在辖区各公立医疗机构就诊时，可以通过多种线上渠道进行预约挂号，提升就医体验。我作为系统架构师参与此…
阅读更多...
BEVDet4D: Exploit Temporal Cues in Multi-camera 3D Object Detection

BEVDet4D: Exploit Temporal Cues in Multi-camera 3D Object Detection

背景 对于现有的BEVDet方法，它对于速度的预测误差要高于基于点云的方法，对于像速度这种与时间有关的属性，仅靠单帧数据很难预测好。因此本文提出了BEVDet4D，旨在获取时间维度上的丰富信息。它是在BEVDet的基础上进行拓展，保留了之前帧的BEV特征，并将其进行空间对齐后与当…
阅读更多...
el-upload 上传逻辑和ui解耦，上传七牛

el-upload 上传逻辑和ui解耦，上传七牛

解耦的作用在于如果后面要我改成从阿里云oss上传文件，我只需要实现上传逻辑从七牛改成阿里云即可，其他不用动。实现方式有2部分组成，一部分是上传逻辑，一部分是ui。 上传逻辑 大概逻辑就是先去服务端拿上传token和地址&#xff0…
阅读更多...
酒水类目电商代运营公司-品融电商：全域策略驱动品牌长效增长

酒水类目电商代运营公司-品融电商：全域策略驱动品牌长效增长

酒水类目电商代运营公司-品融电商：全域策略驱动品牌长效增长 在竞争日益激烈的酒水市场中，品牌如何快速突围并实现长效增长？品融电商凭借「效品合一 全域增长」方法论与全链路运营能力，成为酒水类目代运营的领跑者。从品牌定位、视…
阅读更多...
机器学习特征工程中的数值分箱技术：原理、方法与实例解析

机器学习特征工程中的数值分箱技术：原理、方法与实例解析

标题：机器学习特征工程中的数值分箱技术：原理、方法与实例解析 摘要： 分箱技术作为机器学习特征工程中的关键环节，通过将数值数据划分为离散区间，能够有效提升模型对非线性关系的捕捉能力，同时增强模型对异…
阅读更多...
【MySQL专栏】MySQL数据库的复合查询语句

【MySQL专栏】MySQL数据库的复合查询语句

文章目录 1、首先练习MySQL基本语句的练习①查询工资高于500或岗位为MANAGER的雇员，同时还要满足他们的姓名首字母为大写的J②按照部门号升序而雇员的工资降序排序③使用年薪进行降序排序④显示工资最高的员工的名字和工作岗位⑤显示工资高于平均工资的员工信息⑥显…
阅读更多...
Python爬虫（5）静态页面抓取实战：requests库请求头配置与反反爬策略详解

Python爬虫（5）静态页面抓取实战：requests库请求头配置与反反爬策略详解

目录 一、背景与需求‌二、静态页面抓取的核心流程‌三、requests库基础与请求头配置‌3.1 安装与基本请求3.2 请求头核心参数解析‌3.3 自定义请求头实战 四、实战案例：抓取豆瓣读书Top250‌1. 目标‌2. 代码实现3. 技术要点‌ 五、高阶技巧与反反爬策略‌5.1 动态…
阅读更多...
HTML给图片居中

HTML给图片居中

在不同的布局场景下&#xff0c;让 <img> 元素居中的方法有所不同。下面为你介绍几种常见的居中方式 1. 块级元素下的水平居中 如果 <img> 元素是块级元素&#xff08;可以通过 display: block 设置&#xff09;&#xff0c;可以使用 margin: 0 auto 来实现水平居…
阅读更多...
【高频考点精讲】前端构建工具对比：Webpack、Vite、Rollup和Parcel

【高频考点精讲】前端构建工具对比：Webpack、Vite、Rollup和Parcel

前端构建工具大乱斗：Webpack、Vite、Rollup和Parcel谁是你的菜？ 【初级】前端开发工程师面试100题（一） 【初级】前端开发工程师面试100题（二） 【初级】前端开发工程师的面试100题（速记版） 最近在后台收到不少同学提问：“老李啊，现在前端构建工具这么多，我该选哪个？…
阅读更多...
赶紧收藏！教您如何用 GitHub 账号，获取永久免费的 Docker 容器！！快速搭建我们的网站/应用！

赶紧收藏！教您如何用 GitHub 账号，获取永久免费的 Docker 容器！！快速搭建我们的网站/应用！

文章目录 📖 介绍 📖🏡 演示环境 🏡📒 永久免费的 Docker 容器 📒🚀 注册与登录➕ 创建 Docker 容器💻 部署你的网站🔑 注意事项💡 使用场景⚓️ 相关链接 ⚓️📖 介绍 📖 还在为搭建个人网站寻找免费方案而烦恼？ 今天发现一个宝藏平台！只需一个 Git…
阅读更多...
Java大师成长计划之第3天：Java中的异常处理机制

Java大师成长计划之第3天：Java中的异常处理机制

&#x1f4e2; 友情提示&#xff1a; 本文由银河易创AI&#xff08;https://ai.eaigx.com&#xff09;平台gpt-4o-mini模型辅助创作完成&#xff0c;旨在提供灵感参考与技术分享&#xff0c;文中关键数据、代码与结论建议通过官方渠道验证。 在 Java 编程中&#xff0c;异常处理…
阅读更多...
大数据去重

大数据去重

实验4 大数据去重 1.实验目的 通过Hadoop数据去重实验&#xff0c;学生可以掌握准备数据、伪分布式文件系统配置方法&#xff0c;以及在集成开发环境Eclipse中实现Hadoop数据去重方法。 2.实验要求 了解基于Hadoop处理平台的大数据去重过程&#xff0c;理解其主要功能&…
阅读更多...
http协议、全站https

http协议、全站https

一、http协议 1、为何要学http协议？ 用户用浏览器访问网页，默认走的都是http协议，所以要深入研究web层，必须掌握http协议 2、什么是http协议 1、全称Hyper Text Transfer Protocol（超文本传输协议） ### 一个请求得到一个响应包 普通…
阅读更多...
使用 Logstash 迁移 MongoDB 数据到 Easysearch

使用 Logstash 迁移 MongoDB 数据到 Easysearch

大家好&#xff01;在前面的文章中&#xff0c;我们已经详细介绍了如何通过 Logstash 和 Canal 工具实现 MySQL 数据向 Easysearch 的迁移。如果您正在使用 MongoDB 作为数据存储&#xff0c;并希望将其数据迁移到 Easysearch 中&#xff0c;这篇指南或许能为您提供一些帮助。 …
阅读更多...
亚马逊英国站FBA费用重构：轻小商品迎红利期，跨境卖家如何抢占先机？

亚马逊英国站FBA费用重构：轻小商品迎红利期，跨境卖家如何抢占先机？

一、政策背景&#xff1a;成本优化成平台与卖家共同诉求 2024年4月&#xff0c;亚马逊英国站&#xff08;Amazon.co.uk&#xff09;发布近三年来力度最大的FBA费用调整方案&#xff0c;标志着英国电商市场正式进入精细化成本管理时代。这一决策背后&#xff0c;是多重因素的叠…
阅读更多...
使用Qt Quick Controls创建自定义日历组件

使用Qt Quick Controls创建自定义日历组件

目录 引言相关阅读1. DayOfWeekRow2. MonthGrid3. WeekNumberColumn 项目结构及实现工程结构图代码实现及解析1. 组件封装2. 主界面实现 运行效果 总结下载链接 引言 Qt6 Quick框架提供了一套丰富的日历相关组件&#xff0c;包括 MonthGrid、DayOfWeekRow 和 WeekNumberColumn…
阅读更多...
【AI微信小程序开发】大转盘小程序项目代码：自设转盘选项和概率（含完整前端+后端代码）

【AI微信小程序开发】大转盘小程序项目代码：自设转盘选项和概率（含完整前端+后端代码）

系列文章目录 【AI微信小程序开发】AI减脂菜谱小程序项目代码：根据用户身高/体重等信息定制菜谱（含完整前端+后端代码）【AI微信小程序开发】AI菜谱推荐小程序项目代码：根据剩余食材智能生成菜谱（含完整前端+后端代码）【AI微信小程序开发】图片工具小程序项目代码：图片压…
阅读更多...
redis相关问题整理

redis相关问题整理

Redis 支持多种数据类型&#xff1a; 字符串 示例&#xff1a;存储用户信息 // 假设我们使用 redis-plus-plus 客户端库 auto redis Redis("tcp://127.0.0.1:6379"); redis.set("user:1000", "{name: John Doe, email: john.doeexample.com}"…
阅读更多...
Vue-组件的懒加载，按需加载

Vue-组件的懒加载，按需加载

在Vue项目中实现组件的懒加载&#xff08;也称为按需加载或代码分割&#xff09;&#xff0c;可以大大提升应用的加载速度和性能。懒加载主要通过Webpack的代码分割功能实现&#xff0c;特别是使用动态导入&#xff08;import()语法&#xff09;。 为什么要使用懒加载&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023