当前位置：首页 > 文章列表 > Golang > Go教程 > Golang操作SQLite数据库教程详解

Golang操作SQLite数据库教程详解

2025-12-08 14:38:44 0浏览收藏

推广推荐

支持 PC / 移动端，安全直达

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《Golang连接操作SQLite数据库教程》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

使用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

在代码中导入：

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

说明：

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

事务中任何一步出错都应调用tx.Rollback()回滚，成功则调用tx.Commit()提交。

基本上就这些。在实际项目中，建议将数据库操作封装成Repository结构体，便于测试和维护。SQLite轻量、无需部署，非常适合小型服务、CLI工具或本地缓存场景。合理使用database/sql的接口和驱动，可以写出简洁可靠的数据库代码。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。

golang SQLite