如何用Go语言操作MySQL示例详解
更新时间：2025年10月30日 11:37:13 作者：数据知道
MySQL是业界常用的关系型数据库,这篇文章主要介绍了如何用Go语言操作MySQL的相关资料,文中通过代码介绍的非常详细,对大家学习或者使用go语言操作mysql具有一定的参考借鉴价值,需要的朋友可以参考下
一、MySQL数据库连接
Go语言操作MySQL是开发中常见的任务，通过Go语言的标准库database/sql和第三方MySQL驱动（如go-sql-driver/mysql），可以方便地实现数据库的连接、查询、插入、更新和删除等操作。
1.1 下载依赖
在Go语言中操作MySQL，首先需要安装MySQL驱动。常用的驱动是go-sql-driver/mysql，可以通过以下命令安装：
go get -u github.com/go-sql-driver/mysql
1.2 初始化连接
使用database/sql包和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?charset=utf8mb4&parseTime=True&loc=Local"
db, err := sql.Open("mysql", dsn)
if err != nil {
log.Fatal("Failed to open database:", err)
}
defer db.Close()
// 测试连接是否成功
err = db.Ping()
if err != nil {
log.Fatal("Failed to connect to database:", err)
}
fmt.Println("Successfully connected to MySQL database!")
}
1.3 连接池配置
为了提高性能，可以配置数据库连接池：
db.SetMaxOpenConns(10) // 设置最大打开的连接数 db.SetMaxIdleConns(5) // 设置最大空闲连接数
二、MySQL的CRUD操作
2.1 建库建表
在操作数据之前，首先需要创建数据库和表。以下是建表SQL语句示例：
CREATE DATABASE IF NOT EXISTS testdb;
USE testdb;
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(50) NOT NULL,
age INT NOT NULL,
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
2.2 插入数据
使用Exec方法插入数据：
func insertUser(db *sql.DB, name string, age int) error {
query := "INSERT INTO users (name, age) VALUES (?, ?)"
_, err := db.Exec(query, name, age)
if err != nil {
return err
}
fmt.Println("User inserted successfully!")
return nil
}
调用示例：
err := insertUser(db, "Alice", 25)
if err != nil {
log.Fatal("Failed to insert user:", err)
}
2.3 查询数据
使用Query方法查询数据：
func queryUsers(db *sql.DB) error {
query := "SELECT id, name, age FROM users"
rows, err := db.Query(query)
if err != nil {
return err
}
defer rows.Close()
fmt.Println("Users:")
for rows.Next() {
var id int
var name string
var age int
if err := rows.Scan(&id, &name, &age); err != nil {
return err
}
fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
}
return nil
}
调用示例：
err := queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
2.4 更新数据
使用Exec方法更新数据：
func updateUser(db *sql.DB, id int, newName string, newAge int) error {
query := "UPDATE users SET name = ?, age = ? WHERE id = ?"
_, err := db.Exec(query, newName, newAge, id)
if err != nil {
return err
}
fmt.Println("User updated successfully!")
return nil
}
调用示例：
err := updateUser(db, 1, "Bob", 30)
if err != nil {
log.Fatal("Failed to update user:", err)
}
2.5 删除数据
使用Exec方法删除数据：
func deleteUser(db *sql.DB, id int) error {
query := "DELETE FROM users WHERE id = ?"
_, err := db.Exec(query, id)
if err != nil {
return err
}
fmt.Println("User deleted successfully!")
return nil
}
调用示例：
err := deleteUser(db, 1)
if err != nil {
log.Fatal("Failed to delete user:", err)
}
三、完整代码案例
以下是一个完整的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)/testdb?charset=utf8mb4&parseTime=True&loc=Local"
db, err := sql.Open("mysql", dsn)
if err != nil {
log.Fatal("Failed to open database:", err)
}
defer db.Close()
err = db.Ping()
if err != nil {
log.Fatal("Failed to connect to database:", err)
}
fmt.Println("Successfully connected to MySQL database!")
// 插入数据
err = insertUser(db, "Alice", 25)
if err != nil {
log.Fatal("Failed to insert user:", err)
}
// 查询数据
err = queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
// 更新数据
err = updateUser(db, 1, "Bob", 30)
if err != nil {
log.Fatal("Failed to update user:", err)
}
// 查询更新后的数据
err = queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
// 删除数据
err = deleteUser(db, 1)
if err != nil {
log.Fatal("Failed to delete user:", err)
}
// 查询删除后的数据
err = queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
}
func insertUser(db *sql.DB, name string, age int) error {
query := "INSERT INTO users (name, age) VALUES (?, ?)"
_, err := db.Exec(query, name, age)
if err != nil {
return err
}
fmt.Println("User inserted successfully!")
return nil
}
func queryUsers(db *sql.DB) error {
query := "SELECT id, name, age FROM users"
rows, err := db.Query(query)
if err != nil {
return err
}
defer rows.Close()
fmt.Println("Users:")
for rows.Next() {
var id int
var name string
var age int
if err := rows.Scan(&id, &name, &age); err != nil {
return err
}
fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
}
return nil
}
func updateUser(db *sql.DB, id int, newName string, newAge int) error {
query := "UPDATE users SET name = ?, age = ? WHERE id = ?"
_, err := db.Exec(query, newName, newAge, id)
if err != nil {
return err
}
fmt.Println("User updated successfully!")
return nil
}
func deleteUser(db *sql.DB, id int) error {
query := "DELETE FROM users WHERE id = ?"
_, err := db.Exec(query, id)
if err != nil {
return err
}
fmt.Println("User deleted successfully!")
return nil
}
总结：Go语言通过database/sql包和MySQL驱动，提供了强大的数据库操作能力。本文详细介绍了MySQL的连接、插入、查询、更新和删除操作，并提供了完整的代码示例。
到此这篇关于如何用Go语言操作MySQL的文章就介绍到这了,更多相关Go语言操作MySQL内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
HTTP接口在各个业务模块之间扮演着重要的角色,本文主要介绍了go基于Gin框架的HTTP接口限速实践,具有一定的参考价值,感兴趣的可以了解一下2023-09-09
这篇文章主要给大家介绍了关于golang中定时器cpu使用率高的现象的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。2018-04-04
选择排序是一种简单的比较排序算法.这篇文章将利用Go语言实现冒泡排序算法，文中的示例代码讲解详细，对学习Go语言有一定的帮助，需要的可以参考一下2022-12-12
这篇文章主要介绍了解决golang时间字符串转time.Time的坑，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-04-04
这篇文章主要介绍了Go标准容器之Ring的使用说明，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-05-05
与其他语言一样,内置标准库默认支持文件压缩功能,本文介绍Golang如何创建压缩文件,增加一个或多个文件生成压缩文件,也可以在压缩文件中创建文件夹,用于对文件进行分类管理,Golang标准库 archive/zip提供了创建和读取压缩文件功能,需要的朋友可以参考下2024-01-01
这篇文章主要为大家详细介绍了Go语言多人聊天室项目实战，实现单撩或多撩等多种功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-08-08
Go语言pointer及switch fallthrough实战详解
这篇文章主要为大家介绍了Go语言pointer及switch fallthrough实战详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-06-06
这篇文章主要为大家详细介绍了Golang实现心跳机制的相关知识,文中的示例代码讲解详细,具有一定的借鉴价值,有需要的小伙伴可以参考一下2024-04-04
go语言reflect.Type 和 reflect.Value 应用示例详解
这篇文章主要为大家介绍了go语言reflect.Type 和 reflect.Value 应用示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-09-09
最新评论