Golang操作sqlite3數(shù)據(jù)庫的詳細教程
本文介紹sqlite數(shù)據(jù)庫,如何使用sqlite3包操作輕量級關(guān)系型數(shù)據(jù)庫。
sqlite概述
sqlite是嵌入式關(guān)系型數(shù)據(jù)庫引擎,官方描述為自包含的、無服務(wù)的、零配置并支持事務(wù)的關(guān)系型數(shù)據(jù)庫引擎。我們在產(chǎn)品開發(fā)過程中經(jīng)常使用,可以快速進行產(chǎn)品驗證和部署,快速實現(xiàn)產(chǎn)品演示。
Go有sql包,它提供了sql(或類sql)數(shù)據(jù)庫的通用接口。sql包必須與數(shù)據(jù)庫驅(qū)動程序一起使用。
創(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ù)庫中所有表,當(dāng)前沒有表;.exit命令終止活動session命令行工具。ls命令顯示當(dāng)前目錄下的文件,可以看到我們創(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) }
首先導(dǎo)入包,這里導(dǎo)入前綴為下劃線,則init函數(shù)被執(zhí)行。然后注冊驅(qū)動;
db, err := sql.Open("sqlite3", ":memory:")
Open函數(shù)指定驅(qū)動名稱和數(shù)據(jù)源名稱,本示例連接內(nèi)存數(shù)據(jù)庫。接著調(diào)用db.Close函數(shù),確保關(guān)閉數(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方法準(zhǔn)備下一個結(jié)果行。成功返回True,如果沒有結(jié)果或發(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語句刪除三行記錄,然后打印結(jié)果進行驗證。運行結(jié)果如下:
$ go run main.go The statement has affected 3 rows
總結(jié)
到此這篇關(guān)于Golang操作sqlite3數(shù)據(jù)庫的文章就介紹到這了,更多相關(guān)Golang操作sqlite3數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
使用go語言實現(xiàn)查找兩個數(shù)組的異同操作
這篇文章主要介紹了使用go語言實現(xiàn)查找兩個數(shù)組的異同操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12Golang?urfave/cli庫簡單應(yīng)用示例詳解
這篇文章主要為大家介紹了Golang?urfave/cli庫簡單應(yīng)用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-09-09Go語言實現(xiàn)基于websocket瀏覽器通知功能
這篇文章主要介紹了Go語言實現(xiàn)基于websocket瀏覽器通知功能,本文通過實例代碼給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-07-07