Golang框架如何集成SQLite数据库?

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

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

Golang框架如何集成SQLite数据库?

在 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

(0)
上一篇 2024-08-11 08:32
下一篇 2024-08-11 08:32

相关推荐

联系我们

在线咨询: QQ交谈

邮件:442814395@qq.com

工作时间:周一至周五,9:30-18:30,节假日休息

关注微信公众号