SQLite库笔记：API函数编程

embedded/2024/10/19 5:26:24/

本文主要介绍SQLite库的一些核心API函数，和实现数据库增删查改功能的C语言示例程序代码。

目录

1. API函数原型

sqlite3_open-toc" style="margin-left:40px;">1.1 sqlite3_open

sqlite3_close-toc" style="margin-left:40px;">1.2 sqlite3_close

sqlite3_free-toc" style="margin-left:40px;">1.3 sqlite3_free

sqlite3_errmsg-toc" style="margin-left:40px;">1.4 sqlite3_errmsg

sqlite3_exec-toc" style="margin-left:40px;">1.5 sqlite3_exec

sqlite3_get_table-toc" style="margin-left:40px;">1.6 sqlite3_get_table

sqlite3_free_table-toc" style="margin-left:40px;">1.7 sqlite3_free_table

2. 返回码定义

3. 示例程序

3.1 数据库表设计

3.2 代码

3.3 编译运行

1. API函数原型

SQLite库有两百多个API，下面列出几个核心的API。

sqlite3_open">1.1 sqlite3_open

函数声明    

int sqlite3_open(const char *filename, sqlite3 **ppDb);

描述  

打开数据库文件

参数

filename[输入]  

数据库文件名 (UTF-8)

ppDb[输出]  

 SQLite db句柄

返回值

0-成功，其它-失败

sqlite3_close">1.2 sqlite3_close

函数声明    

int sqlite3_close(sqlite3* pDb);

描述  

关闭数据库db句柄

参数

pDb[输入]

数据库db句柄

返回值

0-成功，其它-失败

sqlite3_free">1.3 sqlite3_free

函数声明    

void sqlite3_free(void* ptr);

描述  

释放指针数据

参数

Ptr[输入]

指针数据

返回值

无

sqlite3_errmsg">1.4 sqlite3_errmsg

函数声明    

const char *sqlite3_errmsg(sqlite3* pDb);

描述  

获取具体的错误信息

参数

pDb[输入]

数据库db句柄

返回值

错误信息字符串

sqlite3_exec">1.5 sqlite3_exec

函数声明    

int sqlite3_exec(sqlite3*db, const char *sql,

                        int (*callback)(void*,int,char**,char**), void *arg, char **errmsg);

描述  

运行SQL语句

参数

db[输入]

一个打开的数据库db句柄

Sql[输入]

要执行的SQL语句

callback [输入]

回调函数

arg[输入]

回调函数的第一个参数

errmsg[输出]

错误信息

返回值

0-成功，其它-失败

sqlite3_get_table">1.6 sqlite3_get_table

函数声明    

int sqlite3_get_table(sqlite3 *db, const char *zSql, char ***pazResult,

                                int *pnRow, int *pnColumn, char **pzErrmsg);

描述  

运行SQL查询语句

参数

db[输入]

一个打开的数据库db句柄

zSql[输入]

要执行的SQL语句

pazResult[输出]

查询的结果

pnRow[输出]

查询结果的行数

pnColumn[输出]

查询结果的列数

pzErrmsg[输出]

错误信息

返回值

0-成功，其它-失败

sqlite3_free_table">1.7 sqlite3_free_table

函数声明    

void sqlite3_free_table(char **result);

描述  

释放SQL查询结果指针

参数

result [输入]

查询的结果

返回值

无

2. 返回码定义

sqlite3.h中常遇到的返回码

含义

SQLITE_OK (0)

成功

SQLITE_ERROR (1)

通用返回码

SQLITE_INTERNAL (2)

内部故障

SQLITE_PERM (3)

无法提供新创建的数据库的请求访问模式

SQLITE_ABORT (4)

操作中断

SQLITE_BUSY (5)

由于其它数据库连接的并发活动，无法读写

SQLITE_LOCKED (6)

连接冲突，写操作失败

3. 示例程序

3.1 数据库表设计

元素

类型

说明

id

int

货物ID

name

char(16)

货物名称

supplier

char(16)

供应商

ymdhms

datetime

年-月-日 时:分:秒

unit

int

单价

num

int

数量

sum

int

总价

3.2 代码

下面的代码实现了数据库的基本功能操作，包括：

/*  This is a demo using the SQLite library API functions.*  More details about SQLite: https://www.sqlite.org/*/#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include "sqlite3.h"#define DEBUG_PRINTF(format, ...)   printf("<%s, %d> "format" ", __func__, __LINE__, ## __VA_ARGS__)
#define ARRAY_SIZE(_arr)		    (sizeof((_arr)) / sizeof((_arr)[0]))
#define PURCHASE_DB_FILE			"test.db"typedef struct _purchase_para{int id;char name[16];char supplier[16];char ymdhms[24];int unit;int num;int sum;
}purchase_para;int iDBInit(sqlite3 **ppDb)
{char *err = NULL;char sql[256] = {0};int ret;/* database init */ret = sqlite3_open(PURCHASE_DB_FILE, ppDb);if (ret != SQLITE_OK) {DEBUG_PRINTF("sqlite3_open ret:%d, msg:%s\n", ret, sqlite3_errmsg(*ppDb));sqlite3_close(*ppDb);return -1;}snprintf(sql, sizeof(sql), "create table if not exists purchase \(id int, \name char(16), \supplier char(16), \ymdhms datetime,\unit int, \num int, \sum int, \primary key(id, ymdhms));");ret = sqlite3_exec(*ppDb , sql , NULL , NULL , &err);if (ret != SQLITE_OK) {DEBUG_PRINTF("sqlite3_exec ret:%d, %s\n", ret, err);sqlite3_free(err);}return 0;
}void vDBFree(sqlite3 *pDb)
{if (pDb != NULL) {sqlite3_close(pDb);pDb = NULL;}
}/* insert data */
int iDBInsert(sqlite3 *pDb, purchase_para *pdata)
{char sql[256] = {0};char *errmsg = NULL;int ret;if (pDb == NULL || pdata == NULL) {return -1;}snprintf(sql, sizeof(sql), "insert into purchase(id, name, supplier, ymdhms, unit, num, sum) \values(%d, '%s', '%s', '%s', %d, %d, %d);", pdata->id, pdata->name, pdata->supplier, pdata->ymdhms, pdata->unit, pdata->num, pdata->sum);ret = sqlite3_exec(pDb , sql , NULL , NULL , &errmsg);if (ret != SQLITE_OK) {DEBUG_PRINTF("sqlite3_exec ret:%d, %s\n", ret, errmsg);sqlite3_free(errmsg);}return ret;
}/* modify data if id matches */
int iDBUpdateByID(sqlite3 *pDb, purchase_para *pdata)
{char sql[256] = {0};char *errmsg = NULL;int ret;if (pDb == NULL || pdata == NULL) {return -1;}snprintf(sql, sizeof(sql), "update purchase set name = '%s', supplier = '%s', ymdhms = '%s', \unit = %d, num = %d, sum = %d where id == %d;",pdata->name, pdata->supplier, pdata->ymdhms, pdata->unit, pdata->num, pdata->sum, pdata->id);ret = sqlite3_exec(pDb , sql , NULL , NULL , &errmsg);if (ret != SQLITE_OK) {DEBUG_PRINTF("sqlite3_exec ret:%d, %s\n", ret, errmsg);sqlite3_free(errmsg);}return ret;
}/* delete data if id matches */
int iDBDelByID(sqlite3 *pDb, int id)
{int ret = 0;char sql[64] = {0};char *errmsg = NULL;if (pDb == NULL) {return -1;}snprintf(sql, sizeof(sql), "delete from purchase where id == %d;vacuum;", id);ret = sqlite3_exec(pDb , sql , NULL , NULL , &errmsg);if (ret != SQLITE_OK) {DEBUG_PRINTF("<%s> sqlite3_exec ret:%d, %s\n", __func__, ret, errmsg);sqlite3_free(errmsg);}return ret;
}/* query the number of database data items */
int iDBQueryCnt(sqlite3 *pDb, int *cnt)
{int ret = 0;int row = 0;int column = 0;char **result;char sql[64] = {0};char *errmsg = NULL;snprintf(sql, sizeof(sql), "select count(*) from purchase;");ret = sqlite3_get_table(pDb , sql , &result , &row , &column , &errmsg);if (ret != SQLITE_OK) {DEBUG_PRINTF("<%s> sqlite3_exec ret:%d, %s\n", __func__, ret, errmsg);sqlite3_free(errmsg);}else {*cnt = atoi(result[1]);DEBUG_PRINTF("select successfully, row:%d, col:%d, cnt:%d\n", row, column, *cnt);		}sqlite3_free_table(result);return ret;
}/* query all data in the database */
int iDBQueryAll(sqlite3 *pDb)
{int ret = 0;int row = 0;int column = 0;int i, j;char **result;char sql[64] = {0};char *errmsg = NULL;snprintf(sql, sizeof(sql), "select * from purchase;");ret = sqlite3_get_table(pDb , sql , &result , &row , &column , &errmsg);if (ret != SQLITE_OK) {DEBUG_PRINTF("<%s> sqlite3_exec ret:%d, %s\n", __func__, ret, errmsg);sqlite3_free(errmsg);}else {DEBUG_PRINTF("select successfully, row:%d, col:%d, data:\n", row, column);for(i = 0; i <= row; i++){for(j = 0; j < column; j++){printf("%s, ", result[i * column + j]);}printf("\n");}	}sqlite3_free_table(result);return ret;
}

测试示例

static void vTestInsert(sqlite3 *pDb)
{int i;int errcnt = 0;struct tm *timeinfo = NULL;time_t time_now;purchase_para data[] = {/*{1, "pencil", "sunny", "2024-07-10 12:06:35", 2, 100, 200},*/{1, "pencil", "sunny",  "", 2,  100, 200},{2, "pen",    "sky",    "", 10, 100, 1000},{3, "eraser", "lily",   "", 1,  80,  80},{4, "ruler",   "sunny", "", 2,  200, 400},};time(&time_now);timeinfo = localtime(&time_now);for(i = 0; i < ARRAY_SIZE(data); i++){timeinfo->tm_mon = (timeinfo->tm_mon - i) % 12;strftime(data[i].ymdhms, ARRAY_SIZE(data[i].ymdhms), "%Y-%m-%d %H:%M:%S", timeinfo);if (iDBInsert(pDb, &data[i]) != 0) {errcnt++;}}DEBUG_PRINTF("insert %s\n", (errcnt == 0) ? "succ" : "fail");
}static void vTestModify(sqlite3 *pDb)
{int ret;struct tm *timeinfo = NULL;time_t time_now;purchase_para data = {3, "eraser", "lily", "", 2, 80, 160};/* change the ymdhms to the current date and time */time(&time_now);timeinfo = localtime(&time_now);strftime(data.ymdhms, ARRAY_SIZE(data.ymdhms), "%Y-%m-%d %H:%M:%S", timeinfo);/* update data */ret = iDBUpdateByID(pDb, &data);DEBUG_PRINTF("modify %s\n", (ret == 0) ? "succ" : "fail");
}int main(int argc, char* argv[])
{sqlite3 *ptrDb = NULL;int cnt = 0;int ret;if (iDBInit(&ptrDb) != 0) {return -1;}/* Query the number of database data items  */iDBQueryCnt(ptrDb, &cnt);/* Query all data in the database */iDBQueryAll(ptrDb);/* Insert some data */vTestInsert(ptrDb);/* modify data if id=3 */vTestModify(ptrDb);iDBQueryAll(ptrDb);/* delete data if id=4 */ret = iDBDelByID(ptrDb, 4);DEBUG_PRINTF("delete data %s\n", (ret == 0) ? "succ" : "fail");iDBQueryAll(ptrDb);vDBFree(ptrDb);return 0;
}

3.3 编译运行

将SQLite库编译生成的include和lib文件夹拷贝到工程目录下，编译加上-lsqlite3链接参数。编译示例如下：

运行结果：


http://www.ppmy.cn/embedded/89040.html

相关文章

屏幕比例与分辨率 响应式大屏实现的几种方式

屏幕比例与分辨率 响应式大屏实现的几种方式

一、屏幕比例&#xff1a; 屏幕比例即屏幕宽度和高度的比例&#xff0c;又名纵横比或者长宽比&#xff0c;常见的屏幕比例主要是 16:9 和 4:3 和 16:10。 其中&#xff0c;16:9是目前最为常见的屏幕比例&#xff0c;适用于电视、电脑显示器等。 (1).4:3【1.33:1】比例是最早…
阅读更多...
HDFS常用命令

HDFS常用命令

HDFS常用命令 1.HDFS命令介绍1.1基本语法格式1.2常用命令 1.HDFS命令介绍 HDFS 提供了一组命令行工具&#xff0c;用于管理和操作 HDFS 文件系统。 1.1基本语法格式 hdfs dfs -<命令> [选项] <参数>1.2常用命令 1.显示<path>指定的文件的详细信息。 had…
阅读更多...
计算机基础（Windows 10+Office 2016）教程 —— 第7章 演示文稿软件PowerPoint 2016

计算机基础（Windows 10+Office 2016）教程 —— 第7章 演示文稿软件PowerPoint 2016

第7章 演示文稿软件PowerPoint 2016 7.1 PowerPoint 2016入门7.1.1 PowerPoint 2016 简介7.1.2 PowerPoint 2016 的操作界面组成7.1.3 PowerPoint 2016 的窗口视图方式7.1.4 PowerPoint 2016 的演示文稿及其操作7.1.5 PowerPoint 2016 的幻灯片及其操作 7.2 演示文稿的编辑与设…
阅读更多...
自定义配置新纪元：Laravel配置仓库深度解析

自定义配置新纪元：Laravel配置仓库深度解析

自定义配置新纪元&#xff1a;Laravel配置仓库深度解析 Laravel框架以其优雅的架构和“约定优于配置”的理念而广受开发者喜爱。在Laravel中&#xff0c;配置文件是管理应用设置的中心方式。然而&#xff0c;随着应用的扩展&#xff0c;你可能会发现需要更灵活的配置管理策略。…
阅读更多...
头发健康知识一

头发健康知识一

头发重要性: 头发是人第二张脸,影响人容貌 形象和气质.头皮基本结构 角质层,颗粒层,有挤层,基底层4个细胞层组成,含有大量毛囊和皮脂腺和汗腺.头屑是什么? 头屑为角质细胞的新陈代谢脱落的死细胞,每天都会有十几万角质细胞脱落 (正常的代谢周期为28天). 当基底层细胞受损时…
阅读更多...
Java HashMap 源码解读笔记（二）--xunznux

Java HashMap 源码解读笔记（二）--xunznux

文章目录 HashMapputVal 插入新值方法方法解读1.7和1.8有哪些区别 resize 重新哈希方法treeifyBin 树化方法treeify 树化方法untreeify 链化方法 HashMap 本文主要是用于记录我在阅读Java1.8的 HashMap 源码所做的笔记。对于源码中的注释会进行翻译下来&#xff0c;并且会对其…
阅读更多...
充电宝有必要买贵的吗？充电宝可以带上高铁吗？充电宝选购方法

充电宝有必要买贵的吗？充电宝可以带上高铁吗？充电宝选购方法

市面上的充电宝可以说是非常的多&#xff0c;但是能选到一款适合自己的充电宝基本是不容易的&#xff0c;然而&#xff0c;当我们准备选购充电宝时&#xff0c;常常会面临诸多疑问。其中&#xff0c;“充电宝有必要买贵的吗”就是一个备受关注的问题。价格似乎成为了我们在众多…
阅读更多...
电脑自动重启是什么原因？重启原因排查和解决办法！

电脑自动重启是什么原因？重启原因排查和解决办法！

当你的电脑突然毫无预警地自动重启&#xff0c;不仅打断了工作流程&#xff0c;还可能导致未保存的数据丢失&#xff0c;这无疑令人很懊恼&#xff0c;那么&#xff0c;电脑自动重启是什么原因呢&#xff1f;有什么方法可以解决呢&#xff1f;别担心&#xff0c;在大多数情况下…
阅读更多...
最新文章

Copyright @ 2022~2023