如何用Go語(yǔ)言操作MySQL示例詳解
更新時(shí)間：2025年10月30日 11:37:13 作者：數(shù)據(jù)知道
MySQL是業(yè)界常用的關(guān)系型數(shù)據(jù)庫(kù),這篇文章主要介紹了如何用Go語(yǔ)言操作MySQL的相關(guān)資料,文中通過(guò)代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用go語(yǔ)言操作mysql具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
一、MySQL數(shù)據(jù)庫(kù)連接
Go語(yǔ)言操作MySQL是開(kāi)發(fā)中常見(jiàn)的任務(wù)，通過(guò)Go語(yǔ)言的標(biāo)準(zhǔn)庫(kù)database/sql和第三方MySQL驅(qū)動(dòng)（如go-sql-driver/mysql），可以方便地實(shí)現(xiàn)數(shù)據(jù)庫(kù)的連接、查詢、插入、更新和刪除等操作。
1.1 下載依賴
在Go語(yǔ)言中操作MySQL，首先需要安裝MySQL驅(qū)動(dòng)。常用的驅(qū)動(dòng)是go-sql-driver/mysql，可以通過(guò)以下命令安裝：
go get -u github.com/go-sql-driver/mysql
1.2 初始化連接
使用database/sql包和MySQL驅(qū)動(dòng)初始化數(shù)據(jù)庫(kù)連接。以下是一個(gè)簡(jiǎn)單的連接示例：
package main
import (
"database/sql"
"fmt"
"log"
_ "github.com/go-sql-driver/mysql"
)
func main() {
// 數(shù)據(jù)庫(kù)連接字符串
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()
// 測(cè)試連接是否成功
err = db.Ping()
if err != nil {
log.Fatal("Failed to connect to database:", err)
}
fmt.Println("Successfully connected to MySQL database!")
}
1.3 連接池配置
為了提高性能，可以配置數(shù)據(jù)庫(kù)連接池：
db.SetMaxOpenConns(10) // 設(shè)置最大打開(kāi)的連接數(shù) db.SetMaxIdleConns(5) // 設(shè)置最大空閑連接數(shù)
二、MySQL的CRUD操作
2.1 建庫(kù)建表
在操作數(shù)據(jù)之前，首先需要?jiǎng)?chuàng)建數(shù)據(jù)庫(kù)和表。以下是建表SQL語(yǔ)句示例：
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 插入數(shù)據(jù)
使用Exec方法插入數(shù)據(jù)：
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
}
調(diào)用示例：
err := insertUser(db, "Alice", 25)
if err != nil {
log.Fatal("Failed to insert user:", err)
}
2.3 查詢數(shù)據(jù)
使用Query方法查詢數(shù)據(jù)：
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
}
調(diào)用示例：
err := queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
2.4 更新數(shù)據(jù)
使用Exec方法更新數(shù)據(jù)：
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
}
調(diào)用示例：
err := updateUser(db, 1, "Bob", 30)
if err != nil {
log.Fatal("Failed to update user:", err)
}
2.5 刪除數(shù)據(jù)
使用Exec方法刪除數(shù)據(jù)：
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
}
調(diào)用示例：
err := deleteUser(db, 1)
if err != nil {
log.Fatal("Failed to delete user:", err)
}
三、完整代碼案例
以下是一個(gè)完整的Go語(yǔ)言操作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!")
// 插入數(shù)據(jù)
err = insertUser(db, "Alice", 25)
if err != nil {
log.Fatal("Failed to insert user:", err)
}
// 查詢數(shù)據(jù)
err = queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
// 更新數(shù)據(jù)
err = updateUser(db, 1, "Bob", 30)
if err != nil {
log.Fatal("Failed to update user:", err)
}
// 查詢更新后的數(shù)據(jù)
err = queryUsers(db)
if err != nil {
log.Fatal("Failed to query users:", err)
}
// 刪除數(shù)據(jù)
err = deleteUser(db, 1)
if err != nil {
log.Fatal("Failed to delete user:", err)
}
// 查詢刪除后的數(shù)據(jù)
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
}
總結(jié)：Go語(yǔ)言通過(guò)database/sql包和MySQL驅(qū)動(dòng)，提供了強(qiáng)大的數(shù)據(jù)庫(kù)操作能力。本文詳細(xì)介紹了MySQL的連接、插入、查詢、更新和刪除操作，并提供了完整的代碼示例。
到此這篇關(guān)于如何用Go語(yǔ)言操作MySQL的文章就介紹到這了,更多相關(guān)Go語(yǔ)言操作MySQL內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
HTTP接口在各個(gè)業(yè)務(wù)模塊之間扮演著重要的角色,本文主要介紹了go基于Gin框架的HTTP接口限速實(shí)踐,具有一定的參考價(jià)值,感興趣的可以了解一下2023-09-09
golang中定時(shí)器cpu使用率高的現(xiàn)象詳析
這篇文章主要給大家介紹了關(guān)于golang中定時(shí)器cpu使用率高的現(xiàn)象的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧。2018-04-04
基于Go語(yǔ)言實(shí)現(xiàn)選擇排序算法及優(yōu)化
選擇排序是一種簡(jiǎn)單的比較排序算法.這篇文章將利用Go語(yǔ)言實(shí)現(xiàn)冒泡排序算法，文中的示例代碼講解詳細(xì)，對(duì)學(xué)習(xí)Go語(yǔ)言有一定的幫助，需要的可以參考一下2022-12-12
解決golang時(shí)間字符串轉(zhuǎn)time.Time的坑
這篇文章主要介紹了解決golang時(shí)間字符串轉(zhuǎn)time.Time的坑，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-04-04
Go標(biāo)準(zhǔn)容器之Ring的使用說(shuō)明
這篇文章主要介紹了Go標(biāo)準(zhǔn)容器之Ring的使用說(shuō)明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-05-05
與其他語(yǔ)言一樣,內(nèi)置標(biāo)準(zhǔn)庫(kù)默認(rèn)支持文件壓縮功能,本文介紹Golang如何創(chuàng)建壓縮文件,增加一個(gè)或多個(gè)文件生成壓縮文件,也可以在壓縮文件中創(chuàng)建文件夾,用于對(duì)文件進(jìn)行分類管理,Golang標(biāo)準(zhǔn)庫(kù) archive/zip提供了創(chuàng)建和讀取壓縮文件功能,需要的朋友可以參考下2024-01-01
Go語(yǔ)言多人聊天室項(xiàng)目實(shí)戰(zhàn)
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言多人聊天室項(xiàng)目實(shí)戰(zhàn)，實(shí)現(xiàn)單撩或多撩等多種功能，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-08-08
Go語(yǔ)言pointer及switch?fallthrough實(shí)戰(zhàn)詳解
這篇文章主要為大家介紹了Go語(yǔ)言pointer及switch?fallthrough實(shí)戰(zhàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-06-06
Golang實(shí)現(xiàn)心跳機(jī)制的示例詳解
這篇文章主要為大家詳細(xì)介紹了Golang實(shí)現(xiàn)心跳機(jī)制的相關(guān)知識(shí),文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,有需要的小伙伴可以參考一下2024-04-04
go語(yǔ)言reflect.Type?和?reflect.Value?應(yīng)用示例詳解
這篇文章主要為大家介紹了go語(yǔ)言reflect.Type?和?reflect.Value?應(yīng)用示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-09-09