基本信息
源码名称:go语言操作sqlite数据库
源码大小:2.31KB
文件格式:.go
开发语言:Go
更新时间:2021-08-26
   友情提示:(无需注册或充值,赞助后即可获取资源下载链接)

     嘿,亲!知识可是无价之宝呢,但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下,绝对物超所值哦!如有下载和支付问题,请联系我们QQ(微信同号):813200300

本次赞助数额为: 5 元 
   源码介绍
入门级实例,实现了增删改查

package main

import (
"database/sql"
"fmt"

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

/*
func main() {
dbOption := new(models.DbOption)
err2 := dbOption.InitDB()
if err2 != nil {
fmt.Println("dbOption InitDB:", err2)
}

var stock models.Stock
stock.Code = "212"
stock.Name = "test"
dbOption.StockData = &stock

err2 = dbOption.InsertStock()
if err2 != nil {
fmt.Println("Insert:", err2)
}
}
*/

func main() {
//db, err := sql.Open("sqlite3", "./foo.db")
db, err := sql.Open("sqlite3", "file:test.s3db?_auth&_auth_user=admin&_auth_pass=admin&_auth_crypt=sha1")
checkErr(err)

sql := `
SELECT auth_user_add('admin2', 'admin2', 1);
`

db.Exec(sql)

fmt.Println("生成数据表")
sql_table := `
CREATE TABLE IF NOT EXISTS "userinfo" (
   "uid" INTEGER PRIMARY KEY AUTOINCREMENT,
   "username" VARCHAR(64) NULL,
   "departname" VARCHAR(64) NULL,
   "created" TIMESTAMP default (datetime('now', 'localtime'))  
);
CREATE TABLE IF NOT EXISTS "userdeatail" (
   "uid" INT(10) NULL,
   "intro" TEXT NULL,
   "profile" TEXT NULL,
   PRIMARY KEY (uid)
);
   `
db.Exec(sql_table)

//插入数据
stmt, err := db.Prepare("INSERT INTO userinfo(username, departname, created) values(?,?,?)")
checkErr(err)

res, err := stmt.Exec("astaxie", "研发部门", "2012-12-09")
checkErr(err)

id, err := res.LastInsertId()
checkErr(err)

fmt.Println(id)
//更新数据
stmt, err = db.Prepare("update userinfo set username=? where uid=?")
checkErr(err)

res, err = stmt.Exec("astaxieupdate", id)
checkErr(err)

affect, err := res.RowsAffected()
checkErr(err)

fmt.Println(affect)

//查询数据
rows, err := db.Query("SELECT * FROM userinfo")
checkErr(err)

for rows.Next() {
var uid int
var username string
var department string
var created string
err = rows.Scan(&uid, &username, &department, &created)
checkErr(err)
fmt.Println(uid)
fmt.Println(username)
fmt.Println(department)
fmt.Println(created)
}

/*
//删除数据
stmt, err = db.Prepare("delete from userinfo where uid=?")
checkErr(err)

res, err = stmt.Exec(id)
checkErr(err)

affect, err = res.RowsAffected()
checkErr(err)

fmt.Println(affect)
*/
db.Close()

}

func checkErr(err error) {
if err != nil {
panic(err)
}
}