在 go 中集成 sqlite 数据库既简单又直接,只需安装 database/sql 标准库包即可。步骤包括:建立连接、创建表、插入数据、查询数据、更新数据和删除数据。本文还提供了使用实战案例,展示了如何创建数据库、模型和操作数据,如插入、查找、更新和删除。

在 Go 中集成 SQLite 数据库
简介
SQLite 是一款轻量级且高效的关系型数据库引擎,广泛用于移动和嵌入式应用程序中。在 Golang 中集成 SQLite 数据库既简单又直接。本文将引导您完成这一过程,并提供一个实战案例。
安装
要使用 SQLite,您需要安装 database/sql 标准库包:
go get github.com/go-sql-driver/mysql
登录后复制
连接数据库
建立与 SQLite 数据库的连接非常简单:
import (
"database/sql"
_ "github.com/mattn/go-sqlite3"
)
func main() {
db, err := sql.Open("sqlite3", "./mydb.db")
if err != nil {
// 处理错误
}
}
登录后复制
创建表
使用 db.Exec() 方法创建表:
_, err := db.Exec("CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)")
if err != nil {
// 处理错误
}
登录后复制
插入数据
使用 db.Prepare() 和 Stmt.Exec() 方法插入数据:
stmt, err := db.Prepare("INSERT INTO users (name, age) VALUES (?, ?)")
if err != nil {
// 处理错误
}
_, err = stmt.Exec("John", 30)
if err != nil {
// 处理错误
}
登录后复制
查询数据
使用 db.Query() 方法查询数据:
rows, err := db.Query("SELECT * FROM users")
if err != nil {
// 处理错误
}
for rows.Next() {
var id int
var name string
var age int
if err := rows.Scan(&id, &name, &age); err != nil {
// 处理错误
}
fmt.Println(id, name, age)
}
登录后复制
更新数据
使用 db.Exec() 方法更新数据:
_, err := db.Exec("UPDATE users SET name = 'Jane' WHERE id = 1")
if err != nil {
// 处理错误
}
登录后复制
删除数据
使用 db.Exec() 方法删除数据:
_, err := db.Exec("DELETE FROM users WHERE id = 1")
if err != nil {
// 处理错误
}
登录后复制
实战案例
假设我们有一个名为 user 的数据结构:
type User struct {
ID int
Name string
Age int
}
登录后复制
创建数据库和模型
我们将创建 users.db 数据库、User 表和 UserModel 模型。
func main() {
db, err := sql.Open("sqlite3", "./users.db")
if err != nil {
// 处理错误
}
defer db.Close()
sql := `
CREATE TABLE IF NOT EXISTS users (
id INTEGER PRIMARY KEY,
name TEXT,
age INTEGER
);
`
if _, err := db.Exec(sql); err != nil {
// 处理错误
}
}
type UserModel struct {
DB *sql.DB
}
func NewUserModel(db *sql.DB) *UserModel {
return &UserModel{DB: db}
}
登录后复制
插入数据
func (u *UserModel) Create(user *User) error {
stmt, err := u.DB.Prepare("INSERT INTO users (name, age) VALUES (?, ?)")
if err != nil {
return err
}
defer stmt.Close()
_, err = stmt.Exec(user.Name, user.Age)
return err
}
登录后复制
查询数据
func (u *UserModel) FindByID(id int) (*User, error) {
stmt, err := u.DB.Prepare("SELECT * FROM users WHERE id = ?")
if err != nil {
return nil, err
}
defer stmt.Close()
row := stmt.QueryRow(id)
user := &User{}
if err := row.Scan(&user.ID, &user.Name, &user.Age); err != nil {
if err == sql.ErrNoRows {
return nil, nil
}
return nil, err
}
return user, nil
}
登录后复制
更新数据
func (u *UserModel) Update(user *User) error {
stmt, err := u.DB.Prepare("UPDATE users SET name = ?, age = ? WHERE id = ?")
if err != nil {
return err
}
defer stmt.Close()
_, err = stmt.Exec(user.Name, user.Age, user.ID)
return err
}
登录后复制
删除数据
func (u *UserModel) Delete(id int) error {
stmt, err := u.DB.Prepare("DELETE FROM users WHERE id = ?")
if err != nil {
return err
}
defer stmt.Close()
_, err = stmt.Exec(id)
return err
}
登录后复制
以上就是Golang框架如何集成SQLite数据库?的详细内容,更多请关注叮当号网其它相关文章!
文章来自互联网,只做分享使用。发布者:pansz,转转请注明出处:https://www.dingdanghao.com/article/707385.html
