go 框架集成 mysql 数据库指南:安装 Mysql 数据库和 go 驱动程序 go-mysql-driver。用 go-mysql-driver 连接到数据库,指定用户名、密码和数据库名称。创建和执行插入查询,使用 stmt.exec() 方法。创建和执行查询数据,使用 stmt.query() 方法和 rows.scan() 方法获取结果。使用 defer stmt.close() 关闭查询,防止资源泄漏。使用错误处理函数 checkerror() 处理数据库操作中的错误。
Go 框架集成 MySQL 数据库指南
简介
在 Go 应用程序中集成 MySQL 数据库对于在持久化和检索数据时实现高性能和可靠性至关重要。本文将指导您使用最流行的 Go 数据库驱动程序 go-mysql-driver 来逐步集成 MySQL 数据库。
立即学习“go语言免费学习笔记(深入)”;
先决条件
- 安装 MySQL 数据库
- 安装 Go 1.13 或更高版本
安装数据库驱动程序
1
|
go get Github.com/ go -sql-driver/mysql
|
连接到数据库
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
import (
"io"
"os"
"github.com/go-sql-driver/mysql"
)
func connectToDB() (io.Closer, error ) {
dbuser := os.Ge.env( "DB_USER" )
dbPass := os.Getenv( "DB_PASS" )
dbName := os.Getenv( "DB_NAME" )
db, err := mysql.Open( "mysql" , dbUser+ ":" +dbPass+ "@/" +dbName)
if err != nil {
return nil , err
}
return db, nil
}
|
创建和执行查询
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
func createAndExecuteQuery(db io.Closer) error {
stmt, err := db.Prepare( "INSERT INTO users (name, email) VALUES (?, ?)" )
if err != nil {
return err
}
_, err = stmt.Exec( "John Doe" , "johndoe@example.com" )
if err != nil {
return err
}
if err := stmt. Close (); err != nil {
return err
}
return nil
}
|
查询数据
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
func querydata(db io.Closer) ([][] string , error ) {
stmt, err := db.Prepare( "SELECT name, email FROM users" )
if err != nil {
return nil , err
}
rows, err := stmt.Query()
if err != nil {
return nil , err
}
var result [][] string
for rows.Next() {
var name, email string
if err := rows.Scan(&name, &email); err != nil {
return nil , err
}
result = append (result, [] string {name, email})
}
if err := rows.Err(); err != nil {
return nil , err
}
if err := stmt. Close (); err != nil {
return nil , err
}
return result, nil
}
|
处理错误
1
2
3
4
5
|
func checkError(err error ) {
if err != nil {
log.Fatal(err)
}
}
|
最佳实践
- 使用连接池来管理数据库连接。
- 始终使用 defer stmt.Close() 关闭查询,以释放资源。
- 使用错误处理来处理数据库操作中的错误。
实战案例
此示例展示了如何使用 go-mysql-driver 在 Go 应用程序中管理基本的增删改查操作:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
func main() {
db, err := connectToDB()
checkError(err)
defer db. Close ()
err = createAndExecuteQuery(db)
checkError(err)
data, err := queryData(db)
checkError(err)
fmt. Println ( "查询结果:" )
for _, row := range data {
fmt. Println (row[ 0 ] + " - " + row[ 1 ])
}
}
|