sqlite是嵌入式關(guān)系型數(shù)據(jù)庫(kù)引擎，官方描述為自包含的、無(wú)服務(wù)的、零配置并支持事務(wù)的關(guān)系型數(shù)據(jù)庫(kù)引擎。我們?cè)诋a(chǎn)品開發(fā)過(guò)程中經(jīng)常使用，可以快速進(jìn)行產(chǎn)品驗(yàn)證和部署，快速實(shí)現(xiàn)產(chǎn)品演示。

Go有sql包，它提供了sql(或類sql)數(shù)據(jù)庫(kù)的通用接口。sql包必須與數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序一起使用。

創(chuàng)建SQLITE數(shù)據(jù)庫(kù)

使用sqlite3命令行工具創(chuàng)建數(shù)據(jù)庫(kù)，查詢數(shù)據(jù)。

sudo apt install sqlite3

安裝好工具，創(chuàng)建數(shù)據(jù)庫(kù)：

sqlite3 test.db
SQLite version 3.37.2 2022-01-06 13:25:41
Enter ".help" for usage hints.
sqlite>

test.db是sqlite3命令的參數(shù)，即為數(shù)據(jù)庫(kù)名稱，也是磁盤上的文件名。如果文件存在就打開，不存在則創(chuàng)建：

sqlite> .tables
sqlite> .exit

$ ls
test.db

.tables名稱列出test.db數(shù)據(jù)庫(kù)中所有表，當(dāng)前沒(méi)有表；.exit命令終止活動(dòng)session命令行工具。ls命令顯示當(dāng)前目錄下的文件，可以看到我們創(chuàng)建的test.db文件。

打印版本

下面示例打印sqlite3的版本，主要通過(guò)SELECT SQLITE_VERSION()語(yǔ)句返回版本號(hào)：

package main

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

	_ "github.com/mattn/go-sqlite3"
)

func main() {

	db, err := sql.Open("sqlite3", ":memory:")

	if err != nil {
		log.Fatal(err)
	}

	defer db.Close()

	var version string
	err = db.QueryRow("SELECT SQLITE_VERSION()").Scan(&version)

	if err != nil {
		log.Fatal(err)
	}

	fmt.Println(version)
}

首先導(dǎo)入包，這里導(dǎo)入前綴為下劃線，則init函數(shù)被執(zhí)行。然后注冊(cè)驅(qū)動(dòng)；

db, err := sql.Open("sqlite3", ":memory:")

Open函數(shù)指定驅(qū)動(dòng)名稱和數(shù)據(jù)源名稱，本示例連接內(nèi)存數(shù)據(jù)庫(kù)。接著調(diào)用db.Close函數(shù)，確保關(guān)閉數(shù)據(jù)庫(kù)并阻止啟動(dòng)新的查詢。

err = db.QueryRow("SELECT SQLITE_VERSION()").Scan(&version)

QueryRow執(zhí)行查詢，至少返回一行。Scan函數(shù)從返回行拷貝列至version變量。

$ go run main.go
3.39.4

Exec執(zhí)行DML語(yǔ)句

Exec函數(shù)執(zhí)行沒(méi)有返回記錄的查詢語(yǔ)句，即DML語(yǔ)句：

package main

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

	_ "github.com/mattn/go-sqlite3"
)

func main() {

	db, err := sql.Open("sqlite3", "test.db")

	if err != nil {
		log.Fatal(err)
	}

	defer db.Close()

	sts := `
DROP TABLE IF EXISTS cars;
CREATE TABLE cars(id INTEGER PRIMARY KEY, name TEXT, price INT);
INSERT INTO cars(name, price) VALUES('Audi',52642);
INSERT INTO cars(name, price) VALUES('Mercedes',57127);
INSERT INTO cars(name, price) VALUES('Skoda',9000);
INSERT INTO cars(name, price) VALUES('Volvo',29000);
INSERT INTO cars(name, price) VALUES('Bentley',350000);
INSERT INTO cars(name, price) VALUES('Citroen',21000);
INSERT INTO cars(name, price) VALUES('Hummer',41400);
INSERT INTO cars(name, price) VALUES('Volkswagen',21600);
`
	_, err = db.Exec(sts)

	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("table cars created")
}

首先創(chuàng)建數(shù)據(jù)庫(kù)，生成新的數(shù)據(jù)庫(kù)文件：

db, err := sql.Open("sqlite3", "test.db")

接著創(chuàng)建表并插入數(shù)據(jù)。通過(guò)_, err = db.Exec(sts)語(yǔ)句執(zhí)行DML。

查詢記錄

查詢語(yǔ)句返回符合條件記錄，典型是SELECT，可選參數(shù)為占位符：

package main

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

	_ "github.com/mattn/go-sqlite3"
)

func main() {

	db, err := sql.Open("sqlite3", "test.db")

	if err != nil {
		log.Fatal(err)
	}

	defer db.Close()

	rows, err := db.Query("SELECT * FROM cars")

	if err != nil {
		log.Fatal(err)
	}

	defer rows.Close()

	for rows.Next() {

		var id int
		var name string
		var price int

		err = rows.Scan(&id, &name, &price)

		if err != nil {
			log.Fatal(err)
		}

		fmt.Printf("%d %s %d\n", id, name, price)
	}
}

執(zhí)行查詢語(yǔ)句：

rows, err := db.Query("SELECT * FROM cars")

Next為Scan方法準(zhǔn)備下一個(gè)結(jié)果行。成功返回True，如果沒(méi)有結(jié)果或發(fā)生錯(cuò)誤返回false。

	for rows.Next() {

		var id int
		var name string
		var price int

		err = rows.Scan(&id, &name, &price)

		if err != nil {
			log.Fatal(err)
		}

		fmt.Printf("%d %s %d\n", id, name, price)
	}

Scan方法獲取字段值，最后打印記錄的列值。

帶參數(shù)的prepared 語(yǔ)句

使用prepared 語(yǔ)句，可以包括占位符代替直接在語(yǔ)句中寫值，保證數(shù)據(jù)庫(kù)操作的性能和安全。

package main

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

    _ "github.com/mattn/go-sqlite3"
)

func main() {

    db, err := sql.Open("sqlite3", "test.db")

    if err != nil {
        log.Fatal(err)
    }

    defer db.Close()

    stm, err := db.Prepare("SELECT * FROM cars WHERE id = ?")

    if err != nil {
        log.Fatal(err)
    }

    defer stm.Close()

    var id int
    var name string
    var price int

    cid := 3

    err = stm.QueryRow(cid).Scan(&id, &name, &price)

    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("%d %s %d\n", id, name, price)
}

使用prepare函數(shù)執(zhí)行prepare語(yǔ)句查詢特定行：

stm, err := db.Prepare("SELECT * FROM cars WHERE id = ?")

傳入?yún)?shù)給QueryRow函數(shù)，以替換占位符：

err = stm.QueryRow(cid).Scan(&id, &name, &price)

也可以一步實(shí)現(xiàn)上面兩步功能：

row := db.QueryRow("SELECT * FROM cars WHERE id = ?", cid)

返回影響行數(shù)

RowsAffected 返回執(zhí)行DML語(yǔ)句影響的行數(shù)：

package main

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

    _ "github.com/mattn/go-sqlite3"
)

func main() {

    db, err := sql.Open("sqlite3", "test.db")

    if err != nil {
        log.Fatal(err)
    }

    defer db.Close()

    res, err := db.Exec("DELETE FROM cars WHERE id IN (1, 2, 3)")

    if err != nil {
        log.Fatal(err)
    }

    n, err := res.RowsAffected()

    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("The statement has affected %d rows\n", n)
}

上面示例使用delete語(yǔ)句刪除三行記錄，然后打印結(jié)果進(jìn)行驗(yàn)證。運(yùn)行結(jié)果如下：

$ go run main.go 
The statement has affected 3 rows

總結(jié)

到此這篇關(guān)于Golang操作sqlite3數(shù)據(jù)庫(kù)的文章就介紹到這了,更多相關(guān)Golang操作sqlite3數(shù)據(jù)庫(kù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: