我白天是个 搞笑废物
表演不在乎
夜晚变成 忧伤怪物
撕扯着孤独
我曾经是个 感性动物
小心地感触
现在变成 无关人物
                     🎵 张碧晨/王赫野《何物》

在现代应用程序开发中，连接和操作数据库是一个基本需求。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 语言进行数据库操作。如果你有任何问题或建议，欢迎在评论区留言。