Go语言集成SQLite3数据库：使用go-sqlite3驱动的实践指南

go get github.com/mattn/go-sqlite3

sqlite3.go: In function ‘_cgo_..._Cfunc_sqlite3_prepare_v2’:
sqlite3.go:198:2: warning: passing argument 5 of ‘sqlite3_prepare_v2’ from incompatible pointer type [enabled by default]
/usr/local/include/sqlite3.h:2924:16: note: expected ‘const char **’ but argument is of type ‘char **’

package main

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

    _ "github.com/mattn/go-sqlite3" // 导入SQLite3驱动，下划线表示只导入包进行初始化，不直接使用其导出成员
)

func main() {
    // 1. 打开或创建SQLite3数据库文件
    // 如果文件不存在，会自动创建。参数 "file:test.db?cache=shared&mode=rwc" 可以配置更多选项
    db, err := sql.Open("sqlite3", "./test.db")
    if err != nil {
        log.Fatal(err)
    }
    defer func() {
        err := db.Close()
        if err != nil {
            log.Printf("Error closing database: %v", err)
        }
    }()

    fmt.Println("数据库连接成功！")

    // 2. 创建表
    sqlStmt := `
    CREATE TABLE IF NOT EXISTS users (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        name TEXT NOT NULL,
        age INTEGER
    );`
    _, err = db.Exec(sqlStmt)
    if err != nil {
        log.Fatalf("创建表失败: %v", err)
    }
    fmt.Println("表 'users' 创建或已存在。")

    // 3. 插入数据
    stmt, err := db.Prepare("INSERT INTO users(name, age) VALUES(?, ?)")
    if err != nil {
        log.Fatalf("准备插入语句失败: %v", err)
    }
    defer func() {
        err := stmt.Close()
        if err != nil {
            log.Printf("Error closing statement: %v", err)
        }
    }()

    _, err = stmt.Exec("Alice", 30)
    if err != nil {
        log.Fatalf("插入数据失败 (Alice): %v", err)
    }
    _, err = stmt.Exec("Bob", 25)
    if err != nil {
        log.Fatalf("插入数据失败 (Bob): %v", err)
    }
    fmt.Println("数据插入成功。")

    // 4. 查询数据
    rows, err := db.Query("SELECT id, name, age FROM users WHERE age > ?", 28)
    if err != nil {
        log.Fatalf("查询数据失败: %v", err)
    }
    defer func() {
        err := rows.Close()
        if err != nil {
            log.Printf("Error closing rows: %v", err)
        }
    }()

    fmt.Println("\n查询结果 (age > 28):")
    for rows.Next() {
        var id int
        var name string
        var age int
        err = rows.Scan(&id, &name, &age)
        if err != nil {
            log.Fatalf("扫描行数据失败: %v", err)
        }
        fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
    }
    err = rows.Err() // 检查迭代过程中是否有错误
    if err != nil {
        log.Fatalf("遍历行数据失败: %v", err)
    }

    // 5. 更新数据 (可选)
    updateStmt, err := db.Prepare("UPDATE users SET age = ? WHERE name = ?")
    if err != nil {
        log.Fatalf("准备更新语句失败: %v", err)
    }
    defer func() {
        err := updateStmt.Close()
        if err != nil {
            log.Printf("Error closing update statement: %v", err)
        }
    }()
    _, err = updateStmt.Exec(31, "Alice")
    if err != nil {
        log.Fatalf("更新数据失败 (Alice): %v", err)
    }
    fmt.Println("\n数据更新成功 (Alice的年龄更新为31)。")

    // 6. 再次查询所有数据以验证更新
    rows, err = db.Query("SELECT id, name, age FROM users")
    if err != nil {
        log.Fatalf("再次查询数据失败: %v", err)
    }
    defer func() {
        err := rows.Close()
        if err != nil {
            log.Printf("Error closing rows: %v", err)
        }
    }()

    fmt.Println("\n所有用户数据:")
    for rows.Next() {
        var id int
        var name string
        var age int
        err = rows.Scan(&id, &name, &age)
        if err != nil {
            log.Fatalf("扫描行数据失败: %v", err)
        }
        fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
    }
    err = rows.Err()
    if err != nil {
        log.Fatalf("遍历行数据失败: %v", err)
    }
}