Golang数据库编程详解 | 深入浅出Go语言原生数据库编程

 

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站https://www.captainbed.cn/kitie。

Golang学习专栏:https://blog.csdn.net/qq_35716689/category_12575301.html

前言

对数据库的CURD是现代应用程序的必备功能,Go语言当然也对数据库的操作提供了非常完善的支持。

尽管在Go语言社区中有很多优秀的ORM库或框架(比如GORM,后面也会发文)能让我们更方便地操作数据库,不过要更好地使用ORM库,掌握Go原生操作数据库database/sql包的使用还是有必要的。

所以,在这篇文章中,我们先来学习一下database/sql包的使用吧。

目录

前言

database/sql简介

连接数据库

MySQL

Postgres

SQLite

关闭连接

连接池设置

示例数据表

sql.DB

sql.Stmt

sql.Tx

小结


database/sql简介

我们可以把标准库中的database/sql包看作一个数据库操作抽象层,因为database/sql并不直接连接并操作数据库,而是为不同的数据库驱动提供了统一的API,database/sql包与驱动包(driver)的关系如下图所示:

对数据库的具体操作由对应数据库的驱动包来完成,访问不同的类型的数据库需要导入不同的驱动包,而所有驱动包都必须实现database/sql/driver包下的相关接口,因此database/sql、database/sql/driver以及驱动包的关系如下图所示:

这样做的好处在于,如果某一天我们想迁移数据库,比如从MySQL切换为Postgres,只需要更换驱动包即可,而不需要把数据库操作的代码重写一遍。

连接数据库

连接到数据库,获取一个数据库操作句柄,简单来说可以分为三步:

  1. 选择对应数据库的驱动,并导入。
  2. 配置连接数据库所需的DSN。
  3. 使用sql.Open()函数打开数据连接,获得*sql.DB对象。

DSN是Data Source Name,包含了连接数据库所需的参数,比如用户,密码、数据编码、数据库名称等。

下面我们以MySQL,Postgres,SQLite为例介绍在Go语言中如何连接到数据库。

MySQL

连接MySQL驱动包推荐用github.com/go-sql-driver/mysql库,其完整的DSN为如以所示,可以看到MySQL的DSN各个部分都是可选的:

[username[:password]@][protocol[host[:port]]]/dbname[?param1=value1&...&paramN=valueN]
  • username:用户名。
  • password:密码,与用户名之间要用冒号分隔。
  • protocol:网络协议,默认用tcp即可。
  • host:数据库地址。
  • port:端口号,默认为3306
  • dbname:数据库名称
  • param1~paramN:可选参数。
package main import ("database/sql"// 匿名导入_ "github.com/go-sql-driver/mysql"
)func main(){//db为*sql.DB//DSN要根据实际替换db, err := sql.Open("mysql", "user:password@/dbname")if err != nil {panic(err)}
}

Postgres

连接Postgres数据库推荐用github.com/lib/pq,其连接DSN为:

host=192.168.0.1 user=postgres dbname=postgres port=5432 password=123456 sslmode=disable
  • user:用户名。
  • password:密码,与用户名之间要用冒号分隔。
  • dbname:数据库名称。
  • sslmode:是否使用ss模式,其值可以是disable,required,verify-ca ,verify-full等。
  • host:主机
  • port:端口号
package main import ("context""fmt""os""github.com/lib/pq"
)func main(){dsn := "user=postgres dbname=postgres password=123456 sslmode=disable"db, err := sql.Open("postgres", dsn)if err != nil {log.Fatal(err)}defer db.Close()
}

SQLite

连接SQLite数据库推荐用github.com/mattn/go-sqlite3,SQLite是嵌入式数据库,因此它的DSN是数据库文件所在的路径:

import ("database/sql"_ "github.com/mattn/go-sqlite3"
)func main(){dsn := "./test.db"db,err := sql.Open("sqlite3",dsn)
}

关闭连接

打开数据库连接要记得关闭数据连接,一般在defer语句后面调用sql.DB的Close()方法:

import ("database/sql"_ "github.com/mattn/go-sqlite3"
)func main(){dsn := "./test.db"db,err := sql.Open("sqlite3",dsn)if err != nil{panic(err)}//关闭数据库连接defer db.Close()
}

连接池设置

sql.DB对象内包含一个数据库连池,并支持通过以下几个方法设置连接池的相关配置:

	db.SetConnMaxLifetime(0)  //最大打开的连接时间db.SetMaxIdleConns(50) //最大闲置连接数db.SetMaxOpenConns(50) //最大打开的连接数

示例数据表

为了后面更好的进行实例演示,我们需要一个演示数据库,这里以Mysql数据库为例,数据库名称为test,创建一个users数据表:

CREATE DATABASE IF NOT EXISTS test;USE test;CREATE TABLE IF NOT EXISTS users(
id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
gender TINYINT NOT NULL DEFAULT 0,
mobile VARCHAR(255) NOT NULL DEFAULT ''
);

sql.DB

前面我们调用sql.Open()获得了sql.DB对象,这是操作数据的句柄,也可以理解为一个数据库连接池,可以通过sql.DB的Conn()可以获得数据库连接池里的单个连接对象sql.Conn:

ctx, _ := context.WithCancel(context.Background())
conn, err := db.Conn(ctx)

无论是sql.DB,还是sql.Conn,其对数据库执行CURD操作的方法是类似,一般推荐使用sql.DB。

执行insert、update、delete用Exec()和ExecContext()方法,其签名如下:

func (db *DB) Exec(query string, args ...any) (Result, error)
func (db *DB) ExecContext(ctx context.Context, query string, args ...any) (Result, error)

上面的方法执行后返回sql.Result接口的实例,这个接口只有两个方法:

type Result interface {//执行insert语句时,返回自增idLastInsertId() (int64, error)//影响行数RowsAffected() (int64, error)
}

示例代码:

package mainimport ("database/sql""fmt"_ "github.com/mattn/go-sqlite3"
)func main() {db, err := sql.Open("sqlite3", "../test.db")if err != nil {panic(err)}defer db.Close()insertSql := "INSERT INTO users(name,gender,mobile) VALUES(?,?,?),(?,?,?)"insertResult, err := db.Exec(insertSql, "小白", 2, "166xxxxxxxx", "小张", 1, "13493023333")if err != nil {panic(err)}lastInsertId, _ := insertResult.LastInsertId()fmt.Printf("最新记录id:%d\n", lastInsertId)rowsAffected, _ := insertResult.RowsAffected()fmt.Println("影响行数:", rowsAffected)updateSql := "UPDATE users SET mobile = ? WHERE id = ?"updateResult, err := db.Exec(updateSql, "136xxxxxxxx", 1)if err != nil {panic(err)}rowsAffected, _ = updateResult.RowsAffected()fmt.Printf("影响行数:%d\n", rowsAffected)deleteSql := "DELETE FROM users WHERE id = ?"deleteResult, err := db.Exec(deleteSql, 14)if err != nil {panic(err)}rowsAffected, _ = deleteResult.RowsAffected()fmt.Printf("影响行数:%d\n", rowsAffected)
}

如果你只想从数据表查询一行数据,可以调用QueryRow()和QueryRowContext()方法:

func (db *DB) QueryRow(query string, args ...any) *Row
func (db *DB) QueryRowContext(ctx context.Context, query string, args ...any) *Row

上面的方法返回的是sql.Row对象,代表查询的那一行数据,这个对象只有Scan方法可以获取对象里的数据,调用Scan方法时传进去参数个数必须与查询返回的数据列数一致:

package mainimport ("database/sql""fmt"_ "github.com/mattn/go-sqlite3"
)func main() {db, err := sql.Open("sqlite3", "./test.db")if err != nil {panic(err)}defer db.Close()selectOne := "SELECT * FROM users WHERE id = ?"row := db.QueryRow(selectOne, 1)var (id     intname   stringgender uint8mobile string)//扫描数据err = row.Scan(&id, &name, &gender, &mobile)if err != nil {panic(err)}genderText := "未知"switch gender {case 1:genderText = "男"case 2:genderText = "女"}fmt.Printf("用户:%s | 性别:%s | 手机:%s\n", name, genderText, mobile)
}

然而,更多的时候,我们需要查询多行数据,可以调用Query()和QueryContext()方法:

func (db *DB) Query(query string, args ...any) (*Rows, error)
func (db *DB) QueryContext(ctx context.Context, query string, args ...any) (*Rows, error)

上面两个方法返回的是sql.Rows对象,代表查询回来的多行数据,可以在for循环语句中通过Next()和Scan()方法扫描每一行数据,传给Scan方法的参数数量必须与查询回来的列数相同,另外,要记得调用Close()方法关闭sql.Rows对象:

package mainimport ("database/sql""fmt""log"_ "github.com/mattn/go-sqlite3"
)func main() {db, err := sql.Open("sqlite3", "./test.db")if err != nil {panic(err)}defer db.Close()selectMany := "SELECT * FROM users"rows, err := db.Query(selectMany)if err != nil {panic(err)}defer rows.Close()for rows.Next() {var (id     intname   stringgender uint8mobile string)if err := rows.Scan(&id, &name, &gender, &mobile); err != nil {log.Fatal(err)}genderText := "未知"switch gender {case 1:genderText = "男"case 2:genderText = "女"}fmt.Printf("用户:%s | 性别:%s | 手机:%s\n", name, genderText, mobile)}}

sql.Stmt

SQL语句预编译机制允许先把带有参数占位符的SQL语句发送给数据库,数据库会提前对SQL语句进行编译,之后我们再发送对应占位符的参数给数据库 。

SQL语句的好处在于:

  • 预防SQL注入攻击。
  • 复杂的SQL语句,提前编译提高SQL语句执行效率。

调用sql.DB、sql.Conn和sql.Tx(下面会讲到)的Prepare()方法或者PrepareContext()会返回一个sql.Stmt:

stmt, err := db.Prepare("INSERT INTO users(name,) VALUES(?,?,?),(?,?,?)")

因为SQL语句已经预发送给数据库,因此调用sql.Stmt的ExecXXX()和QueryXXX()时,只需要发送参数即可:

Stmt.Exec("张三",2,"10086","李四",1,"10086111")

sql.Stmt对象里的方法返回值与sql.DB一样是sql.Result,具体使用参考前面的例子。

sql.Tx

sql.Tx表示一个数据库事务对象,调用sql.DB或者sql.Conn对象的Begin()或者BeginTx()方法会返回一个sql.Tx:

tx,err := db.Begin()

sql.Tx与sql.DB执行CURD的方法基本相同,所不同的是,通过sql.Tx执行的语句,最后要调用sql.Tx的Commit()方法提交事务,如果执行时有错误发生,则应该调用Rollback()方法回滚事务:

package mainimport ("database/sql"_ "github.com/mattn/go-sqlite3"
)func main() {db, err := sql.Open("sqlite3", "./test.db")if err != nil {panic(err)}defer db.Close()tx, err := db.Begin()if err != nil {panic(err)}if _, err := tx.Exec("INSERT INTO users VALUES(?,?,?,?)", 1, "小龙", 1, "137xxxxxxxx"); err != nil {tx.Rollback()}if _, err := tx.Exec("INSERT INTO users VALUES(?,?,?,?)", 2, "小明", 1, "137xxxxxxxx"); err != nil {tx.Rollback()}tx.Commit()
}

总结

通过本文的学习,我们能够掌握Go语言数据库编程的基本技能,并能够独立进行数据库应用程序的开发。Go语言数据库编程是一个实践性很强的领域,需要不断地学习和实践。希望本文能够为你的学习之路提供指导和帮助。

简单总结一下:

  • sql.DB对象表示一个数据库句柄,其中包含一个数据库连接池。
  • sql.Conn对象表示一个连接池里的普通数据库连接。
  • sql.Tx表示一个数据库事务对象,通过该对象执行的SQL语句要调用Commit()方法才会生效,如果执行过程发生错误,要调用Rollback()方法回滚事务。
  • sql.Stmt表示一个预编译对象,通过这个对象执行的SQL语句会先发送给数据库,之后再发送参数,这样可以避免SQL注入以及提前编译语句,提高执行效率。
  • sql.Rows是调用QueryXXX这类方法返回的表示多行数据的对象,内置迭代器,可以调用for语句迭代查询回来的数据。
  • sql.Row是调用QueryRowXXX这类方法返回的对象,代表一行数据。
  • sql.Result是调用ExecXXX这类方法进行update,delete,insert操作之后返回的结果。

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

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

相关文章

OLED调试简介

文章目录 一、介绍调试方法介绍OLED简介硬件电路OLED驱动函数 二、操作连接线路使用驱动函数显示内容 OLED.c的内容 一、介绍 调试方法介绍 OLED简介 硬件电路 OLED驱动函数 二、操作 连接线路 因为这两个引脚不做配置是浮空状态,在这里直接用电源给OLED供电 使…

【leetcode热题100】搜索二维矩阵

给你一个满足下述两条属性的 m x n 整数矩阵: 每行中的整数从左到右按非严格递增顺序排列。每行的第一个整数大于前一行的最后一个整数。 给你一个整数 target ,如果 target 在矩阵中,返回 true ;否则,返回 false 。…

python实现中国剩余定理

中国剩余定理又称孙子定理,是数论中一个重要定理。最早可见于我国的数学著作《孙子算经》卷下“物不知数”问题,原文如下: 有物不知其数,三三数之剩二,五五数之剩三,七七数之剩二。问物几何?即…

2024-02-04(hive)

1.Hive中的分区表 可以选择字段作为表分区。 分区其实就是HDFS上的不同文件夹。 分区表可以极大的提高特定场景下Hive的操作性能。 2.分区语法 create table tablename(...) partitioned by (分区列 列类型, ...) row format delimited fields terminated by ; 3.Hive中的…

《向量数据库指南》——Milvus Cloud「删除」:眼见未必为实

“执行 Collection 中的 delete 操作后,再次调用 num_entities 检查集合中的数据的条数,和删除前一致, delete 不能从物理层面上删除数据吗?”“删除的数据还能被查到是为什么?”“请问下删除 collection 后,磁盘大小没有恢复,该怎么处理?”社区中关于“删除”讨论最多…

ppi rust开发 python调用

创建python的一个测试工程 python -m venv venv .\venv\Scripts\activatepip install cffi创建一个rust的lib项目 cargo new --lib pyrustlib.rs #[no_mangle] pub extern "C" fn rust_add(x: i32, y: i32) -> i32 {x y }Cargo.toml [package] name "p…

【算法】递归入门

文章目录 一、基础知识二、刷题实战1. 汉诺塔问题2. 合并两个有序链表3. 反转链表4. 快速幂 三、技巧总结 一、基础知识 什么是递归: 函数自己调用自己 什么时候能用递归: 有重复子问题 如何看待递归函数: 看作一个黑盒 如何编写递归代码…

Allergo_17_4安装记录

习惯用Allergo软件中的Orcad组件来画原理图,画PCB用PADS PADS的安装记录参考:PADS VX 2.7安装记录-CSDN博客 一、资源: 资源:百度云安装包:Cadence SPB 17.4-2019 安装包 提取码:ajow 二、安装 2.1 右键…

链表算法练习

1、206-单链表反转 思路1:在链表上直接反转,只是需要一个节点存储剩余部分的链表指针 时间复杂度:O(n) 空间复杂度:O(1) const listNode (val,next) >{this.val val;this.next next; }const reverseList (head) >{if(!head || !hea…

百面嵌入式专栏(面试题)C语言面试题22道

沉淀、分享、成长,让自己和他人都能有所收获!😄 📢本篇我们将介绍C语言相关面试题 。 宏定义是在编译的哪个阶段被处理的?答案:宏定义是在编译预处理阶段被处理的。 解读:编译预处理:头文件包含、宏替换、条件编译、去除注释、添加行号。 写一个“标准”宏MIN,这个…

React中的Props:传递数据与组件通信

在React程序中,Props(属性)是组件之间通信的核心机制之一。Props允许将数据从一个组件传递到另一个组件,并在整个应用程序中有效地管理状态和行为。本文将探讨React中的Props,包括其基本概念和用法。 什么是Props&…

c#表达式树(MemberInitExpression)成员初始化表达式

在 C# 中,表达式树是表示代码中的表达式的一种抽象表示形式。它可以用于在运行时动态地构建、分析和执行代码。表达式树提供了一种方式来表示代码中的表达式,而不是直接执行它们。 成员初始化也可以在表达式树中使用,通过表达式树&#xff0…

备战蓝桥杯---搜索(进阶3)

看一道比较难又有趣的题: 下面是分析: 我们不妨把属性值看成点,一个装备可以看成一条边(只能选一个端点)不存在有装备属性值的当成一个点,于是我们便形成了树或图,如果是树的话,有一…

2024年的VUE2下的无效指令npm install --save vue-i18n

vue官网已经声明了不再维护vue2, vue-i18n安装依赖的时候就只接安装vue3的vue-i18, 直接报错: > npm install --save vue-i18n npm ERR! code ERESOLVE npm ERR! ERESOLVE unable to resolve dependency tree npm ERR! npm ERR! While resolving: yudao-ui-admin…

XSS攻击 - 不要再硬背了

XSS攻击是所有程序员都知道的一件事,它也是前后端面试的一个常考点。也正如标题所说,很多人在背它,为什么要背它?这点我深有感悟,最近我突破了那个key,所以我想将它分享出来。 XSS攻击,其实都是…

字节3面真题,LeetCode上hard难度,极具启发性题解

文章目录 🚀前言🚀LeetCode:41. 缺失的第一个正整数🚀思路🚀整个代码思路串一下🚀Code 🚀前言 铁子们好啊!阿辉来讲道题,这道题据说是23年字节3面真题,LeetC…

RabbitMQ-3.发送者的可靠性

发送者的可靠性 3.发送者的可靠性3.1.生产者重试机制3.2.生产者确认机制3.3.实现生产者确认3.3.1.开启生产者确认3.3.2.定义ReturnCallback3.3.3.定义ConfirmCallback 3.发送者的可靠性 首先,我们一起分析一下消息丢失的可能性有哪些。 消息从发送者发送消息&#…

前后端分离项目:前端的文件夹应该叫什么名字,后端呢

在前后端分离的项目中,为了提高项目的可读性和易管理性,给前端和后端的文件夹选择合适的名字是很重要的。这里提供一些建议,但请记住,最终的命名应该根据你的团队习惯、项目特性以及可能的公司规定来决定。 ### 前端文件夹命名建…

主键、候选键与外键的关系

主键、候选键与外键的关系 主键、候选键与外键的关系? 一个表的外键只能是其他表的主键吗?还是其他表的候选键也可以? 比如:员工表的字段中包含员工ID和员工账号,其中员工ID为主键,员工账号为普通候选键&am…

【状态管理一】概览:状态使用、状态分类、状态具体使用

文章目录 一. 状态使用概览二. 状态的数据类型1. 算子层面2. 接口层面2.1. UML与所有状态类型介绍2.2. 内部状态:InternalKvState 将知识与实际的应用场景、设计背景关联起来,这是学以致用、刨根问底知识的一种直接方式。 本文介绍 状态数据管理&#x…