【Go】如何使用 Go 连接 MySQL 数据库

2024-07-15 08:24:04
开发
23

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

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

原文地址:https://blog.csdn.net/qq_35240081/article/details/140425331 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：https://www.suanlizi.com/kf/1812644262014226432.html 如若内容造成侵权/违法违规/事实不符，请联系《酸梨子》网邮箱：1419361763@qq.com进行投诉反馈，一经查实，立即删除！

阅读全部