Golang如何连接并操作MySQL数据库 使用database/sql标准库教程

golang连接和操作mysql数据库最常用的方式是使用标准库database/sql配合mysql驱动。1. 安装驱动：执行go get -u github.com/go-sql-driver/mysql并导入\_ "github.com/go-sql-driver/mysql"。2. 连接数据库：通过sql.open("mysql", dsn)创建连接，dsn格式为用户名:密码@协议(地址:端口)/数据库名，并用db.ping()验证连接。3. 查询数据：多行查询用db.query()配合rows.next()和rows.scan()遍历结果，单行查询用db.queryrow().scan()。4. 写操作：插入、更新、删除使用db.exec()，通过result.lastinsertid()和result.rowsaffected()获取执行结果。5. 优化性能：通过db.setmaxopenconns()、db.setmaxidleconns()和db.setconnmaxlifetime()调整连接池参数。开发中需注意错误处理、资源释放（如rows.close()和db.close()）以及使用占位符?防止sql注入。

Golang连接和操作MySQL数据库，最常用的方式是使用标准库

database/sql

go-sql-driver/mysql

下面直接进入具体实现方式。

安装MySQL驱动

在 Golang 中，

database/sql

立即学习“go语言免费学习笔记（深入）”；

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

这一步完成后，你就可以在代码中导入

_ "github.com/go-sql-driver/mysql"

连接MySQL数据库

连接 MySQL 主要通过

sql.Open()

示例代码如下：

package main

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // 尝试连接数据库
    err = db.Ping()
    if err != nil {
        panic(err)
    }
}

• dsn

  登录后复制
  是数据源名称，格式为：

  用户名:密码@协议(地址:端口)/数据库名

  登录后复制

• sql.Open()

  登录后复制
  的第一个参数必须是驱动名，这里是

  "mysql"

  登录后复制
• 使用完数据库后记得调用

  db.Close()

  登录后复制
  释放资源

常见错误：

• DSN 格式错误
• 数据库服务未启动或网络不通
• 用户权限不足

查询数据

查询操作使用

db.Query()

db.QueryRow()

动态WEB网站中的PHP和MySQL：直观的QuickPro指南第2版

动态WEB网站中的PHP和MySQL详细反映实际程序的需求，仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法，让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能，对常用的、强大的包

508

查看详情

例如查询用户信息：

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

for rows.Next() {
    var id int
    var name string
    err := rows.Scan(&id, &name)
    if err != nil {
        panic(err)
    }
    fmt.Println(id, name)
}

• 使用

  rows.Next()

  登录后复制
  遍历每一行
• 每次遍历用

  Scan()

  登录后复制
  把字段值读取到变量中
• 记得关闭

  rows

  登录后复制

如果是单条查询，可以这样写：

var name string
err := db.QueryRow("SELECT name FROM users WHERE id = ?", 1).Scan(&name)
if err != nil {
    panic(err)
}

插入、更新与删除操作

这些操作属于“写”操作，使用

db.Exec()

例如插入一条记录：

result, err := db.Exec("INSERT INTO users(name, age) VALUES (?, ?)", "Tom", 25)
if err != nil {
    panic(err)
}

lastInsertId, _ := result.LastInsertId()
rowsAffected, _ := result.RowsAffected()

• LastInsertId()

  登录后复制
  获取自增主键的值（适用于 INSERT）

• RowsAffected()

  登录后复制
  获取受影响的行数（适用于 UPDATE、DELETE）

建议：

• 使用占位符

  ?

  登录后复制
  来防止 SQL 注入
• 处理错误时不要忽略返回值

使用连接池优化性能

默认情况下，

database/sql

db.SetMaxOpenConns(10)   // 设置最大打开连接数
db.SetMaxIdleConns(5)    // 设置最大空闲连接数
db.SetConnMaxLifetime(0) // 设置连接最大生命周期（0表示不限制）

这些设置可以根据实际业务压力进行调整。比如并发高的服务可以适当增加最大连接数；如果连接容易超时，可以设置合理的生命周期。

基本上就这些内容了。虽然看起来步骤不少，但只要按照模板写，连接和操作 MySQL 并不复杂，只是有些细节容易被忽略，比如错误处理、资源释放等。把这些基础打牢，后续开发就会顺畅很多。

以上就是Golang如何连接并操作MySQL数据库 使用database/sql标准库教程的详细内容，更多请关注php中文网其它相关文章！