Golang项目实战中如何使用database/sql包连接并操作SQLite数据库-Golang-PHP中文网

Golang项目实战中如何使用database/sql包连接并操作SQLite数据库

P粉602998670

发布： 2025-09-07 09:16:02

原创

442人浏览过

使用mattn/go-sqlite3驱动操作SQLite数据库，需先安装驱动并下划线导入以注册；通过sql.Open创建数据库连接池，建议全局复用；执行建表、增删改查等操作时使用预处理语句防止SQL注入；查询单行用QueryRow.Scan，多行用Query遍历；涉及多个操作需一致性时使用db.Begin开启事务，出错及时Rollback，成功则Commit；实际项目中应封装Repository结构体以提升可维护性；SQLite适用于小型服务、CLI工具等轻量场景。

golang项目实战中如何使用database/sql包连接并操作sqlite数据库

在Golang项目实战中，使用

database/sql

登录后复制

包操作SQLite数据库是一种常见且高效的方式。Go语言标准库中的

database/sql

登录后复制

提供了通用的数据库接口，但本身不包含具体的驱动实现。要操作SQLite，需要结合第三方驱动，比如

mattn/go-sqlite3

登录后复制

。下面详细介绍如何在实际项目中连接并操作SQLite数据库。

引入SQLite驱动

Go的

database/sql

登录后复制

是数据库抽象层，必须配合具体的驱动使用。SQLite在Go中没有官方驱动，推荐使用

github.com/mattn/go-sqlite3

登录后复制

，它支持大多数SQLite功能，并且广泛用于生产环境。

安装驱动：

go get github.com/mattn/go-sqlite3

在代码中导入：

立即学习“go语言免费学习笔记（深入）”；

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

注意：驱动前使用下划线

登录后复制

导入，是为了触发其

init()

登录后复制

函数，注册驱动到

sql.Register

登录后复制

，从而让

sql.Open

登录后复制

能够识别

sqlite3

登录后复制

类型。

连接SQLite数据库

使用

sql.Open

登录后复制

打开数据库连接。SQLite数据库以文件形式存在，传入文件路径即可。如果文件不存在，SQLite会自动创建。

示例代码：

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

// 测试连接
if err := db.Ping(); err != nil {
log.Fatal(err)
}

说明：

Tavus

Tavus是一个AI视频生成平台，可以自动将你的视频个性化给每个观众。

128

查看详情

```
sql.Open
```
登录后复制
返回的是数据库句柄，不是一次连接，而是连接池的抽象。
建议在程序启动时打开一次，全局复用，不要频繁打开关闭。
使用
```
db.Ping()
```
登录后复制
验证是否能正常连接数据库。

执行SQL操作

常见的数据库操作包括建表、插入、查询、更新和删除。下面以一个用户表为例演示。

建表：

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)
}

插入数据（使用预处理防止SQL注入）：

stmt, err := db.Prepare("INSERT INTO users(name, email) VALUES(?, ?)")
if err != nil {
    log.Fatal(err)
}
defer stmt.Close()

result, err := stmt.Exec("Alice", "alice@example.com")
if err != nil {
    log.Fatal(err)
}

lastID, err := result.LastInsertId()
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Inserted user with ID: %d\n", lastID)

查询单行数据：

var id int
var name, email string
err = db.QueryRow("SELECT id, name, email FROM users WHERE name = ?", "Alice").Scan(&id, &name, &email)
if err != nil {
    if err == sql.ErrNoRows {
        fmt.Println("No user found")
    } else {
        log.Fatal(err)
    }
} else {
    fmt.Printf("User: %d, %s, %s\n", id, 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("User: %d, %s, %s\n", id, name, email)
}
if err = rows.Err(); err != nil {
    log.Fatal(err)
}

事务处理

对于需要保证一致性的多个操作，应使用事务。

tx, err := db.Begin()
if err != nil {
    log.Fatal(err)
}

stmt1, err := tx.Prepare("INSERT INTO users(name, email) VALUES(?, ?)")
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}
defer stmt1.Close()

_, err = stmt1.Exec("Bob", "bob@example.com")
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}

_, err = stmt1.Exec("Charlie", "charlie@example.com")
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}

err = tx.Commit()
if err != nil {
    log.Fatal(err)
}

事务中任何一步出错都应调用