首先安装MySQL驱动，然后使用database/sql包连接数据库并执行查询。通过sql.Open()建立连接，db.Ping()测试连通性，QueryRow()查询单行，Query()查询多行并遍历结果，Exec()执行插入等操作，最后用Scan()读取数据并处理错误。完整示例展示了查询用户列表并存入切片输出。
要让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操作。
1. 查询单行数据（QueryRow）
var id intvar name stringerr := db.QueryRow(“SELECT id, name FROM users WHERE id = ?”, 1).Scan(&id, &name)if err != nil { log.Fatal(“查询失败:”, err)}fmt.Printf(“用户: %d, %sn”, 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 intvar name stringif err := rows.Scan(&id, &name); err != nil {log.Fatal(“读取数据失败:”, err)}fmt.Printf(“ID: %d, Name: %sn”, 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: %dn”, lastId)
注意：所有SQL操作都应处理错误，尤其是
Scan
和
Exec
后的返回值。
完整示例：查询用户列表
package main
import (“database/sql””fmt””log”
_ "github.com/go-sql-driver/mysql"
)
type User struct {ID intName 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 []Userfor 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 - %sn", u.ID, u.Name)}
}
基本上就这些。只要配置好DSN，导入驱动，使用
database/sql
的标准方法，就能稳定地操作MySQL。实际项目中建议封装数据库操作，使用连接池配置（如
SetMaxOpenConns
）提升性能。
以上就是Golang项目如何连接MySQL数据库并执行基本的SQL查询的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1402334.html
微信扫一扫 
支付宝扫一扫 
