使用database/sql包操作MySQL
最后更新于：2022-04-02 06:47:58
## 使用database/sql包操作MySQL
关系数据库较为常见且易于理解。MySQL和Postgres是两个最流行的开源关系数据库。本节将演示如何使用database/sql包，该包为许多关系数据库提供钩子并自动处理连接池、连接持续时间等。
该包的未来版本将提供包括对上下文和超时的支持。
### 实践
1. 获取第三方库：
```
go get github.com/go-sql-driver/mysql
```
2. 建立config.go：
```
package database
import (
"database/sql"
"fmt"
"os"
"time"
_ "github.com/go-sql-driver/mysql" //注意这里的导入方式
)
// Example 保存了查询的结果
type Example struct {
Name string
Created *time.Time
}
// Setup 配置数据库连接
func Setup() (*sql.DB, error) {
db, err := sql.Open("mysql",
fmt.Sprintf("%s:%s@/gocookbook?parseTime=true", os.Getenv("MYSQLUSERNAME"), os.Getenv("MYSQLPASSWORD")))
if err != nil {
return nil, err
}
return db, nil
}
```
3. 建立create.go：
```
package database
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
// Create 建立一个表并填充数据
func Create(db *sql.DB) error {
if _, err := db.Exec("CREATE TABLE example (name VARCHAR(20), created DATETIME)"); err != nil {
return err
}
if _, err := db.Exec(`INSERT INTO example (name, created) values ("Aaron", NOW())`); err != nil {
return err
}
return nil
}
```
4. 建立query.go：
```
package database
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
)
// Query 获取一个新的连接到数据库 并进行查询
func Query(db *sql.DB) error {
name := "Aaron"
rows, err := db.Query("SELECT name, created FROM example where name=?", name)
if err != nil {
return err
}
defer rows.Close()
for rows.Next() {
var e Example
if err := rows.Scan(&e.Name, &e.Created); err != nil {
return err
}
fmt.Printf("Results:\n\tName: %s\n\tCreated: %v\n", e.Name, e.Created)
}
return rows.Err()
}
```
5. 建立 exec.go：
```
package database
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
// Exec 删除该表
func Exec(db *sql.DB) error {
// 在删除该表时存在未处理的错误 这样写并不推荐
defer db.Exec("DROP TABLE example")
if err := Create(db); err != nil {
return err
}
if err := Query(db); err != nil {
return err
}
return nil
}
```
6. 建立 main.go：
```
package main
import (
"github.com/agtorre/go-cookbook/chapter5/database"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := database.Setup()
if err != nil {
panic(err)
}
if err := database.Exec(db); err != nil {
panic(err)
}
}
```
7. 这会输出：
```
Results:
Name: Aaron
Created: 2017-02-16 19:02:36 +0000 UTC
```
### 说明
```
_ "github.com/go-sql-driver/mysql"
```
该行引入了数据库驱动。如果要连接到Postgres，SQLite或任何其他实现了database/sql接口的驱动，命令将类似。
一旦建立连接成功，该包会建立连接池。你可以直接在连接上执行SQL，也可以创建用commit和rollback命令执行的事务对象。在随后的章节会进一步探讨连接池的相关问题。
在与数据库通信时，mysql包为Go的时间对象提供了一些便利支持。 注意本节是从从MYSQLUSERNAME和MYSQLPASSWORD环境变量中检索数据库用户名和密码的。
* * * *
学识浅薄，错误在所难免。欢迎在群中就本书提出修改意见，以飨后来者，长风拜谢。
Golang中国（211938256）
beego实战（258969317）
Go实践（386056972）
';