当前位置：首页 > news >正文

Go语言中的MySQL操作：database/sql实战

news 2026/4/13 11:02:10

Go语言中的MySQL操作：database/sql实战

1. database/sql包简介

Go语言的database/sql包提供了通用的SQL数据库接口，配合MySQL驱动可以实现对MySQL数据库的操作。本文将详细介绍如何使用database/sql包进行MySQL数据库操作。

2. 连接数据库

2.1 安装驱动

go get -u github.com/go-sql-driver/mysql

2.2 建立连接

package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" ) func main() { // 连接字符串 dsn := "user: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(err) } defer db.Close() // 测试连接 err = db.Ping() if err != nil { log.Fatal(err) } fmt.Println("Successfully connected to database") }

3. 基本CRUD操作

3.1 创建表

func createTable(db *sql.DB) error { query := `CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100) NOT NULL, email VARCHAR(100) UNIQUE NOT NULL, age INT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP )` _, err := db.Exec(query) return err }

3.2 插入数据

func insertUser(db *sql.DB, name, email string, age int) (int64, error) { result, err := db.Exec( "INSERT INTO users (name, email, age) VALUES (?, ?, ?)", name, email, age, ) if err != nil { return 0, err } return result.LastInsertId() }

3.3 查询数据

func getUser(db *sql.DB, id int) (*User, error) { var user User err := db.QueryRow( "SELECT id, name, email, age, created_at FROM users WHERE id = ?", id, ).Scan(&user.ID, &user.Name, &user.Email, &user.Age, &user.CreatedAt) if err == sql.ErrNoRows { return nil, nil } if err != nil { return nil, err } return &user, nil }

3.4 更新数据

func updateUser(db *sql.DB, id int, name string) error { _, err := db.Exec( "UPDATE users SET name = ? WHERE id = ?", name, id, ) return err }

3.5 删除数据

func deleteUser(db *sql.DB, id int) error { _, err := db.Exec("DELETE FROM users WHERE id = ?", id) return err }

4. 事务处理

func transferMoney(db *sql.DB, fromID, toID int, amount float64) error { tx, err := db.Begin() if err != nil { return err } defer tx.Rollback() // 扣款 _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromID) if err != nil { return err } // 收款 _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, toID) if err != nil { return err } return tx.Commit() }

5. 连接池配置

func setupDB(dsn string) (*sql.DB, error) { db, err := sql.Open("mysql", dsn) if err != nil { return nil, err } // 设置连接池参数 db.SetMaxOpenConns(25) // 最大打开连接数 db.SetMaxIdleConns(10) // 最大空闲连接数 db.SetConnMaxLifetime(5 * time.Minute) // 连接最大生命周期 return db, nil }