使用mattn/go-sqlite3驱动操作SQLite数据库，需先安装驱动并下划线导入以注册；通过sql.Open创建数据库连接池，建议全局复用；执行建表、增删改查等操作时使用预处理语句防止SQL注入；查询单行用QueryRow.Scan，多行用Query遍历；涉及多个操作需一致性时使用db.Begin开启事务，出错及时Rollback，成功则Commit；实际项目中应封装Repository结构体以提升可维护性；SQLite适用于小型服务、CLI工具等轻量场景。
在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)
}
说明：
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: %dn”, 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, %sn”, 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, %sn”, 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项目实战中如何使用database/sql包连接并操作SQLite数据库的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1403769.html
微信扫一扫 
支付宝扫一扫 
