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,配合 MySQL 驱动(如
go-sql-driver/mysql)。这种方式结构清晰、性能稳定,适合大多数项目需求。

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

安装MySQL驱动
在 Golang 中,
database/sql是一个接口层,需要搭配具体的驱动才能操作数据库。要连接 MySQL,首先需要安装官方推荐的驱动:
立即学习“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详细反映实际程序的需求,仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法,让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能,对常用的、强大的包
例如查询用户信息:
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()执行 SQL 语句即可。
例如插入一条记录:
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 并不复杂,只是有些细节容易被忽略,比如错误处理、资源释放等。把这些基础打牢,后续开发就会顺畅很多。









