一文理清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

相关文章

Ubuntu 24.04启用root图形登录的操作流程

《Ubuntu24.04启用root图形登录的操作流程》Ubuntu默认禁用root账户的图形与SSH登录,这是为了安全,但在某些场景你可能需要直接用root登录GNOME桌面,本文以Ubuntu2... 目录一、前言二、准备工作三、设置 root 密码四、启用图形界面 root 登录1. 修改 GDM 配

MyBatis-Plus通用中等、大量数据分批查询和处理方法

《MyBatis-Plus通用中等、大量数据分批查询和处理方法》文章介绍MyBatis-Plus分页查询处理,通过函数式接口与Lambda表达式实现通用逻辑,方法抽象但功能强大,建议扩展分批处理及流式... 目录函数式接口获取分页数据接口数据处理接口通用逻辑工具类使用方法简单查询自定义查询方法总结函数式接口

C++中assign函数的使用

《C++中assign函数的使用》在C++标准模板库中,std::list等容器都提供了assign成员函数,它比操作符更灵活,支持多种初始化方式,下面就来介绍一下assign的用法,具有一定的参考价... 目录​1.assign的基本功能​​语法​2. 具体用法示例​​​(1) 填充n个相同值​​(2)

MySql基本查询之表的增删查改+聚合函数案例详解

《MySql基本查询之表的增删查改+聚合函数案例详解》本文详解SQL的CURD操作INSERT用于数据插入(单行/多行及冲突处理),SELECT实现数据检索(列选择、条件过滤、排序分页),UPDATE... 目录一、Create1.1 单行数据 + 全列插入1.2 多行数据 + 指定列插入1.3 插入否则更

MySQL深分页进行性能优化的常见方法

《MySQL深分页进行性能优化的常见方法》在Web应用中,分页查询是数据库操作中的常见需求,然而,在面对大型数据集时,深分页(deeppagination)却成为了性能优化的一个挑战,在本文中,我们将... 目录引言:深分页,真的只是“翻页慢”那么简单吗?一、背景介绍二、深分页的性能问题三、业务场景分析四、

MySQL 迁移至 Doris 最佳实践方案(最新整理)

《MySQL迁移至Doris最佳实践方案(最新整理)》本文将深入剖析三种经过实践验证的MySQL迁移至Doris的最佳方案,涵盖全量迁移、增量同步、混合迁移以及基于CDC(ChangeData... 目录一、China编程JDBC Catalog 联邦查询方案(适合跨库实时查询)1. 方案概述2. 环境要求3.

Spring StateMachine实现状态机使用示例详解

《SpringStateMachine实现状态机使用示例详解》本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解... 目录什么是状态机使用示例什么是状态机状态机是计算机科学中的​​核心建模工具​​,用于描述对象在其生命

nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析(结合应用场景)

《nginx-t、nginx-sstop和nginx-sreload命令的详细解析(结合应用场景)》本文解析Nginx的-t、-sstop、-sreload命令,分别用于配置语法检... 以下是关于 nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析,结合实际应

SQL server数据库如何下载和安装

《SQLserver数据库如何下载和安装》本文指导如何下载安装SQLServer2022评估版及SSMS工具,涵盖安装配置、连接字符串设置、C#连接数据库方法和安全注意事项,如混合验证、参数化查... 目录第一步:打开官网下载对应文件第二步:程序安装配置第三部:安装工具SQL Server Manageme

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用:如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.