Golang如何操作SQLite数据库_Golang SQLite数据库CRUD示例

Go语言通过database/sql和mattn/go-sqlite3驱动操作SQLite，实现增删改查：先用sql.Open连接数据库并Ping验证，接着Exec创建表，使用预处理语句插入数据并获取ID，QueryRow查询单行、Query多行遍历结果，Exec配合RowsAffected更新或删除记录，最后完整示例展示流程，适用于轻量级项目开发。

Go语言操作SQLite数据库非常简单，主要通过database/sql包结合第三方驱动（如modernc.org/sqlite或mattn/go-sqlite3）来实现。本文使用广泛使用的mattn/go-sqlite3驱动，演示如何在Golang中完成SQLite的增删改查（CRUD）操作。

安装依赖

使用以下命令安装SQLite驱动：

go get github.com/mattn/go-sqlite3

连接SQLite数据库

打开或创建SQLite数据库文件只需调用sql.Open并指定驱动名和数据库路径：

db, err := sql.Open("sqlite3", "./example.db")
if err != nil {
  log.Fatal(err)
}
defer db.Close()

如果文件不存在，SQLite会自动创建它。注意：即使数据库文件未创建，sql.Open也不会立即报错，建议执行一条简单查询验证连接：

if err = db.Ping(); err != nil {
  log.Fatal(err)
}

创建数据表

使用db.Exec执行DDL语句创建表：

createTableSQL := `CREATE TABLE IF NOT EXISTS users (
  id INTEGER PRIMARY KEY AUTOINCREMENT,
  name TEXT NOT NULL,
  email TEXT UNIQUE NOT NULL
);`
_, err = db.Exec(createTableSQL)
if err != nil {
  log.Fatal(err)
}

插入数据（Create）

使用预处理语句防止SQL注入，Exec返回结果对象可获取自增ID：

insertSQL := "INSERT INTO users(name, email) VALUES(?, ?)"
result, err := db.Exec(insertSQL, "Alice", "alice@example.com")
if err != nil {
  log.Fatal(err)
}
id, err := result.LastInsertId()
if err != nil {
  log.Fatal(err)
}
fmt.Printf("插入成功，ID: %d\n", id)

查询数据（Read）

使用Query或QueryRow读取数据：

// 查询单行
var name, email string
err = db.QueryRow("SELECT name, email FROM users WHERE id = ?", 1).Scan(&name, &email)
if err != nil {
  if err == sql.ErrNoRows {
    fmt.Println("用户不存在")
  } else {
    log.Fatal(err)
  }
}
fmt.Printf("用户: %s, 邮箱: %s\n", name, email)

// 查询多行
rows, err := db.Query("SELECT id, name, email FROM users")
if err != nil {
  log.Fatal(err)
}
defer rows.Close()

for rows.Next() {
  var id int
  var name, email string
  err := rows.Scan(&id, &name, &email)
  if err != nil {
    log.Fatal(err)
  }
  fmt.Printf("ID: %d, 名字: %s, 邮箱: %s\n", id, name, email)
}

更新数据（Update）

使用Exec执行UPDATE语句，检查影响行数判断是否成功：

updateSQL := "UPDATE users SET email = ? WHERE name = ?"
result, err := db.Exec(updateSQL, "new_email@example.com", "Alice")
if err != nil {
  log.Fatal(err)
}
count, err := result.RowsAffected()
if err != nil {
  log.Fatal(err)
}
fmt.Printf("更新了 %d 条记录\n", count)

删除数据（Delete）

DELETE操作与UPDATE类似：

deleteSQL := "DELETE FROM users WHERE id = ?"
result, err := db.Exec(deleteSQL, 1)
if err != nil {
  log.Fatal(err)
}
count, err := result.RowsAffected()
if err != nil {
  log.Fatal(err)
}
fmt.Printf("删除了 %d 条记录\n", count)

完整示例代码结构

将上述逻辑整合成一个可运行程序：

package main

import (
  "database/sql"
  "fmt"
  "log"
  "_ github.com/mattn/go-sqlite3"
)

func main() {
  db, err := sql.Open("sqlite3", "./example.db")
  if err != nil {
    log.Fatal(err)
  }
  defer db.Close()

  if err = db.Ping(); err != nil {
    log.Fatal(err)
  }

  // 创建表、插入、查询、更新、删除...
  // 此处省略中间代码
}

基本上就这些。整个流程清晰明了，适合快速构建本地应用或原型系统。注意错误处理不可忽略，尤其是Scan和Exec后的返回值检查。SQLite轻量且无需服务端，非常适合嵌入式或小型项目使用。