Golang操作sqlite3数据库的详细教程
作者:梦想画家 发布时间:2024-01-14 05:32:52
本文介绍sqlite数据库,如何使用sqlite3包操作轻量级关系型数据库。
sqlite概述
sqlite是嵌入式关系型数据库引擎,官方描述为自包含的、无服务的、零配置并支持事务的关系型数据库引擎。我们在产品开发过程中经常使用,可以快速进行产品验证和部署,快速实现产品演示。
Go有sql包,它提供了sql(或类sql)数据库的通用接口。sql包必须与数据库驱动程序一起使用。
创建SQLITE数据库
使用sqlite3命令行工具创建数据库,查询数据。
sudo apt install sqlite3
安装好工具,创建数据库:
sqlite3 test.db
SQLite version 3.37.2 2022-01-06 13:25:41
Enter ".help" for usage hints.
sqlite>
test.db是sqlite3命令的参数,即为数据库名称,也是磁盘上的文件名。如果文件存在就打开,不存在则创建:
sqlite> .tables
sqlite> .exit
$ ls
test.db
.tables名称列出test.db数据库中所有表,当前没有表;.exit命令终止活动session命令行工具。ls命令显示当前目录下的文件,可以看到我们创建的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函数被执行。然后注册驱动;
db, err := sql.Open("sqlite3", ":memory:")
Open函数指定驱动名称和数据源名称,本示例连接内存数据库。接着调用db.Close函数,确保关闭数据库并阻止启动新的查询。
err = db.QueryRow("SELECT SQLITE_VERSION()").Scan(&version)
QueryRow执行查询,至少返回一行。Scan函数从返回行拷贝列至version变量。
$ go run main.go
3.39.4
Exec执行DML语句
Exec函数执行没有返回记录的查询语句,即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")
}
首先创建数据库,生成新的数据库文件:
db, err := sql.Open("sqlite3", "test.db")
接着创建表并插入数据。通过_, err = db.Exec(sts)
语句执行DML。
查询记录
查询语句返回符合条件记录,典型是SELECT,可选参数为占位符:
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)
}
}
执行查询语句:
rows, err := db.Query("SELECT * FROM cars")
Next为Scan方法准备下一个结果行。成功返回True,如果没有结果或发生错误返回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方法获取字段值,最后打印记录的列值。
带参数的prepared 语句
使用prepared 语句,可以包括占位符代替直接在语句中写值,保证数据库操作的性能和安全。
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函数执行prepare语句查询特定行:
stm, err := db.Prepare("SELECT * FROM cars WHERE id = ?")
传入参数给QueryRow函数,以替换占位符:
err = stm.QueryRow(cid).Scan(&id, &name, &price)
也可以一步实现上面两步功能:
row := db.QueryRow("SELECT * FROM cars WHERE id = ?", cid)
返回影响行数
RowsAffected 返回执行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()
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
来源:https://blog.csdn.net/neweastsun/article/details/127721797
猜你喜欢
- 关于 Python requests ,在使用中,总结了一些小技巧把,记录下。1:保持请求之间的Cookies,我们可以这样做。
- 下载并选择MySQL的安装包由于MySQL一直在升级,所以当您阅读本文时,或许在其官方网站上已提供了新的正式版供你下载,因此,以下提供的链接
- 在官网下载python和pycharm的安装包python: https://www.python.org/downloads/window
- 这段时间有个朋友想导出微信里面的账单信息,后来发现微信的反爬虫还是很厉害的,花了点时间去分析。一、采用传统模拟http抓取抓取的主要URL:
- python实现四舍五入""" 四舍五入 :param
- 每次卷积神经网络训练的结果都只保存了最后一部分,查阅了一下相关资料,发现是定义saver时采用的默认值,这里进行如下设置: saver =
- import numpy as npimport pandas as pdfrom pandas_datareader import dat
- Rs.GetRows(N):N代表获取记录数量 Rs.GetRows(1):1表示只返回一行记录 Rs.GetRows(-1):-1表示默认
- 实现的思路:将准备好的图片通过opencv读取出来,并将其设置好帧数等参数后合成为无声视频。最后通过moviepy编辑视频将背景音乐加入到视
- 说起页面执行时间相信大家并不陌生,如果你经常逛论坛,就会发现很多论坛底部都显示有页面执行时间,那么什么是页面执行时间呢?我个人理解是一个网页
- 前言相信在日常生活中,平常大家聚在一起总会聊聊天,特别是女生(有冒犯到doge)非常喜欢聊星座,这个男生什么星座呀,那个男生什么星座呀…今天
- 本文实例讲述了Python实现将Excel转换成xml的方法。分享给大家供大家参考,具体如下:最近写了个小工具 用于excel转成xml直接
- 本文实例为大家分享了python爬取淘宝商品的具体代码,供大家参考,具体内容如下import requests as req import
- 前言本文主要介绍的是Python WSGI相关内容,主要来自以下网址:What is WSGI?WSGI TutorialAn Introd
- 上篇文章给大家介绍过解决Navicat for Mysql连接报错1251的问题(连接失败),今天介绍Navicat for MySQL 连
- 两种方法,一种是为表空间增加数据文件: alter tablespace users add datafile '/opt/orac
- 1. datetime模块介绍1.1 datetime模块包含的类1.2 datetime模块中包含的常量2. datetime实例的方法案
- 利用Keras构建完普通BP神经网络后,还要会构建CNNKeras中构建CNN的重要函数1、Conv2DConv2D用于在CNN中构建卷积层
- 一、简介Supervisor 是一款 Python 开发的进程管理系统,允许用户监视和控制 Linux 上的进程,能将一个普通命令行进程变为
- SQL Server 2008我们也能从中体验到很多新的特性,但是对于SQL Server 2008安装,还是用图来说话比较好。本文将从SQ