Golang操作sqlite3數(shù)據(jù)庫的詳細教程
本文介紹sqlite數(shù)據(jù)庫,如何使用sqlite3包操作輕量級關系型數(shù)據(jù)庫。
sqlite概述
sqlite是嵌入式關系型數(shù)據(jù)庫引擎,官方描述為自包含的、無服務的、零配置并支持事務的關系型數(shù)據(jù)庫引擎。我們在產(chǎn)品開發(fā)過程中經(jīng)常使用,可以快速進行產(chǎn)品驗證和部署,快速實現(xiàn)產(chǎn)品演示。
Go有sql包,它提供了sql(或類sql)數(shù)據(jù)庫的通用接口。sql包必須與數(shù)據(jù)庫驅動程序一起使用。
創(chuàng)建SQLITE數(shù)據(jù)庫
使用sqlite3命令行工具創(chuàng)建數(shù)據(jù)庫,查詢數(shù)據(jù)。
sudo apt install sqlite3
安裝好工具,創(chuàng)建數(shù)據(jù)庫:
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ù)庫名稱,也是磁盤上的文件名。如果文件存在就打開,不存在則創(chuàng)建:
sqlite> .tables sqlite> .exit $ ls test.db
.tables名稱列出test.db數(shù)據(jù)庫中所有表,當前沒有表;.exit命令終止活動session命令行工具。ls命令顯示當前目錄下的文件,可以看到我們創(chuàng)建的test.db文件。
打印版本
下面示例打印sqlite3的版本,主要通過SELECT SQLITE_VERSION()語句返回版本號:
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)
}首先導入包,這里導入前綴為下劃線,則init函數(shù)被執(zhí)行。然后注冊驅動;
db, err := sql.Open("sqlite3", ":memory:")Open函數(shù)指定驅動名稱和數(shù)據(jù)源名稱,本示例連接內(nèi)存數(shù)據(jù)庫。接著調(diào)用db.Close函數(shù),確保關閉數(shù)據(jù)庫并阻止啟動新的查詢。
err = db.QueryRow("SELECT SQLITE_VERSION()").Scan(&version)QueryRow執(zhí)行查詢,至少返回一行。Scan函數(shù)從返回行拷貝列至version變量。
$ go run main.go 3.39.4
Exec執(zhí)行DML語句
Exec函數(shù)執(zhí)行沒有返回記錄的查詢語句,即DML語句:
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ù)庫,生成新的數(shù)據(jù)庫文件:
db, err := sql.Open("sqlite3", "test.db")接著創(chuàng)建表并插入數(shù)據(jù)。通過_, err = db.Exec(sts)語句執(zhí)行DML。
查詢記錄
查詢語句返回符合條件記錄,典型是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í)行查詢語句:
rows, err := db.Query("SELECT * FROM cars")Next為Scan方法準備下一個結果行。成功返回True,如果沒有結果或發(fā)生錯誤返回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 語句
使用prepared 語句,可以包括占位符代替直接在語句中寫值,保證數(shù)據(jù)庫操作的性能和安全。
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語句查詢特定行:
stm, err := db.Prepare("SELECT * FROM cars WHERE id = ?")傳入?yún)?shù)給QueryRow函數(shù),以替換占位符:
err = stm.QueryRow(cid).Scan(&id, &name, &price)
也可以一步實現(xiàn)上面兩步功能:
row := db.QueryRow("SELECT * FROM cars WHERE id = ?", cid)返回影響行數(shù)
RowsAffected 返回執(zhí)行DML語句影響的行數(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語句刪除三行記錄,然后打印結果進行驗證。運行結果如下:
$ go run main.go The statement has affected 3 rows
總結
到此這篇關于Golang操作sqlite3數(shù)據(jù)庫的文章就介紹到這了,更多相關Golang操作sqlite3數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
使用go語言實現(xiàn)查找兩個數(shù)組的異同操作
這篇文章主要介紹了使用go語言實現(xiàn)查找兩個數(shù)組的異同操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
Go語言實現(xiàn)基于websocket瀏覽器通知功能
這篇文章主要介紹了Go語言實現(xiàn)基于websocket瀏覽器通知功能,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-07-07

