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

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

P粉602998670

发布： 2025-09-01 10:22:01

原创

844人浏览过

首先安装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()

登录后复制

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

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

示例代码：

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操作。

蓝心千询

蓝心千询是vivo推出的一个多功能AI智能助手

查看详情

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，导入驱动，使用