Golang操作数据库简单示例
目录
- 准备工作
- 准备数据
- 创建项目
- 连接数据库
- 查询数据
- 修改数据
- 插入数据
- 删除数据
- 释放资源
- 完整代码
- 最终执行结果
准备工作
在开始之前,你需要确保自己安装了Golang的编程环境,安装MySQL数据库,有一个可以用于编写代码的编辑器或IDE工具。我在这里使用的编辑器是Fleet。
准备数据
将下面的SQL语句在MySQL中执行,创建数据库并插入数据.。
drop table if exists album;
create table album (id int auto_increment not null,title varchar(128) not null,artist varchar(255) not null,price decimal(5,2) not null,primary key (`id`)
);
insert into album(title, artist, price)
values('Blue Train', 'John Coltrane', 56.99),('Giant Steps', 'Greey Mulligan', 63.99),('Jeru', 'Gerry Mulligan', 17.99),('Sarah Vaughan', 'Sarah Vaughan', 34.98);
创建项目
进入终端,输入以下命令。(当然,你也可以手动创建)
mkdir data-access
cd ./data-access
go mod init example/data-access
在上面创建的目录下创建文件main.go,将以下代码粘贴到文件中。
package mainimport ("database/sql""errors""fmt""github.com/go-sql-driver/mysql""log"
)
终端输入以下命令下载上面代码中引入的MySQL的驱动包
go mod tidy
连接数据库
在main.go中输入以下代码,连接数据库。
var db *sql.DBfunc main() {// 设置连接属性cfg := mysql.Config{User: "root",Passwd: "123456",Net: "tcp",Addr: "127.0.0.1:3306",DBName: "recordings",}// 获取数据库句柄var err errordb, err = sql.Open("mysql", cfg.FormatDSN())if err != nil {log.Fatal(err)}// 测试是否连接成功pingErr := db.Ping()if pingErr != nil {log.Fatal(pingErr)}log.Println("Connected!")
}
查询数据
对于数据库中的数据,我们需要定义一个结构体去接收。在main.go中输入以下代码。
// Album 记录实体结构体
type Album struct {ID int64Title stringArtist stringPrice float32
}
接着我们实现String函数让输出稍微美观一些。
func (album Album) String() string {return fmt.Sprintf(`{ "id": %d, "title": %q, "artist": %q, "price": %.2f }`, album.ID, album.Title, album.Artist, album.Price)
}
接下来,让我们编写一个函数,这个函数的功能是通过人名去查询数据库中的记录。
// 通过人名查询记录
func albumsByArtist(name string) ([]Album, error) {var albums []Albumrows, err := db.Query("select * from album where artist = ?", name)if err != nil {return nil, fmt.Errorf("albumsByArtist %q: %v", name, err)}// 资源释放,defer关键字修饰的语句在其下方语句未执行完成前不会执行defer rows.Close()// 循环获取相关值for rows.Next() {var alb Albumif err := rows.Scan(&alb.ID, &alb.Title, &alb.Artist, &alb.Price); err != nil {return nil, fmt.Errorf("albumsByArtist %q: %v", name, err)}albums = append(albums, alb)}if err := rows.Err(); err != nil {return nil, fmt.Errorf("albumsByArtist %q: %v", name, err)}return albums, nil
}
接着定义一个函数,通过id去查询记录。
// 通过ID查询记录
func albumsById(id int64) (Album, error) {var alb Albumrow := db.QueryRow("select * from album where id = ?", id)if err := row.Scan(&alb.ID, &alb.Title, &alb.Artist, &alb.Price); err != nil {if errors.Is(err, sql.ErrNoRows) {return alb, fmt.Errorf("albumsById %d: no such album", id)}return alb, fmt.Errorf("albumsById %d: %v", id, err)}return alb, nil
}
然后,我们在main函数中调用。
// 查询数据
albums, err := albumsByArtist("John Coltrane")
if err != nil {log.Fatal(err)
}
log.Printf("Albums found: %v\n", albums)alb, err := albumsById(2)
if err != nil {log.Fatal(err)
}
log.Printf("Album found: %v\n", alb)
修改数据
我们来定义一个函数用来修改数据,用id做为删选条件。
// 修改数据
func updateAlbumById(alb Album) (int64, error) {result, err := db.Exec("update album set title = ?, artist = ?, price = ? where id = ?", alb.Title, alb.Artist, alb.Price, alb.ID)if err != nil {return 0, fmt.Errorf("updateAlbumById: %v", err)}rows, err := result.RowsAffected()if err != nil {return 0, fmt.Errorf("updateAlbumById: %v", err)}return rows, nil
}
在main函数中调用它。
// 修改数据
updateRows, err := updateAlbumById(Album{ID: 1,Title: "White teddy bear",Artist: "John Thompson's",Price: 20.99,
})
if err != nil {log.Fatal(err)
}
log.Printf("Number of rows updated: %v\n", updateRows)
插入数据
定义一个函数用来插入数据并且返回插入数据在数据库中的id。
// 插入记录
func addAlbum(alb Album) (int64, error) {result, err := db.Exec("insert into album (title, artist, price) values (?, ?, ?)", alb.Title, alb.Artist, alb.Price)if err != nil {return 0, fmt.Errorf("addAlbum: %v", err)}id, err := result.LastInsertId()if err != nil {return 0, fmt.Errorf("addAlbum: %v", err)}return id, nil
}
在main函数中调用
// 插入数据
albId, err := addAlbum(Album{Title: "The Modern Sound of Betty Carter",Artist: "Betty Carter",Price: 49.99,
})
if err != nil {log.Fatal(err)
}
log.Printf("id of added alnum: %v\n", albId)
删除数据
定义一个函数用来删除数据。
// 删除记录,返回删除的行数
func deleteAlbum(id int64) (int64, error) {result, err := db.Exec("delete from album where id = ?", id)if err != nil {return 0, fmt.Errorf("deleteAlbum: %v", err)}rows, err := result.RowsAffected()if err != nil {return 0, fmt.Errorf("deleteAlbum: %v", err)}return rows, nil
}
在main函数中调用
// 删除数据
deleteRows, err := deleteAlbum(albId)
if err != nil {log.Fatal(err)
}
log.Printf("Number of rows deleted: %v\n", deleteRows)
释放资源
对于数据库的操作完成后,需要释放数据库连接,在main函数中输入以下代码释放资源。
// 释放资源
err = db.Close()
if err != nil {log.Fatal(err)
}
完整代码
完整代码如下。
package mainimport ("database/sql""errors""fmt""github.com/go-sql-driver/mysql""log"
)var db *sql.DB// Album 记录实体结构体
type Album struct {ID int64Title stringArtist stringPrice float32
}func (album Album) String() string {return fmt.Sprintf(`{ "id": %d, "title": %q, "artist": %q, "price": %.2f }`, album.ID, album.Title, album.Artist, album.Price)
}func main() {// 设置连接属性cfg := mysql.Config{User: "root",Passwd: "123456",Net: "tcp",Addr: "127.0.0.1:3306",DBName: "recordings",}// 获取数据库句柄var err errordb, err = sql.Open("mysql", cfg.FormatDSN())if err != nil {log.Fatal(err)}// 测试是否连接成功pingErr := db.Ping()if pingErr != nil {log.Fatal(pingErr)}log.Println("Connected!")// 查询数据albums, err := albumsByArtist("John Coltrane")if err != nil {log.Fatal(err)}log.Printf("Albums found: %v\n", albums)alb, err := albumsById(2)if err != nil {log.Fatal(err)}log.Printf("Album found: %v\n", alb)// 修改数据updateRows, err := updateAlbumById(Album{ID: 1,Title: "White teddy bear",Artist: "John Thompson's",Price: 20.99,})if err != nil {log.Fatal(err)}log.Printf("Number of rows updated: %v\n", updateRows)// 插入数据albId, err := addAlbum(Album{Title: "The Modern Sound of Betty Carter",Artist: "Betty Carter",Price: 49.99,})if err != nil {log.Fatal(err)}log.Printf("id of added alnum: %v\n", albId)// 删除数据deleteRows, err := deleteAlbum(albId)if err != nil {log.Fatal(err)}log.Printf("Number of rows deleted: %v\n", deleteRows)// 释放资源err = db.Close()if err != nil {log.Fatal(err)}
}// 通过人名查询记录
func albumsByArtist(name string) ([]Album, error) {var albums []Albumrows, err := db.Query("select * from album where artist = ?", name)if err != nil {return nil, fmt.Errorf("albumsByArtist %q: %v", name, err)}// 资源释放,defer关键字修饰的语句在其下方语句未执行完成前不会执行defer rows.Close()// 循环获取相关值for rows.Next() {var alb Albumif err := rows.Scan(&alb.ID, &alb.Title, &alb.Artist, &alb.Price); err != nil {return nil, fmt.Errorf("albumsByArtist %q: %v", name, err)}albums = append(albums, alb)}if err := rows.Err(); err != nil {return nil, fmt.Errorf("albumsByArtist %q: %v", name, err)}return albums, nil
}// 通过ID查询记录
func albumsById(id int64) (Album, error) {var alb Albumrow := db.QueryRow("select * from album where id = ?", id)if err := row.Scan(&alb.ID, &alb.Title, &alb.Artist, &alb.Price); err != nil {if errors.Is(err, sql.ErrNoRows) {return alb, fmt.Errorf("albumsById %d: no such album", id)}return alb, fmt.Errorf("albumsById %d: %v", id, err)}return alb, nil
}// 修改数据
func updateAlbumById(alb Album) (int64, error) {result, err := db.Exec("update album set title = ?, artist = ?, price = ? where id = ?", alb.Title, alb.Artist, alb.Price, alb.ID)if err != nil {return 0, fmt.Errorf("updateAlbumById: %v", err)}rows, err := result.RowsAffected()if err != nil {return 0, fmt.Errorf("updateAlbumById: %v", err)}return rows, nil
}// 插入记录
func addAlbum(alb Album) (int64, error) {result, err := db.Exec("insert into album (title, artist, price) values (?, ?, ?)", alb.Title, alb.Artist, alb.Price)if err != nil {return 0, fmt.Errorf("addAlbum: %v", err)}id, err := result.LastInsertId()if err != nil {return 0, fmt.Errorf("addAlbum: %v", err)}return id, nil
}// 删除记录,返回删除的行数
func deleteAlbum(id int64) (int64, error) {result, err := db.Exec("delete from album where id = ?", id)if err != nil {return 0, fmt.Errorf("deleteAlbum: %v", err)}rows, err := result.RowsAffected()if err != nil {return 0, fmt.Errorf("deleteAlbum: %v", err)}return rows, nil
}
最终执行结果

相关文章:
Golang操作数据库简单示例
目录 准备工作准备数据创建项目连接数据库查询数据修改数据插入数据删除数据释放资源完整代码最终执行结果 准备工作 在开始之前,你需要确保自己安装了Golang的编程环境,安装MySQL数据库,有一个可以用于编写代码的编辑器或IDE工具。我在这里…...
亚马逊测评,买家号支付不了、砍单率高是什么问题,需要怎么解决
下半年旺季很多卖家都在使用自养号测评给产品冲一波权重,但是很多朋友会遇到下不了单或者砍单率过高等问题。有人以为是支付卡的问题,也有人觉得是IP被关联了。其实他们讲的也没错,但是,亚马逊风控不会针对某个点去进行检测&#…...
B. Jellyfish and Game-Codeforces Round 902 (Div. 2)
B. Jellyfish and Game 交换k轮使得第一个同学拥有数值总数最大; 很容易看出这道题需要判断k奇偶数。 当k是奇数时可以看作第一个同学操作一轮。 k为偶数可以看作两个同学各操作一轮。 #include<iostream> #include<vector> #include<algorithm>…...
Linux下的命令行参数和环境变量
命令行参数 什么是命令行参数 命令行参数是指在执行命令行程序时,给程序传递的额外参数。在Linux终端中,命令行参数通常通过在命令后面添加空格分隔的参数来传递。 Linux下以main函数举例说明 #include<stdio.h>int main(int argc char* argv[])…...
语音芯片KT142C两种音频输出方式PWM和DAC的区别
目录 语音芯片KT142C两种音频输出方式PWM和DAC的区别 一般的语音芯片,输出方式,无外乎两种,即dac输出,或者PWM输出 其中dac的输出,一般应用场景都是外挂功放芯片,实现声音的放大,比如常用的音箱…...
Kotlin 协程的挂起和阻塞的区别
一,简介 Kotlin协程引入了非常强大的异步编程模型,通过挂起而不是阻塞来实现并发操作。以下是有关Kotlin协程挂起和阻塞的详细介绍: 挂起(Suspending): 挂起是指一个协程的执行可以在不阻塞线程的情况下暂…...
解决Github Markdown图片显示残缺的问题
title: 解决Github Markdown图片显示残缺的问题 tags: 个人成长 categories:杂谈 在Github存放Markdown文档,如果图片没有存放在Github服务器上,github会尝试生成Github图片缓存,使用Github图片缓存,进行实际的展示。但比较蛋疼的…...
[MAUI]深入了解.NET MAUI Blazor与Vue的混合开发
文章目录 Vue在混合开发中的特点创建MAUI项目创建Vue应用使用element-ui组件库JavaScript和原生代码的交互传递根组件参数从设备调用Javascript代码从Vue页面调用原生代码 读取设备信息项目地址 .NET MAUI结合Vue的混合开发可以使用更加熟悉的Vue的语法代替Blazor语法ÿ…...
1209. 带分数
题目: 1209. 带分数 - AcWing题库 思路: 1.targetab/c,由题意a,b,c会包含1~9 且每个数出现且只能出现一次。我们可以抽象化为9个坑位分成3份分别给a,b,c。 2.先采用递归搜索树写出9个坑位的全排列,再分成3个区,分…...
【树莓派触摸屏等学习笔记】
前言 树莓派触摸屏 提示:以下是本篇文章正文内容,下面案例可供参考 一、触摸屏硬件驱动 出现黑屏的时候,恢复一下txt config.txt 全屏显示 showFull Exec :自启动 surf 算法 特征点识别 算法的复杂度挺高的 特性树莓派强大…...
ERR_PNPM_JSON_PARSE Unexpected end of JSON input while parsing empty string in
终端报错: ERR_PNPM_JSON_PARSE Unexpected end of JSON input while parsing empty string in 报错原因:依赖没有删除干净 解决办法: ①删除node_modules ②在package.json的dependencies删除不需要依赖 ③重新pnpm i...
linux基础IO
文章目录 前言一、基础IO1、文件预备知识1.1 文件类的系统调用接口1.2 复习c语言接口 2、文件类的系统调用接口2.1 open系统调用2.2 close系统调用2.3 write系统调用2.4 read系统调用 3、文件描述符3.1 文件描述符fd介绍3.2 文件描述符fd分配规则与重定向3.3 重定向原理3.4输入…...
华为OD机试 - TLV格式 - 逻辑分析(Java 2023 B卷 100分)
目录 专栏导读一、题目描述二、输入描述三、输出描述四、解题思路五、Java算法源码六、效果展示1、输入2、输出3、说明 华为OD机试 2023B卷题库疯狂收录中,刷题点这里 专栏导读 本专栏收录于《华为OD机试(JAVA)真题(A卷B卷&#…...
LLMs之RAG:利用langchain实现RAG应用五大思路步骤—基于langchain使用LLMs(ChatGPT)构建一个问题回答文档的应用程序实战代码
LLMs之RAG:利用langchain实现RAG应用五大思路步骤—基于langchain使用LLMs(ChatGPT)构建一个问题回答文档的应用程序实战代码 目录 相关文章...
链式队列----数据结构
队列的基本概念 队列是一种操作受限的线性表(先进先出),只允许在队尾插入,队头删除。 例如去银行办理业务,肯定是先来的先出去,后来的人排在后方,只有第一个人业务办理完了,才会有…...
VM虚拟机VMware Fusion(13.5.0)
VMware Fusion提供了在Apple Mac上运行Windows、Linux等操作系统的最佳方式,无需重新启动。Fusion 13支持运行macOS 12及更高版本的Intel和Apple Silicon Mac,并包含面向开发人员、IT管理员和日常用户的功能。 Fusion 13 新增功能 支持新的客户机操作系…...
自动化测试08
Junit 为什么学了Selenium还需学习Junit Selenium自动化测试框架;Junit单元测试框架。 拿着一个技术写自动化测试用例(Selenium3) 拿着一个技术管理已经编写好的测试用例(Junit5) Junit相关的技术 Junit是针对Java的一…...
d3dx9_43.dll丢失有什么办法可以解决,解决d3dx9_43.dll丢失
通常d3dx9_43.dll丢失都是在运行游戏时汤出的d3dx9_43.dll找不到的错误窗口,因为d3dx9_43.dll文件更多是在使用游戏时会被调用的dll文件,d3dx9_43.dll是属于DirectX9的一个组件,DirectX9是游戏系统中的一个重要程序,所以当d3dx9_4…...
【C++】: auto关键字(C++11)+基于范围的for循环(C++11)+指针空值nullptr(C++11)
auto关键字(C11) 随着程序越来越复杂,程序中用到的类型也越来越复杂,经常体现在: 类型难于拼写含义不明确导致容易出错 #include <string> #include <map> int main() {std::map<std::string, std::…...
华为OD机试 - 玩牌高手 - 动态规划(Java 2023 B卷 100分)
目录 一、题目描述二、输入描述三、输出描述四、解题思路具体规则如下:具体步骤如下: 五、Java算法源码六、效果展示1、输入2、输出3、说明 华为OD机试 2023B卷题库疯狂收录中,刷题点这里 一、题目描述 给定一个长度为n的整型数组࿰…...
ES6从入门到精通:前言
ES6简介 ES6(ECMAScript 2015)是JavaScript语言的重大更新,引入了许多新特性,包括语法糖、新数据类型、模块化支持等,显著提升了开发效率和代码可维护性。 核心知识点概览 变量声明 let 和 const 取代 var…...
JavaScript 中的 ES|QL:利用 Apache Arrow 工具
作者:来自 Elastic Jeffrey Rengifo 学习如何将 ES|QL 与 JavaScript 的 Apache Arrow 客户端工具一起使用。 想获得 Elastic 认证吗?了解下一期 Elasticsearch Engineer 培训的时间吧! Elasticsearch 拥有众多新功能,助你为自己…...
CentOS下的分布式内存计算Spark环境部署
一、Spark 核心架构与应用场景 1.1 分布式计算引擎的核心优势 Spark 是基于内存的分布式计算框架,相比 MapReduce 具有以下核心优势: 内存计算:数据可常驻内存,迭代计算性能提升 10-100 倍(文档段落:3-79…...
Python实现prophet 理论及参数优化
文章目录 Prophet理论及模型参数介绍Python代码完整实现prophet 添加外部数据进行模型优化 之前初步学习prophet的时候,写过一篇简单实现,后期随着对该模型的深入研究,本次记录涉及到prophet 的公式以及参数调优,从公式可以更直观…...
论文浅尝 | 基于判别指令微调生成式大语言模型的知识图谱补全方法(ISWC2024)
笔记整理:刘治强,浙江大学硕士生,研究方向为知识图谱表示学习,大语言模型 论文链接:http://arxiv.org/abs/2407.16127 发表会议:ISWC 2024 1. 动机 传统的知识图谱补全(KGC)模型通过…...
现代密码学 | 椭圆曲线密码学—附py代码
Elliptic Curve Cryptography 椭圆曲线密码学(ECC)是一种基于有限域上椭圆曲线数学特性的公钥加密技术。其核心原理涉及椭圆曲线的代数性质、离散对数问题以及有限域上的运算。 椭圆曲线密码学是多种数字签名算法的基础,例如椭圆曲线数字签…...
在鸿蒙HarmonyOS 5中使用DevEco Studio实现录音机应用
1. 项目配置与权限设置 1.1 配置module.json5 {"module": {"requestPermissions": [{"name": "ohos.permission.MICROPHONE","reason": "录音需要麦克风权限"},{"name": "ohos.permission.WRITE…...
Swagger和OpenApi的前世今生
Swagger与OpenAPI的关系演进是API标准化进程中的重要篇章,二者共同塑造了现代RESTful API的开发范式。 本期就扒一扒其技术演进的关键节点与核心逻辑: 🔄 一、起源与初创期:Swagger的诞生(2010-2014) 核心…...
Java多线程实现之Thread类深度解析
Java多线程实现之Thread类深度解析 一、多线程基础概念1.1 什么是线程1.2 多线程的优势1.3 Java多线程模型 二、Thread类的基本结构与构造函数2.1 Thread类的继承关系2.2 构造函数 三、创建和启动线程3.1 继承Thread类创建线程3.2 实现Runnable接口创建线程 四、Thread类的核心…...
重启Eureka集群中的节点,对已经注册的服务有什么影响
先看答案,如果正确地操作,重启Eureka集群中的节点,对已经注册的服务影响非常小,甚至可以做到无感知。 但如果操作不当,可能会引发短暂的服务发现问题。 下面我们从Eureka的核心工作原理来详细分析这个问题。 Eureka的…...
