如何用Go語言操作MySQL示例詳解
一、MySQL數(shù)據(jù)庫連接
Go語言操作MySQL是開發(fā)中常見的任務(wù),通過Go語言的標(biāo)準(zhǔn)庫database/sql和第三方MySQL驅(qū)動(如go-sql-driver/mysql),可以方便地實現(xiàn)數(shù)據(jù)庫的連接、查詢、插入、更新和刪除等操作。
1.1 下載依賴
在Go語言中操作MySQL,首先需要安裝MySQL驅(qū)動。常用的驅(qū)動是go-sql-driver/mysql,可以通過以下命令安裝:
go get -u github.com/go-sql-driver/mysql
1.2 初始化連接
使用database/sql包和MySQL驅(qū)動初始化數(shù)據(jù)庫連接。以下是一個簡單的連接示例:
package main
import (
"database/sql"
"fmt"
"log"
_ "github.com/go-sql-driver/mysql"
)
func main() {
// 數(shù)據(jù)庫連接字符串
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 連接池配置
為了提高性能,可以配置數(shù)據(jù)庫連接池:
db.SetMaxOpenConns(10) // 設(shè)置最大打開的連接數(shù) db.SetMaxIdleConns(5) // 設(shè)置最大空閑連接數(shù)
二、MySQL的CRUD操作
2.1 建庫建表
在操作數(shù)據(jù)之前,首先需要創(chuàng)建數(shù)據(jù)庫和表。以下是建表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 插入數(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)
}
三、完整代碼案例
以下是一個完整的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!")
// 插入數(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語言通過database/sql包和MySQL驅(qū)動,提供了強大的數(shù)據(jù)庫操作能力。本文詳細(xì)介紹了MySQL的連接、插入、查詢、更新和刪除操作,并提供了完整的代碼示例。
到此這篇關(guān)于如何用Go語言操作MySQL的文章就介紹到這了,更多相關(guān)Go語言操作MySQL內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
解決golang時間字符串轉(zhuǎn)time.Time的坑
這篇文章主要介紹了解決golang時間字符串轉(zhuǎn)time.Time的坑,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
Go語言pointer及switch?fallthrough實戰(zhàn)詳解
這篇文章主要為大家介紹了Go語言pointer及switch?fallthrough實戰(zhàn)詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-06-06
go語言reflect.Type?和?reflect.Value?應(yīng)用示例詳解
這篇文章主要為大家介紹了go語言reflect.Type?和?reflect.Value?應(yīng)用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-09-09

