当前位置：首页 > 文章列表 > Golang > Go教程 > Golang连接MySQL查询教程详解

Golang连接MySQL查询教程详解

2026-01-26 17:02:45 0浏览收藏

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《Golang连接MySQL执行SQL查询教程》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

首先安装MySQL驱动，然后使用database/sql包连接数据库并执行查询。通过sql.Open()建立连接，db.Ping()测试连通性，QueryRow()查询单行，Query()查询多行并遍历结果，Exec()执行插入等操作，最后用Scan()读取数据并处理错误。完整示例展示了查询用户列表并存入切片输出。

Golang项目如何连接MySQL数据库并执行基本的SQL查询

要让Golang项目连接MySQL数据库并执行基本的SQL查询，你需要使用Go的database/sql包搭配一个MySQL驱动。最常用的是github.com/go-sql-driver/mysql驱动。下面一步步说明如何实现。

安装MySQL驱动

在项目目录下运行以下命令安装MySQL驱动：

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

这个驱动实现了database/sql接口，是连接MySQL的基础。

连接MySQL数据库

使用sql.Open()函数创建数据库连接。注意这并不会立即建立连接，真正的连接会在第一次需要时建立。

示例代码：

package main

import ( "database/sql" "fmt" "log"

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

)

func main() { dsn := "用户名:密码@tcp(localhost:3306)/数据库名" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal("打开数据库失败:", err) } defer db.Close()

// 测试连接是否成功
if err := db.Ping(); err != nil {
    log.Fatal("数据库连接失败:", err)
}

fmt.Println("数据库连接成功")

}

说明：
- 用户名:密码@tcp(主机:端口)/数据库名 是标准的DSN（Data Source Name）格式。
- 导入驱动时使用 _ "github.com/go-sql-driver/mysql" 是为了触发其init()函数注册驱动。
- db.Ping() 用于验证与数据库的连接是否正常。

执行基本SQL查询

连接成功后，可以使用Query()、QueryRow()、Exec()等方法执行SQL操作。

1. 查询单行数据（QueryRow）

var id int var name string err := db.QueryRow("SELECT id, name FROM users WHERE id = ?", 1).Scan(&id, &name) if err != nil { log.Fatal("查询失败:", err) } fmt.Printf("用户: %d, %s\n", id, name)

2. 查询多行数据（Query）

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

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) }

if err := rows.Err(); err != nil { log.Fatal("遍历行时出错:", err) }

3. 执行插入、更新、删除（Exec）

result, err := db.Exec("INSERT INTO users(name, email) VALUES(?, ?)", "Alice", "alice@example.com") if err != nil { log.Fatal("插入失败:", err) }

lastId, err := result.LastInsertId() if err != nil { log.Fatal("获取ID失败:", err) } fmt.Printf("插入成功，ID: %d\n", lastId)

注意：所有SQL操作都应处理错误，尤其是Scan和Exec后的返回值。

完整示例：查询用户列表

package main

import ( "database/sql" "fmt" "log"

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

)

type User struct { ID int Name string }

func main() { dsn := "root:123456@tcp(localhost:3306)/testdb" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal(err) } defer db.Close()

if err := db.Ping(); err != nil {
    log.Fatal(err)
}

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

var users []User
for rows.Next() {
    var u User
    if err := rows.Scan(&u.ID, &u.Name); err != nil {
        log.Fatal(err)
    }
    users = append(users, u)
}

for _, u := range users {
    fmt.Printf("用户: %d - %s\n", u.ID, u.Name)
}

}

基本上就这些。只要配置好DSN，导入驱动，使用database/sql的标准方法，就能稳定地操作MySQL。实际项目中建议封装数据库操作，使用连接池配置（如SetMaxOpenConns）提升性能。

今天关于《Golang连接MySQL查询教程详解》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！

golang mysql