golang如何操作mysql数据

林译川

2026-10-01 • 👁 0人浏览过

什么是 MySQL 由Oracle公司赞助开发的MySQL是一种广泛应用于互联网基础设施中的关系型数据库管理系统。它支持多种操作系统和编程语言，包括 Go 语言，并且拥有一系列对于大型数据集成和高性能查询支持良好的特性。 MySQL使用基于表的数据结构，每行代表一个记录，每列代表一个字段。它使用 SQL 语言对数据进行操作，其中最常见的 SQL 操作包括 SELECT、INSERT、UPDATE、DELETE 和 CREATE TABLE。 Go 语言中的 MySQL 驱动在 Go 语言中，我们可以使用第三方 MySQL 驱动程序来连接和查询 MySQL 数据库。但是，GO 语言标准库中已经包含了

database/sql

包，这个包已经实现了标准的 SQL 数据库接口，可以和其他方便的流行的 SQL 数据库交互操作，包括 MySQL、PostgreSQL 和 SQLite 等。因此，在我们开始构建查询 MySQL 的 Go 应用程序之前，我们需要安装 MySql 驱动程序。可以使用命令行命令

go get -u github.com/go-sql-driver/mysql

快捷安装。立即学习 “ go语言免费学习笔记（深入） ”；这是因为在 Go 语言中，所有的数据访问都需通过

SQL.DB

连接进行。并且驱动程序的目的是用来实现

database/sql

的功能中那样的的接口约定。建立连接在 Go 语言中，建立到 MySQL 数据库的连接是基于连接字符串的，连接字符串包含连接 MySQL 所需的所有参数，如用户名、密码、主机名或 IP 地址、端口号和数据库名称等。 MySQL（Linux） MySQL 9.6.0是面向Linux平台的2026年创新版本，核心架构迎来重大革新。其将外键约束与级联操作从InnoDB引擎层上移至SQL层，确保所有数据变更均被完整记录至Binlog，彻底解决了CDC（变更数据捕获）与主从复制中的数据不一致难题。此外，该版本引入container_aware启动选项以原生适配容器环境，并对审计日志进行了组件化重构，为追求极致数据一致性与云原生体验的开发者提供了全新选择。下载

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
    log.Fatal(err)
}

查询数据在 Go 语言中，可以使用

db.Query()

、

db.QueryRow()

和

db.Exec()

函数查询和操作 MySQL 数据库中的数据。

db.Query()

函数用于查询多条记录，返回一个

*sql.Rows

对象。

db.QueryRow()

函数用于查询单条记录，返回一个

*sql.Row

对象，类似于

resultset

，但是它只返回第一行记录，通常用于查询单个唯一记录。

db.Exec()

函数用于执行非查询 SQL 语句，例如 INSERT、UPDATE 和 DELETE，返回一个

sql.Result

对象。在本例中，我们使用

db.Query()

函数来查询所有记录。我们将使用一个简单的计数器来统计记录的数量，并将每行数据打印到控制台。

rows, err := db.Query("SELECT id, name FROM users")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

count := 0
for rows.Next() {
    var id int
    var name string
    if err := rows.Scan(&id, &name); err != nil {
        log.Fatal(err)
    }
    fmt.Printf("id=%d, name=%s\n", id, name)
    count++
}
if err := rows.Err(); err != nil {
    log.Fatal(err)
}

fmt.Printf("Found %d users\n", count)

必须在检索数据后调用

rows.Close()

函数以释放与

*sql.Rows

关联的数据库资源。同时，代码中使用了

rows.Next()

函数，它返回一个布尔值，指示是否还有更多的行可以进行处理。另外，在这个例子中使用了

rows.Scan()

函数将每行记录的值复制到这个例子中定义的

id

和

name

变量中，然后在控制台中打印每个值。插入数据我们也可以使用 Go 语言插入数据到 MySQL 数据库中，最简单的方法使用

db.Exec()

函数。我们可以将插入语句传递到

db.Exec()

函数中，它将以 SQL 语句的形式在 MySQL 中执行。

result, err := db.Exec("INSERT INTO users(name, email) VALUES('John Doe', 'johndoe@gmail.com')")
if err != nil {
    log.Fatal(err)
}

rowsAffected, err := result.RowsAffected()
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Inserted %d rows into users table\n", rowsAffected)

我们可以使用

result.RowsAffected()

获取结果集中受影响的行数，并使用该数值在控制台中打印更新数据的数量。

相关文章