如何使用Golang实现数据库操作_连接MySQL并执行基本CRUD_技术教程

使用 Golang 连接 MySQL 并执行 CRUD（创建、读取、更新、删除）操作，核心是 database/sql 包配合 MySQL 驱动（如 go-sql-driver/mysql）。它不提供 ORM 功能，但足够轻量、可控且性能好。

安装依赖与建立连接

先通过 go mod 初始化项目并引入 MySQL 驱动：

go mod init example.com/dbdemo
go get -u github.com/go-sql-driver/mysql

然后用 sql.Open 创建数据库句柄（注意：此时并未真正连接），再调用 db.Ping() 验证连接是否可用：

import (
  "database/sql"
  "fmt"
  "log"
  "time"

  _ "github.com/go-sql-driver/mysql"
)

func main() {
  dsn := "user:password@tcp(127.0.0.1:3306)/testdb?parseTime=true&loc=Local"
  db, err := sql.Open("mysql", dsn)
  if err != nil {
    log.Fatal(err)
  }
  defer db.Close()

  if err = db.Ping(); err != nil {
    log.Fatal("无法

连接到 MySQL:", err)
}
fmt.Println("MySQL 连接成功")
}

定义结构体与建表语句

为方便操作，建议定义 Go 结构体对应数据库表。例如用户表：

CREATE TABLE users (
  id INT AUTO_INCREMENT PRIMARY KEY,
  name VARCHAR(50) NOT NULL,
  email VARCHAR(100) UNIQUE,
  created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

对应结构体可写为：

type User struct {
  ID int `db:"id"`
  Name string `db:"name"`
  Email string `db:"email"`
  CreatedAt time.Time `db:"created_at"`
}

注意：db 标签不是必须的，仅在配合第三方库（如 sqlx）做字段映射时有用；原生 database/sql 依赖查询列顺序或显式列名。

执行 CRUD 操作

所有操作都基于 *sql.DB 或 *sql.Tx（事务）进行，推荐使用 Prepare 预处理语句防 SQL 注入：

Create（插入）：用 Exec 执行 INSERT，获取自增 ID

stmt, _ := db.Prepare("INSERT INTO users(name, email) VALUES(?, ?)")
defer stmt.Close()
result, _ := stmt.Exec("张三", "zhangsan@example.com")
id, _ := result.LastInsertId()
fmt.Printf("插入成功，ID=%d\n", id)

Read（查询单条/多条）：用 QueryRow 查一行，Query 查多行

// 查询单条
var user User
err := db.QueryRow("SELECT id,name,email,created_at FROM users WHERE id = ?", 1).Scan(&user.ID, &user.Name, &user.Email, &user.CreatedAt)
if err != nil {
  if err == sql.ErrNoRows {
    fmt.Println("未找到用户")
  } else {
    log.Fatal(err)
  }
}

// 查询多条
rows, _ := db.Query("SELECT id,name,email,created_at FROM users WHERE email LIKE ?", "%@example.com")
defer rows.Close()
for rows.Next() {
  var u User
  rows.Scan(&u.ID, &u.Name, &u.Email, &u.CreatedAt)
  fmt.Printf("%+v\n", u)
}