Go语言中SQLite3数据库使用详解

创作时间:

作者:

@小白创作中心

Go语言中SQLite3数据库使用详解

引用

CSDN

https://blog.csdn.net/qq_14829643/article/details/136954802

SQLite是一个广泛使用的嵌入式SQL数据库引擎，以其轻量级和自足性而闻名。Go语言，以其简洁的语法和强大的性能而受到开发者的青睐，通过database/sql包和专用的SQLite3驱动程序提供了对SQLite数据库的支持。本文旨在指导如何在Go语言中使用SQLite3，包括设置环境、连接数据库、执行SQL语句、处理查询结果等方面。

环境准备和安装

在开始之前，确保您的系统已安装Go环境。接着，您需要安装SQLite3的Go语言驱动。最流行的驱动是mattn/go-sqlite3，可以通过如下命令安装：

go get -u github.com/mattn/go-sqlite3

请注意，该驱动使用cgo，因此需要C编译器环境。

打开数据库连接

首先，导入必要的包：

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

然后，可以使用sql.Open函数打开一个SQLite数据库文件：

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

这里的your_database.db是数据库文件的路径，如果文件不存在，SQLite将会创建一个新文件。

创建表

使用Exec方法执行SQL语句创建一个新表：

createTableSQL := `CREATE TABLE IF NOT EXISTS projects (
    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,   
    "name" TEXT,
    "description" TEXT
);`

_, err = db.Exec(createTableSQL)
if err != nil {
    log.Fatal(err)
}

插入数据

插入数据到表中，可以使用预处理语句：

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

_, err = stmt.Exec("My Project", "This is a sample project")
if err != nil {
    log.Fatal(err)
}

查询数据

查询表中的数据并处理结果：

rows, err := db.Query("SELECT id, name, description FROM projects")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

for rows.Next() {
    var id int
    var name, description string
    err = rows.Scan(&id, &name, &description)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(id, name, description)
}

完整代码

package main

import (
    "database/sql"
    "fmt"
    "log"

    _ "github.com/mattn/go-sqlite3" // 导入SQLite3驱动
)

func main() {
    // 打开数据库连接
    db, err := sql.Open("sqlite3", "./test.db")
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    // 创建表
    createTableSQL := `CREATE TABLE IF NOT EXISTS projects (
        "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,   
        "name" TEXT,
        "description" TEXT
    );`
    _, err = db.Exec(createTableSQL)
    if err != nil {
        log.Fatal(err)
    }

    // 插入数据
    stmt, err := db.Prepare("INSERT INTO projects(name, description) VALUES(?, ?)")
    if err != nil {
        log.Fatal(err)
    }
    defer stmt.Close()

    _, err = stmt.Exec("My Project", "This is a sample project")
    if err != nil {
        log.Fatal(err)
    }

    // 查询数据
    rows, err := db.Query("SELECT id, name, description FROM projects")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    for rows.Next() {
        var id int
        var name, description string
        err = rows.Scan(&id, &name, &description)
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println(id, name, description)
    }

    // 检查查询过程中可能出现的错误
    err = rows.Err()
    if err != nil {
        log.Fatal(err)
    }
}