一文理清database/sql包的使用场景和宕机查询流程

2024-05-25 19:52

本文主要是介绍一文理清database/sql包的使用场景和宕机查询流程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一文理清database/sql包你可能遇到的问题

    • 那么database/sql包实现了什么功能呢?
      • 建立数据库连接
      • 检测连接是否能ping通
      • 通过连接进行具体的sql查询
      • 查询完将连接进行关闭
      • 当数据库宕掉重启后再次查询
    • database/sql包创建的db连接 对于数据库宕掉后重启是否仍然有效?


当你点开这篇文章的时候你应该是想用go来与数据库进行交互的咯,那么正常流程下,你会涉及到建立数据库连接、检测连接是否能ping通、通过连接进行具体的sql查询,查询完将连接进行关闭,当数据库宕掉重启后再次查询等等。下面对于这些实现都会有介绍。

那么database/sql包实现了什么功能呢?

我们来看一下官方的答案。

Go语言中的database/sql包提供了一套与数据库进行交互的统一编程接口。它的主要功能和特性可以总结为以下几点:

  1. 统一的编程接口database/sql包通过提供一组统一的API,如Prepare(), Exec(), Query()等,使得开发人员能够以相同的方式操作不同的数据库。这大大提高了代码的可移植性和灵活性。
  2. 驱动支持database/sql包本身并不直接与数据库通信,而是依赖于第三方数据库驱动程序。这些驱动程序需要实现database/sql/driver包中定义的Driver接口,并在程序初始化阶段通过sql.Register()方法注册到database/sql中。常见的关系型数据库如MySQL、PostgreSQL、Oracle、Gbase8s等都有对应的Go语言驱动程序。比如oracle的驱动mattn/go-oci8: Oracle driver for Go using database/sql (github.com)
  3. 连接池管理database/sql维护了一个数据库连接池,用于管理数据库连接。当通过sql.Open()打开一个数据库连接时,database/sql会在合适的时机调用注册的驱动来创建一个具体的连接,并将其添加到连接池中。连接池会负责连接的复用、管理和维护工作,并且这是并发安全的。
  4. 事务支持database/sql包还支持事务处理,可以通过Tx类型的方法如Begin(), Commit(), Rollback()等来进行事务的管理。
  5. 安全性:为了防止SQL注入攻击,database/sql包推荐使用预编译语句和参数化查询。这样可以确保所有的SQL语句在执行前都会被预先分析和编译,从而避免了潜在的安全问题。

建立数据库连接

package demoimport ("database/sql"
)var mydb,_ =  sql.Open("mysql","connection_string")

检测连接是否能ping通

err = db.Ping()
if err != nil {panic(err)
}

通过连接进行具体的sql查询

func testSelect(db *sql.DB) error {rows, err := db.Query("select 3.14, 'foo' from dual")if err != nil {return err}defer rows.Close()for rows.Next() {var f1 float64var f2 stringrows.Scan(&f1, &f2)println(f1, f2) // 3.14 foo}return nil
}
//当然 对于不同的查询需求使用的函数不一样 这里就当你使用的时候直接去搜就好啦
//比如 需要返回值时
var primary string
err := c.db.QueryRow("select ha_primary from sysha_type").Scan(&primary)

查询完将连接进行关闭

db.Close()

当数据库宕掉重启后再次查询

if err = testSelect(db); err != nil {fmt.Println(err)return}

大家应该发现了再次查询和查询语句是一样的。其实对于执行上,都是执行的查询语句。但是我们需要考虑的是经历过数据库宕掉之后,还是传原来的db吗?那么就引出下一个问题。

database/sql包创建的db连接 对于数据库宕掉后重启是否仍然有效?

当数据库宕掉后重启,原先由database/sql包创建的db连接并不会自动恢复其有效性。在Go语言中,database/sql包提供了与SQL数据库进行交互的功能,其中包括连接池的管理。连接池负责维护打开的数据库连接,以便在多个数据库操作之间重用这些连接,从而提高应用程序的性能。然而,当数据库宕机并重新启动后,原有的数据库连接将不再有效,需要重新建立连接。以下是具体分析:

  1. 数据库连接状态检测
    • 在正常情况下,database/sql的连接池会维护一定数量的活跃和空闲连接。
    • db.SetMaxIdleConns()用于设置连接池中空闲连接的最大数量。
    • db.SetMaxOpenConns()用于设置到数据库的同时最大打开连接数。
    • db.SetConnMaxLifetime()可以设置连接的最大生命周期,超过这个时间,连接将被关闭并从池中移除。
  2. 数据库宕机影响
    • 当数据库宕机时,所有现有的数据库连接将会失效。
    • 即使数据库随后重启,这些失效的连接也不会自动恢复其有效性。
  3. 数据库重启处理
    • 在数据库重启后,必须创建新的数据库连接以替换失效的连接。
    • database/sql包本身不提供自动重连功能,因此需要在应用程序逻辑中处理这种情况。
  4. 连接池参数配置
    • 通过合理配置连接池参数,如最大空闲连接数、最大打开连接数和连接最大生命周期,可以优化数据库连接的使用效率。
    • 这些参数的设置应根据应用程序的具体需求和数据库的实际性能进行调整。
  5. 异常情况处理
    • 应用程序应具备异常处理机制,能够在数据库不可用时进行适当的错误处理和重试逻辑。
    • 可以考虑实现自定义的重连策略,例如指数退避算法,以避免在数据库重启期间过多地尝试连接。
  6. 测试与验证
    • 在开发过程中,应通过模拟数据库宕机和重启的场景来测试应用程序的异常处理能力。
    • 确保在实际部署前,应用程序能够正确处理数据库连接失效的情况。

所以,正确的执行步骤应该是,ping时发现db连接失效了,不通了,执行close操作,再次使用Open打开新的连接,ping检查db连接是否有效,再进行查询。

这篇关于一文理清database/sql包的使用场景和宕机查询流程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1002468

相关文章

解决Maven项目idea找不到本地仓库jar包问题以及使用mvn install:install-file

《解决Maven项目idea找不到本地仓库jar包问题以及使用mvninstall:install-file》:本文主要介绍解决Maven项目idea找不到本地仓库jar包问题以及使用mvnin... 目录Maven项目idea找不到本地仓库jar包以及使用mvn install:install-file基

Windows 上如果忘记了 MySQL 密码 重置密码的两种方法

《Windows上如果忘记了MySQL密码重置密码的两种方法》:本文主要介绍Windows上如果忘记了MySQL密码重置密码的两种方法,本文通过两种方法结合实例代码给大家介绍的非常详细,感... 目录方法 1:以跳过权限验证模式启动 mysql 并重置密码方法 2:使用 my.ini 文件的临时配置在 Wi

一文详解Java异常处理你都了解哪些知识

《一文详解Java异常处理你都了解哪些知识》:本文主要介绍Java异常处理的相关资料,包括异常的分类、捕获和处理异常的语法、常见的异常类型以及自定义异常的实现,文中通过代码介绍的非常详细,需要的朋... 目录前言一、什么是异常二、异常的分类2.1 受检异常2.2 非受检异常三、异常处理的语法3.1 try-

MySQL重复数据处理的七种高效方法

《MySQL重复数据处理的七种高效方法》你是不是也曾遇到过这样的烦恼:明明系统测试时一切正常,上线后却频频出现重复数据,大批量导数据时,总有那么几条不听话的记录导致整个事务莫名回滚,今天,我就跟大家分... 目录1. 重复数据插入问题分析1.1 问题本质1.2 常见场景图2. 基础解决方案:使用异常捕获3.

Python使用getopt处理命令行参数示例解析(最佳实践)

《Python使用getopt处理命令行参数示例解析(最佳实践)》getopt模块是Python标准库中一个简单但强大的命令行参数处理工具,它特别适合那些需要快速实现基本命令行参数解析的场景,或者需要... 目录为什么需要处理命令行参数?getopt模块基础实际应用示例与其他参数处理方式的比较常见问http

SQL中redo log 刷⼊磁盘的常见方法

《SQL中redolog刷⼊磁盘的常见方法》本文主要介绍了SQL中redolog刷⼊磁盘的常见方法,将redolog刷入磁盘的方法确保了数据的持久性和一致性,下面就来具体介绍一下,感兴趣的可以了解... 目录Redo Log 刷入磁盘的方法Redo Log 刷入磁盘的过程代码示例(伪代码)在数据库系统中,r

C 语言中enum枚举的定义和使用小结

《C语言中enum枚举的定义和使用小结》在C语言里,enum(枚举)是一种用户自定义的数据类型,它能够让你创建一组具名的整数常量,下面我会从定义、使用、特性等方面详细介绍enum,感兴趣的朋友一起看... 目录1、引言2、基本定义3、定义枚举变量4、自定义枚举常量的值5、枚举与switch语句结合使用6、枚

mysql中的group by高级用法

《mysql中的groupby高级用法》MySQL中的GROUPBY是数据聚合分析的核心功能,主要用于将结果集按指定列分组,并结合聚合函数进行统计计算,下面给大家介绍mysql中的groupby用法... 目录一、基本语法与核心功能二、基础用法示例1. 单列分组统计2. 多列组合分组3. 与WHERE结合使

使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)

《使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)》PPT是一种高效的信息展示工具,广泛应用于教育、商务和设计等多个领域,PPT文档中常常包含丰富的图片内容,这些图片不仅提升了... 目录一、引言二、环境与工具三、python 提取PPT背景图片3.1 提取幻灯片背景图片3.2 提取

Mysql用户授权(GRANT)语法及示例解读

《Mysql用户授权(GRANT)语法及示例解读》:本文主要介绍Mysql用户授权(GRANT)语法及示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录mysql用户授权(GRANT)语法授予用户权限语法GRANT语句中的<权限类型>的使用WITH GRANT