Golang使用sqlite3數(shù)據(jù)庫實(shí)現(xiàn)CURD操作
工具類項(xiàng)目慢慢喜歡使用sqlite3數(shù)據(jù)庫。工具類項(xiàng)目不存在并發(fā)問題,部署項(xiàng)目也不需要額外去安裝數(shù)據(jù)庫服務(wù)端,非常省事。
1、安裝sqlite3驅(qū)動(dòng)
go get github.com/mattn/go-sqlite3
2、go連接sqlite3初始化方法
var db *sql.DB
func init() {
// 打開或創(chuàng)建一個(gè) SQLite 數(shù)據(jù)庫文件
var err error
db, err = sql.Open("sqlite3", "./db.db")
if err != nil {
log.Fatal(err)
}
// 測(cè)試連接
if err = db.Ping(); err != nil {
log.Fatal(err)
}
}
這里涉及到一個(gè)init()函數(shù)。在 Go 語言中,init() 函數(shù)是一個(gè)特殊的函數(shù),它在程序開始執(zhí)行時(shí)自動(dòng)調(diào)用,這里就可以拿來連接數(shù)據(jù)庫初始化操作。每個(gè)包都可以包含任意數(shù)量的 init() 函數(shù),并且這些函數(shù)會(huì)在包被導(dǎo)入時(shí)自動(dòng)執(zhí)行。init() 函數(shù)通常用于初始化操作,例如設(shè)置變量、打開文件或數(shù)據(jù)庫連接等。
init() 函數(shù)的特點(diǎn):
自動(dòng)調(diào)用:init() 函數(shù)不需要顯式調(diào)用,它們?cè)诎粚?dǎo)入時(shí)自動(dòng)執(zhí)行。
執(zhí)行順序:
- 如果一個(gè)包中有多個(gè) init() 函數(shù),它們會(huì)按照在源代碼中的順序依次執(zhí)行。
- 如果一個(gè)包導(dǎo)入了其他包,那么被導(dǎo)入包的 init() 函數(shù)會(huì)在導(dǎo)入它的包的 init() 函數(shù)之前執(zhí)行。
- 無參數(shù)和返回值:init() 函數(shù)沒有參數(shù)也沒有返回值。
- 不能被其他函數(shù)調(diào)用:init() 函數(shù)只能由運(yùn)行時(shí)系統(tǒng)調(diào)用,不能被其他函數(shù)調(diào)用。
3、測(cè)試Users結(jié)構(gòu)體
type Users struct {
ID int
Name string
Email string
}
結(jié)構(gòu)體字段的首字母是否大寫決定了該字段是否對(duì)包外可見(即是否具有公共訪問權(quán)限)
知識(shí)點(diǎn):
首字母大寫:如果一個(gè)標(biāo)識(shí)符(包括結(jié)構(gòu)體字段、函數(shù)名、變量名等)的首字母是大寫的,那么它就是可以被其他包訪問的,即它是“導(dǎo)出的”或“公開的”。
首字母小寫:如果一個(gè)標(biāo)識(shí)符的首字母是小寫的,那么它只能在其定義的包內(nèi)部訪問,對(duì)于其他包是不可見的,即它是“未導(dǎo)出的”或“私有的”。
4、users表CURD操作
// CreateUser 創(chuàng)建新用戶
func (u *Users) CreateUser() (int64, error) {
stmt, err := db.Prepare("INSERT INTO users (name, email) VALUES (?, ?)")
if err != nil {
return 0, err
}
res, err := stmt.Exec(u.Name, u.Email)
if err != nil {
return 0, err
}
return res.LastInsertId()
}
// GetUserByID 根據(jù) ID 獲取用戶
func (u *Users) GetUserByID(id int) error {
row := db.QueryRow("SELECT id, name, email FROM users WHERE id = ?", id)
return row.Scan(&u.ID, &u.Name, &u.Email)
}
// GetAllUsers 獲取所有用戶
func GetAllUsers() ([]*Users, error) {
rows, err := db.Query("SELECT id, name, email FROM users")
if err != nil {
return nil, err
}
defer rows.Close()
var users []*Users
for rows.Next() {
user := &Users{}
if err := rows.Scan(&user.ID, &user.Name, &user.Email); err != nil {
return nil, err
}
users = append(users, user)
}
if err := rows.Err(); err != nil {
return nil, err
}
return users, nil
}
// UpdateUser 更新用戶信息
func (u *Users) UpdateUser() (int64, error) {
stmt, err := db.Prepare("UPDATE users SET name = ?, email = ? WHERE id = ?")
if err != nil {
return 0, err
}
res, err := stmt.Exec(u.Name, u.Email, u.ID)
if err != nil {
return 0, err
}
return res.RowsAffected()
}
// DeleteUser 刪除用戶
func (u *Users) DeleteUser() (int64, error) {
stmt, err := db.Prepare("DELETE FROM users WHERE id = ?")
if err != nil {
return 0, err
}
res, err := stmt.Exec(u.ID)
if err != nil {
return 0, err
}
return res.RowsAffected()
}
這里的CURD操作,都是方法。方法是一種特殊類型的函數(shù),它有一個(gè)接收者(receiver)。接收者可以是任何類型的值或指針。這里的接收者就是(u *Users),用的是指針。
5、go使用sqlite3數(shù)據(jù)庫實(shí)現(xiàn)CURD操作
// main.go
package main
import (
"database/sql"
"fmt"
"log"
_ "github.com/mattn/go-sqlite3" // 導(dǎo)入 sqlite3 驅(qū)動(dòng)
)
type Users struct {
ID int
Name string
Email string
}
var db *sql.DB
func init() {
// 打開或創(chuàng)建一個(gè) SQLite 數(shù)據(jù)庫文件
var err error
db, err = sql.Open("sqlite3", "./db.db")
if err != nil {
log.Fatal(err)
}
// 測(cè)試連接
if err = db.Ping(); err != nil {
log.Fatal(err)
}
// 創(chuàng)建用戶表
createTableSQL := `
CREATE TABLE IF NOT EXISTS users (
id INTEGER PRIMARY KEY,
name TEXT NOT NULL,
email TEXT NOT NULL UNIQUE
);
`
// 執(zhí)行 SQL 語句
_, err = db.Exec(createTableSQL)
if err != nil {
log.Fatal(err)
}
}
// CreateUser 創(chuàng)建新用戶
func (u *Users) CreateUser() (int64, error) {
stmt, err := db.Prepare("INSERT INTO users (name, email) VALUES (?, ?)")
if err != nil {
return 0, err
}
res, err := stmt.Exec(u.Name, u.Email)
if err != nil {
return 0, err
}
return res.LastInsertId()
}
// GetUserByID 根據(jù) ID 獲取用戶
func (u *Users) GetUserByID(id int) error {
row := db.QueryRow("SELECT id, name, email FROM users WHERE id = ?", id)
return row.Scan(&u.ID, &u.Name, &u.Email)
}
// GetAllUsers 獲取所有用戶
func GetAllUsers() ([]*Users, error) {
rows, err := db.Query("SELECT id, name, email FROM users")
if err != nil {
return nil, err
}
defer rows.Close()
var users []*Users
for rows.Next() {
user := &Users{}
if err := rows.Scan(&user.ID, &user.Name, &user.Email); err != nil {
return nil, err
}
users = append(users, user)
}
if err := rows.Err(); err != nil {
return nil, err
}
return users, nil
}
// UpdateUser 更新用戶信息
func (u *Users) UpdateUser() (int64, error) {
stmt, err := db.Prepare("UPDATE users SET name = ?, email = ? WHERE id = ?")
if err != nil {
return 0, err
}
res, err := stmt.Exec(u.Name, u.Email, u.ID)
if err != nil {
return 0, err
}
return res.RowsAffected()
}
// DeleteUser 刪除用戶
func (u *Users) DeleteUser() (int64, error) {
stmt, err := db.Prepare("DELETE FROM users WHERE id = ?")
if err != nil {
return 0, err
}
res, err := stmt.Exec(u.ID)
if err != nil {
return 0, err
}
return res.RowsAffected()
}
func main() {
fmt.Println("main函數(shù)開始...")
// 創(chuàng)建用戶
user := &Users{Name: "buddha", Email: "3539949705@qq.com"}
id, err := user.CreateUser()
if err != nil {
log.Fatalf("Failed to create user: %v", err)
}
fmt.Printf("Created user with ID: %d\n", id)
// 獲取用戶
user = &Users{}
if err := user.GetUserByID(int(id)); err != nil {
log.Fatalf("Failed to get user: %v", err)
}
fmt.Printf("User: ID: %d, Name: %s, Email: %s\n", user.ID, user.Name, user.Email)
// 更新用戶
user.Name = "buddha2080"
user.Email = "3539949704@qq.com"
affectedRows, err := user.UpdateUser()
if err != nil {
log.Fatalf("Failed to update user: %v", err)
}
fmt.Printf("Updated %d rows\n", affectedRows)
// 獲取所有用戶
users, err := GetAllUsers()
if err != nil {
log.Fatalf("Failed to get all users: %v", err)
}
for _, u := range users {
fmt.Printf("User: id: %d, name: %s, email: %s\n", u.ID, u.Name, u.Email)
}
// 刪除用戶
affectedRows, err = user.DeleteUser()
if err != nil {
log.Fatalf("Failed to delete user: %v", err)
}
fmt.Printf("Deleted %d rows\n", affectedRows)
fmt.Println("main函數(shù)結(jié)束...")
}
到此這篇關(guān)于Golang使用sqlite3數(shù)據(jù)庫實(shí)現(xiàn)CURD操作的文章就介紹到這了,更多相關(guān)Go sqlite3數(shù)據(jù)庫CURD操作內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
深入解析Go語言編程中slice切片結(jié)構(gòu)
這篇文章主要介紹了Go語言編程中slice切片結(jié)構(gòu),其中Append方法的用法介紹較為詳細(xì),需要的朋友可以參考下2015-10-10
Golang基礎(chǔ)常識(shí)性面試中常見的六大陷阱及應(yīng)對(duì)技巧總結(jié)
Go是一門簡(jiǎn)單有趣的語言,但與其他語言類似,它會(huì)有一些技巧,這篇文章主要給大家介紹了關(guān)于Golang基礎(chǔ)常識(shí)性面試中常見的六大陷阱及應(yīng)對(duì)技巧的相關(guān)資料,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-08-08
Go語言進(jìn)行多時(shí)區(qū)時(shí)間轉(zhuǎn)換的示例代碼
本文介紹了使用Go語言進(jìn)行多時(shí)區(qū)時(shí)間轉(zhuǎn)換,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-12-12
Go?不支持?[]T轉(zhuǎn)換為[]interface類型詳解
這篇文章主要為大家介紹了Go不支持[]T轉(zhuǎn)換為[]interface類型詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-01-01
基于Go語言開發(fā)實(shí)現(xiàn)條形碼識(shí)別器
在物流、零售、倉儲(chǔ)等行業(yè),條形碼是最常見的商品標(biāo)識(shí)方式,本文將用 Go 實(shí)現(xiàn)一個(gè)條形碼識(shí)別工具,能夠從圖片中識(shí)別出條碼并解析內(nèi)容,希望對(duì)大家有所幫助2025-09-09
Go結(jié)合反射將結(jié)構(gòu)體轉(zhuǎn)換成Excel的過程詳解
這篇文章主要介紹了Go結(jié)合反射將結(jié)構(gòu)體轉(zhuǎn)換成Excel的過程詳解,大概思路是在Go的結(jié)構(gòu)體中每個(gè)屬性打上一個(gè)excel標(biāo)簽,利用反射獲取標(biāo)簽中的內(nèi)容,作為表格的Header,需要的朋友可以參考下2022-06-06

