Go语言实战数据库

type

status

date

slug

summary

连接数据库

下载依赖

导入数据驱动

_ "github.com/go-sql-driver/mysql" 的作用是导入mysql驱动包，并执行该包的初始化代码，以便在后续的数据库操作中可以使用该驱动。但由于我们可能并不直接在代码中使用该包内的标识符（例如函数或类型），因此使用下划线来表示不需要直接访问该包内的内容。如果你在代码中确实需要使用包内的标识符，那么就不应该使用下划线，而是直接导入该包并在代码中使用它。

链接数据库

defer 关键字用于延迟执行函数调用，如果不使用会导致报错：数据库连接失败 sql: database is closed，如果不想使用 defer，依然可以将 db.Close( ) 放在结尾。

另外，你还可以使用 DB.SetMaxIdleConns 和 DB.SetMaxOpenConns 方法来设置最大空闲连接数和最大打开连接数，以防止数据库连接超过最大限制而被关闭。

sql.Open( )并不会与数据库正真的连接，而是在实际需要执行查询或操作时才会建立连接。它的返回值是一个 *sql.DB 类型的对象，代表了数据库连接池。db.Ping( ): 这个方法用于检查当前连接是否有效。在数据库操作之前，有时需要确保连接是可用的，以防止执行操作时出现意外错误。db.Ping() 方法会尝试与数据库建立连接，如果连接成功则表示连接有效，否则会返回错误信息。

执行sql语句

Go将数据库操作分为两类：Query与Exec

Query表示查询，它会从数据库获取查询结果（一系列行，可能为空）。

Exec表示执行语句，它不会返回行。

常见数据库操作模式：

QueryRow只返回一行的查询，作为Query的一个常见特例。

Prepare准备一个需要多次使用的语句，供后续执行用。

查询

查询分为两种，一种是单行查询QueryRow()，一种是多行查询Query() 。QueryRow( )总是返回非nil的值，直到返回值的Scan方法被调用时，才会返回被延迟的错误，如：未找到结果。多行查询Query( )执行一次查询，返回多行结果，一般用于执行select命令。

说明：

使用db.Query()来发送查询到数据库，获取结果集Rows，并检查错误。

使用rows.Next()作为循环条件，迭代读取结果集。

使用rows.Scan从结果集中获取一行结果。

使用rows.Close()关闭结果集，释放连接。

输出：

下面以函数的形式给出：

增删改用的都是Exec方法，Exec执行一次命令（包括查询、删除、更新、插入等），返回的Result是对已执行的SQL命令的总结。

插入

更新

删除

完整代码：

运行结果：

预处理

什么是预处理

普通sql执行：

客户端对SQL语句进行占位符替换得到完整的SQL语句。

客户端发送完整SQL语句到MySQL服务端

MySQL服务端执行完整的SQL语句并将结果返回给客户端。

预处理：

把SQL语句分成两部分，命令部分与数据部分。

先把命令部分发送给MySQL服务端，MySQL服务端进行SQL预处理。

然后把数据部分发送给MySQL服务端，MySQL服务端对SQL语句进行占位符替换。

MySQL服务端执行完整的SQL语句并将结果返回给客户端。

为什么要预处理

优化MySQL服务器重复执行SQL的方法，可以提升服务器性能。

避免SQL注入问题。

Go实现MySQL预处理

func (db *DB) Prepare(query string) (*Stmt, error)

预处理和普通执行在代码上就多出一部分，下面仅以查询作展示：

事务

事务是一个最小的不可再分的工作单元。一个事务中的所有操作，要么全部完成，要么全部不完成，不会结束在中间某个环节。事务在执行过程中发生错误，会被回滚到事务开始前的状态，就像这个事务从来没有执行过一样。事务处理结束后，对数据的修改就是永久的，即便系统故障也不会丢失。

示例：