简介
此示例将研究GO语言中MySQL数据库访问的基础知识，创建数据库表，存储和读取数据。
安装go-sql-driver / mysql软件包
Go编程语言附带了一个名为database / sql的软件包，用于查询各种SQL数据库。 这很有用，因为它将所有通用SQL功能抽象为一个API供你使用，但 Go不包括数据库驱动程序。 在Go中，数据库驱动程序是一个用于实现特定数据库底层细节的软件包（本例为MySQL）。由于无法预见哪些数据库将来都会投入使用，而支持每个可能的数据库将需要大量维护工作，因此Go语言未包含数据库驱动程序，需要额外进行安装。
要安装MySQL数据库驱动程序，只需要在终端中执行以下操作：
go get -u github.com/go-sql-driver/mysql
连接到MySQL数据库
安装所有必需的软件包后，需要检查的第一件事是，是否可以成功连接到MySQL数据库。 如果尚未运行MySQL数据库服务器，可以通过Docker轻松的启动一个实例。 这是MySQL的映像的官方Docker镜像：https://hub.docker.com/_/mysql
要检查是否可以连接到数据库，请导入数据库/ sql和go-sql-driver / mysql软件包，并按如下所示打开连接：
import "database/sql"
import _ "go-sql-driver/mysql"
// Configure the database connection (always check errors)
db, err := sql.Open("mysql", "username:password@(127.0.0.1:3306)/dbname?parseTime=true")
// Initialize the first connection to the database, to see if everything works correctly.
// Make sure to check the error.
err := db.Ping()
创建第一个数据库表
我们数据库中的每个数据条目都存储在一个特定的表中。 数据库表由列和行组成。 这些列为每个数据条目提供一个标签并指定其类型。 这些行是插入的数据值。 在我们的第一个示例中，我们想要创建一个像这样的表：
| id | username | password | created_at |
|---|---|---|---|
| 1 | johndoe | secret | 2019-08-10 12:30:00 |
创建表格的SQL命令如下：
CREATE TABLE users (
id INT AUTO_INCREMENT,
username TEXT NOT NULL,
password TEXT NOT NULL,
created_at DATETIME,
PRIMARY KEY (id)
);
现在有了SQL命令，可以使用database/sql包在MySQL数据库中创建表：
query := `
CREATE TABLE users (
id INT AUTO_INCREMENT,
username TEXT NOT NULL,
password TEXT NOT NULL,
created_at DATETIME,
PRIMARY KEY (id)
);`
// Executes the SQL query in our database. Check err to ensure there was no error.
_, err := db.Exec(query)
插入第一个用户
如果你熟悉SQL，向表中插入新数据就像创建表一样容易。 需要注意的一件事是：默认情况下，Go使用准备好的语句将动态数据插入SQL查询语句中，这是一种将用户提供的数据安全地传递到数据库的方式，而不会造成任何损坏。 在Web编程的早期，程序员将带有查询的数据直接传递到数据库，这导致了巨大的漏洞，并可能破坏整个Web应用程序，请不要那样做。
要将第一个用户插入数据库表，创建一个如下的SQL查询。此处省略了id列，因为它是由MySQL自动设置的。 问号告诉SQL驱动程序，它们是实际数据的占位符。 在这里可以看到准备好的语句。
INSERT INTO users (username, password, created_at) VALUES (?, ?, ?)
现在可以在Go中使用此语句插入用户。
import "time"
username := "johndoe"
password := "secret"
createdAt := time.Now()
// Inserts our data into the users table and returns with the result and a possible error.
// The result contains information about the last inserted id (which was auto-generated for us) and the count of rows this query affected.
result, err := db.Exec(`INSERT INTO users (username, password, created_at) VALUES (?, ?, ?)`, username, password, createdAt)
要获取用户在数据库中最新创建的ID，只需按以下方式获取：
userID, err := result.LastInsertId()
查询用户表
现在表中有一个用户，我们想查询它并获取其所有信息。 在Go中有两种查询表的方法。 db.Query可以迭代查询多行；还有db.QueryRow只查询特定的行。
查询特定行的工作原理基本上与之前介绍的所有其他SQL命令一样。
SQL命令通过其ID查询单个用户，如下所示：
SELECT id, username, password, created_at FROM users WHERE id = ?
在Go中首先声明一些变量来存储数据，然后查询单个数据库行，如下所示：
var (
id int
username string
password string
createdAt time.Time
)
// Query the database and scan the values into out variables. Don't forget to check for errors.
query := `SELECT id, username, password, created_at FROM users WHERE id = ?`
err := db.QueryRow(query, 1).Scan(&id, &username, &password, &createdAt)
查询所有用户
前面的部分介绍了如何查询单个用户行。 而许多应用程序都有查询所有用户的应用。 这与上面的示例相似，只是涉及更多的编码。
我们可以使用上面示例中的SQL命令并修改WHERE子句。 这样可以查询所有用户。
SELECT id, username, password, created_at FROM users
在Go中首先声明一些变量来存储数据，然后查询单个数据库行，如下所示：
type user struct {
id int
username string
password string
createdAt time.Time
}
rows, err := db.Query(`SELECT id, username, password, created_at FROM users`) // check err
defer rows.Close()
var users []user
for rows.Next() {
var u user
err := rows.Scan(&u.id, &u.username, &u.password, &u.createdAt) // check err
users = append(users, u)
}
err := rows.Err() // check err
user切片现在包含的内容如下：
users {
user {
id: 1,
username: "johndoe",
password: "secret",
createdAt: time.Time{wall: 0x0, ext: 63701044325, loc: (*time.Location)(nil)},
},
user {
id: 2,
username: "alice",
password: "bob",
createdAt: time.Time{wall: 0x0, ext: 63701044622, loc: (*time.Location)(nil)},
},
}
删除用户
最后，从表中删除用户与上述各节中的.Exec一样简单：
_, err := db.Exec(`DELETE FROM users WHERE id = ?`, 1) // check err
代码
package main
import (
"database/sql"
"fmt"
"log"
"time"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := sql.Open("mysql", "root:root@(127.0.0.1:3306)/root?parseTime=true")
if err != nil {
log.Fatal(err)
}
if err := db.Ping(); err != nil {
log.Fatal(err)
}
{ // Create a new table
query := `
CREATE TABLE users (
id INT AUTO_INCREMENT,
username TEXT NOT NULL,
password TEXT NOT NULL,
created_at DATETIME,
PRIMARY KEY (id)
);`
if _, err := db.Exec(query); err != nil {
log.Fatal(err)
}
}
{ // Insert a new user
username := "johndoe"
password := "secret"
createdAt := time.Now()
result, err := db.Exec(`INSERT INTO users (username, password, created_at) VALUES (?, ?, ?)`, username, password, createdAt)
if err != nil {
log.Fatal(err)
}
id, err := result.LastInsertId()
fmt.Println(id)
}
{ // Query a single user
var (
id int
username string
password string
createdAt time.Time
)
query := "SELECT id, username, password, created_at FROM users WHERE id = ?"
if err := db.QueryRow(query, 1).Scan(&id, &username, &password, &createdAt); err != nil {
log.Fatal(err)
}
fmt.Println(id, username, password, createdAt)
}
{ // Query all users
type user struct {
id int
username string
password string
createdAt time.Time
}
rows, err := db.Query(`SELECT id, username, password, created_at FROM users`)
if err != nil {
log.Fatal(err)
}
defer rows.Close()
var users []user
for rows.Next() {
var u user
err := rows.Scan(&u.id, &u.username, &u.password, &u.createdAt)
if err != nil {
log.Fatal(err)
}
users = append(users, u)
}
if err := rows.Err(); err != nil {
log.Fatal(err)
}
fmt.Printf("%#v", users)
}
{
_, err := db.Exec(`DELETE FROM users WHERE id = ?`, 1)
if err != nil {
log.Fatal(err)
}
}
}
网友评论