阅读量:5
我白天是个 搞笑废物
表演不在乎
夜晚变成 忧伤怪物
撕扯着孤独
我曾经是个 感性动物
小心地感触
现在变成 无关人物
🎵 张碧晨/王赫野《何物》
在现代应用程序开发中，连接和操作数据库是一个基本需求。Go 语言（Golang）以其高效、简单和易用性而受到开发者的广泛欢迎。本文将介绍如何使用 Go 语言连接 MySQL 数据库，并执行基本的数据库操作。
环境准备
在开始之前，请确保你已经安装了 Go 和 MySQL。如果还没有安装，可以参考以下链接进行安装：
- 安装 Go
- 安装 MySQL
此外，你还需要安装 MySQL 的 Go 驱动程序 go-sql-driver/mysql。可以通过以下命令进行安装：
go get -u github.com/go-sql-driver/mysql 创建一个简单的 Go 项目
首先，创建一个新的 Go 项目目录：
mkdir go-mysql-example cd go-mysql-example 然后，初始化一个新的 Go 模块：
go mod init go-mysql-example 编写代码连接 MySQL
创建一个 main.go 文件，并编写以下代码来连接 MySQL 数据库：
package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" ) func main() { // 数据库连接配置 dsn := "username:password@tcp(127.0.0.1:3306)/dbname" // 打开数据库连接 db, err := sql.Open("mysql", dsn) if err != nil { log.Fatalf("Error opening database: %v", err) } defer db.Close() // 验证数据库连接 err = db.Ping() if err != nil { log.Fatalf("Error connecting to the database: %v", err) } fmt.Println("Successfully connected to the database!") } 在上述代码中：
import 部分导入了必要的包，其中 _ “github.com/go-sql-driver/mysql” 是导入 MySQL 驱动。
dsn 是数据源名称，包含了用户名、密码、主机、端口和数据库名。请根据你的实际数据库配置进行修改。
sql.Open(“mysql”, dsn) 打开数据库连接。
db.Ping() 验证数据库连接。
将 username、password 和 dbname 替换为你的实际数据库用户名、密码和数据库名称。
执行基本的数据库操作
下面我们将扩展 main.go 文件，添加一些基本的数据库操作，包括创建表、插入数据、查询数据和更新数据。
创建表
_, err = db.Exec(` CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT, username VARCHAR(255) NOT NULL, email VARCHAR(255) NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (id) )`) if err != nil { log.Fatalf("Error creating table: %v", err) } fmt.Println("Table 'users' created successfully!") 插入数据
insertQuery := `INSERT INTO users (username, email) VALUES (?, ?)` res, err := db.Exec(insertQuery, "john_doe", "john@example.com") if err != nil { log.Fatalf("Error inserting data: %v", err) } id, err := res.LastInsertId() if err != nil { log.Fatalf("Error getting the last insert ID: %v", err) } fmt.Printf("Data inserted successfully with ID: %d\n", id) 查询数据
var ( userID int username string email string createdAt string ) query := `SELECT id, username, email, created_at FROM users WHERE username = ?` err = db.QueryRow(query, "john_doe").Scan(&userID, &username, &email, &createdAt) if err != nil { log.Fatalf("Error querying data: %v", err) } fmt.Printf("User: ID=%d, Username=%s, Email=%s, CreatedAt=%s\n", userID, username, email, createdAt) 更新数据
updateQuery := `UPDATE users SET email = ? WHERE username = ?` _, err = db.Exec(updateQuery, "john.doe@example.com", "john_doe") if err != nil { log.Fatalf("Error updating data: %v", err) } fmt.Println("Data updated successfully!") 完整示例代码
将上述代码整合到一个文件中：
package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" ) func main() { // 数据库连接配置 dsn := "username:password@tcp(127.0.0.1:3306)/dbname" // 打开数据库连接 db, err := sql.Open("mysql", dsn) if err != nil { log.Fatalf("Error opening database: %v", err) } defer db.Close() // 验证数据库连接 err = db.Ping() if err != nil { log.Fatalf("Error connecting to the database: %v", err) } fmt.Println("Successfully connected to the database!") // 创建表 _, err = db.Exec(` CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT, username VARCHAR(255) NOT NULL, email VARCHAR(255) NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (id) )`) if err != nil { log.Fatalf("Error creating table: %v", err) } fmt.Println("Table 'users' created successfully!") // 插入数据 insertQuery := `INSERT INTO users (username, email) VALUES (?, ?)` res, err := db.Exec(insertQuery, "john_doe", "john@example.com") if err != nil { log.Fatalf("Error inserting data: %v", err) } id, err := res.LastInsertId() if err != nil { log.Fatalf("Error getting the last insert ID: %v", err) } fmt.Printf("Data inserted successfully with ID: %d\n", id) // 查询数据 var ( userID int username string email string createdAt string ) query := `SELECT id, username, email, created_at FROM users WHERE username = ?` err = db.QueryRow(query, "john_doe").Scan(&userID, &username, &email, &createdAt) if err != nil { log.Fatalf("Error querying data: %v", err) } fmt.Printf("User: ID=%d, Username=%s, Email=%s, CreatedAt=%s\n", userID, username, email, createdAt) // 更新数据 updateQuery := `UPDATE users SET email = ? WHERE username = ?` _, err = db.Exec(updateQuery, "john.doe@example.com", "john_doe") if err != nil { log.Fatalf("Error updating data: %v", err) } fmt.Println("Data updated successfully!") } 运行程序
确保你的 MySQL 数据库正在运行，并且使用正确的用户名、密码和数据库名称。然后运行程序：
go run main.go 如果一切正常，你将看到以下输出：
Successfully connected to the database! Table 'users' created successfully! Data inserted successfully with ID: 1 User: ID=1, Username=john_doe, Email=john@example.com, CreatedAt=2021-01-01 00:00:00 Data updated successfully! 总结
本文介绍了如何使用 Go 语言连接 MySQL 数据库，并执行基本的数据库操作。通过上述示例代码，你可以轻松地创建、插入、查询和更新数据库中的数据。希望这篇文章能帮助你更好地理解和使用 Go 语言进行数据库操作。如果你有任何问题或建议，欢迎在评论区留言。
