devbox
盐析白兔
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SQLite数据库C_C++接口（保姆级API应用 1.4W字）（全网最详细介绍，学完必掌握）

作者：盐析白兔 | 2024-04-26 12:09:50

赞

踩

SQLite数据库C_C++接口（保姆级API应用 1.4W字）（全网最详细介绍，学完必掌握）

目录

sqlite3的C/C++ API应用

前言

SQLite3库安装

API函数

打开、关闭、错误处理

打开

返回值

关闭

错误调试

实际应用

执行SQL（DDL、DML）

API介绍

实际应用

回调函数查询

API介绍

实际应用

全缓冲查询

API介绍

实际应用

字节缓冲查询

API介绍

实际应用

三种查询方式总结

sqlite实现C语言自定义函数封装

sqlite3的C/C++ API应用

前言

对于主键和外键知识点的补充：

  • 主键的值不能重复，一般将自增的字段设置为主键。
    • 主键是用来唯一表示一条数据的值，不能重复的。比如，一条记录包括身份正号，姓名，年龄。身份证号是唯一能确定你这个人的，其他都可能有重复，所以，身份证号薯磨是主键。
  • 外键主要目的是控制存储在外键表中的数据。 使两张表形成关联，外键只能引用外表中的列的值或使用空值。
    • 外键用于与另一张表的关联。是能确定另一张表记录的字段，用于保持数据的一致性。比如，A表中的一个字段，是B表的主键，那他就可以是A表的外键。

SQLite3库安装

在 C/C++ 程序中使用 SQLite 之前，我们需要确保机器上已经有 SQLite 库，这个库提供了C/C++的操作SQLite的编程接口API。

  • 在linux下只需输入安装命令：sudo apt-get install libsqlite3-dev
  • QT下使用SQLite3数据库

https://www.cnblogs.com/tfanalysis/p/4073756.html

我使用的是Windows下通过vscode远程SSH访问Linux，因此需要在windows下也安装并添加相应的库文件。

安装前，我们在vscode中添加SQLite的头文件，提示找不到头文件

因此我们需要先定位头文件包含路径

然后到sqlite官网下载源码包（sqlite3的源码）

https://www.cnblogs.com/White-strategy-group/p/6360003.html

解压缩后文件内容如图所示

将三个.h文件添加到之前的includePath中："D:/myinclude/**"

我们先在目录下新建一个sqlite文件夹

然后将头文件添加进来

如果发现添加完之后仍然自动找不到头文件，如下所示

我们需要手动包含具体头文件路径，如："D:\\myinclude\\sqlite3"

我们输入sqlite3发现，可以自动提示补全，则表示库文件添加成功！

API函数

打开、关闭、错误处理

打开

第一个参数为指定要打开的数据库的名字，也包括数据库的路径

第二个参数为一个二级指针，这里的作用相当于文件描述符，它是一个数据库文件指针。传入的是一个一级指针的地址作为输出，给指针的具体指向赋值（定义一个空指针传入过来，最终会给这个指针赋值）（通过操作数据库文件指针就相对于操作数据库）

返回值

SQLite3的C/C++接口函数所有返回值如下:

  1. #define SQLITE_OK 0 /* Successful result */
  2. #define SQLITE_ERROR 1 /* SQL error or missing database */
  3. #define SQLITE_INTERNAL 2 /* An internal logic error in SQLite */
  4. #define SQLITE_PERM 3 /* Access permission denied */
  5. #define SQLITE_ABORT 4 /* Callback routine requested an abort */
  6. #define SQLITE_BUSY 5 /* The database file is locked */
  7. #define SQLITE_LOCKED 6 /* A table in the database is locked */
  8. #define SQLITE_NOMEM 7 /* A malloc() failed */
  9. #define SQLITE_READONLY 8 /* Attempt to write a readonly database */
  10. #define SQLITE_INTERRUPT 9 /* Operation terminated by sqlite_interrupt() */
  11. #define SQLITE_IOERR 10 /* Some kind of disk I/O error occurred */
  12. #define SQLITE_CORRUPT 11 /* The database disk image is malformed */
  13. #define SQLITE_NOTFOUND 12 /* (Internal Only) Table or record not found */
  14. #define SQLITE_FULL 13 /* Insertion failed because database is full */
  15. #define SQLITE_CANTOPEN 14 /* Unable to open the database file */
  16. #define SQLITE_PROTOCOL 15 /* Database lock protocol error */
  17. #define SQLITE_EMPTY 16 /* (Internal Only) Database table is empty */
  18. #define SQLITE_SCHEMA 17 /* The database schema changed */
  19. #define SQLITE_TOOBIG 18 /* Too much data for one row of a table */
  20. #define SQLITE_CONSTRAINT 19 /* Abort due to contraint violation */
  21. #define SQLITE_MISMATCH 20 /* Data type mismatch */
  22. #define SQLITE_MISUSE 21 /* Library used incorrectly */
  23. #define SQLITE_NOLFS 22 /* Uses OS features not supported on host */
  24. #define SQLITE_AUTH 23 /* Authorization denied */
  25. #define SQLITE_ROW 100 /* sqlite_step() has another row ready */
  26. #define SQLITE_DONE 101 /* sqlite_step() has finished executing */
关闭

错误调试

返回错误信息

返回值错误码

实际应用
  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3.  
  4. int main(int argc, char const *argv[])
  5. {
  6.     sqlite3 *db;
  7.     int ret = sqlite3_open(argv[1],&db);
  8.  
  9.     if(ret != SQLITE_OK)
  10.     {
  11.         printf("sqlite3 open:%s\n",sqlite3_errmsg(db));
  12.         exit(-1);
  13.     }
  14.  
  15.     printf("sqlite open db successfully!\n");
  16.  
  17.     sqlite3_close(db);
  18.     return 0;
  19. }

编译的时候，不能直接编译

我们需要像使用POSIX库一样，手动链接sqlite3库

运行结果：

但是该函数有个bug，即使不传任何参数，也不会报错

因此最好添加一个命令行传参判断

  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3.  
  4. int main(int argc, char const *argv[])
  5. {
  6.     if(argc != 2)
  7.     {
  8.         printf("Please input db name!\n");
  9.         exit(-1);
  10.     }
  11.  
  12.     sqlite3 *db;
  13.     int ret = sqlite3_open(argv[1],&db);
  14.  
  15.     if(ret != SQLITE_OK)
  16.     {
  17.         printf("sqlite3 open:%s\n",sqlite3_errmsg(db));
  18.         exit(-1);
  19.     }
  20.  
  21.     printf("sqlite open db successfully!\n");
  22.  
  23.     sqlite3_close(db);
  24.     return 0;
  25. }

执行SQL（DDL、DML）

API介绍

执行SQL语句函数，该函数一共有5个参数

参数1：数据库文件句柄

参数2：要执行的SQL语句

参数3：回调函数，传入一个函数指针（这里的sqlite_callback callback中的sqlite_callback是通过函数指针重命名的，如下图所示）。注：回调函数只对SQL查询语句有效。当指定的是一个非查询操作，该参数应该置为NULL，否则即使传入了回调函数，回调函数也不会被执行。

参数4：回调函数的参数

参数5：保存执行SQL后的错误信息，传入的是一级指针的地址

实际应用

我们首先创建一个学生表，其中我们对错误检查进行了二次封装

  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3. #include <string.h>
  4. #include <stdlib.h>
  5.  
  6. void print_error(int ret, char *err, sqlite3 *db)
  7. {
  8.     if(ret != SQLITE_OK)
  9.     {
  10.         printf("%s:%s\n",err,sqlite3_errmsg(db));
  11.         exit(-1);
  12.     }
  13. }
  14.  
  15. int main(int argc, char const *argv[])
  16. {
  17.     if(argc != 2)
  18.     {
  19.         printf("Please input db name!\n");
  20.         exit(-1);
  21.     }
  22.  
  23.     sqlite3 *db;
  24.     char *errmsg;
  25.     char sql[1024] = {0};
  26.     int ret = sqlite3_open(argv[1],&db);
  27.  
  28.     print_error(ret,"sqlite open",db);
  29.  
  30.     printf("sqlite open db successfully!\n");
  31.  
  32.     strcpy(sql,"create table student(id integer primary key, name text, age integer)");
  33.     
  34.     ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
  35.  
  36.     print_error(ret,"sqlite exec create table",db);
  37.  
  38.     printf("create table successfully\n");
  39.  
  40.     sqlite3_close(db);
  41.     return 0;
  42. }

然后通过键盘输入的方式往表里插入三条数据

  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3. #include <string.h>
  4. #include <stdlib.h>
  5.  
  6. void print_error(int ret, char *err, sqlite3 *db)
  7. {
  8.     if(ret != SQLITE_OK)
  9.     {
  10.         printf("%s:%s\n",err,sqlite3_errmsg(db));
  11.         exit(-1);
  12.     }
  13. }
  14.  
  15. int main(int argc, char const *argv[])
  16. {
  17.     if(argc != 2)
  18.     {
  19.         printf("Please input db name!\n");
  20.         exit(-1);
  21.     }
  22.  
  23.     sqlite3 *db;
  24.     char *errmsg;
  25.     char sql[1024] = {0};
  26.  
  27.     int id;
  28.     char name[20];
  29.     int age;
  30.  
  31.     int ret = sqlite3_open(argv[1],&db);
  32.  
  33.     print_error(ret,"sqlite open",db);
  34.  
  35.     printf("sqlite open db successfully!\n");
  36.  
  37.     strcpy(sql,"create table if not exists student(id integer primary key, name text, age integer)");
  38.     
  39.     ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
  40.  
  41.     print_error(ret,"sqlite exec create table",db);
  42.  
  43.     printf("create table successfully\n");
  44.  
  45.     //插入3行数据：id,name,age 键盘输入
  46.     for(int i=0;i<3;i++)
  47.     {
  48.         printf("Please input id:\n");
  49.         scanf("%d",&id);
  50.  
  51.         printf("Please input name:\n");
  52.         scanf("%s",name);
  53.  
  54.         printf("Please input age:\n");
  55.         scanf("%d",&age);
  56.  
  57.         //sql:insert into student(id,name,age)values();
  58.         //sprint();写入到字符串 fprintf();写入到文件
  59.         memset(sql,0,sizeof(sql));
  60.         sprintf(sql,"insert into student(id,name,age)values(%d,'%s',%d)",id,name,age);
  61.         ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
  62.         print_error(ret,"sqlite exec create table",db);
  63.     }
  64.  
  65.     sqlite3_close(db);
  66.     return 0;
  67. }

如果我们想要删除zhangsan的数据，可以使用如下

  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3. #include <string.h>
  4. #include <stdlib.h>
  5. #define DELETE_DATA 1
  6. #define INSERT_DATA 0
  7. void print_error(int ret, char *err, sqlite3 *db)
  8. {
  9.     if(ret != SQLITE_OK)
  10.     {
  11.         printf("%s:%s\n",err,sqlite3_errmsg(db));
  12.         exit(-1);
  13.     }
  14. }
  15.  
  16. int main(int argc, char const *argv[])
  17. {
  18.     if(argc != 2)
  19.     {
  20.         printf("Please input db name!\n");
  21.         exit(-1);
  22.     }
  23.  
  24.     sqlite3 *db;
  25.     char *errmsg;
  26.     char sql[1024] = {0};
  27.  
  28.     int id;
  29.     char name[20];
  30.     int age;
  31.  
  32.     int ret = sqlite3_open(argv[1],&db);
  33.  
  34.     print_error(ret,"sqlite open",db);
  35.  
  36.     printf("sqlite open db successfully!\n");
  37.  
  38.     strcpy(sql,"create table if not exists student(id integer primary key, name text, age integer)");
  39.     
  40.     ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
  41.  
  42.     print_error(ret,"sqlite exec create table",db);
  43.  
  44.     printf("create table successfully\n");
  45.  
  46. #if INSERT_DATA
  47.     //插入3行数据：id,name,age 键盘输入
  48.     for(int i=0;i<3;i++)
  49.     {
  50.         printf("Please input id:\n");
  51.         scanf("%d",&id);
  52.  
  53.         printf("Please input name:\n");
  54.         scanf("%s",name);
  55.  
  56.         printf("Please input age:\n");
  57.         scanf("%d",&age);
  58.  
  59.         //sql:insert into student(id,name,age)values();
  60.         //sprint();写入到字符串 fprintf();写入到文件
  61.         memset(sql,0,sizeof(sql));
  62.         sprintf(sql,"insert into student(id,name,age)values(%d,'%s',%d)",id,name,age);
  63.         ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
  64.         print_error(ret,"sqlite exec create table",db);
  65.     }
  66. #endif
  67.  
  68. #if DELETE_DATA
  69.     printf("Please input who do you want to delete:\n");
  70.     memset(sql,0,sizeof(sql));
  71.     memset(name,0,sizeof(name));
  72.     scanf("%s",name);
  73.     sprintf(sql,"delete from student where name = '%s'",name);
  74.     ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
  75.     print_error(ret,"sqlite exec delete data",db);
  76. #endif
  77.     sqlite3_close(db);
  78.     return 0;
  79. }

注：SQLite库提供的是原生态的接口，我们可以对其进行二次封装，像之前错误检查那样，对sqlite3_exec要执行的SQL语句，进行封装，避免代码的冗余。

回调函数查询

API介绍

每查询到一条结果就会回调一次这个函数，通过一行行缓冲数据，每次缓冲一行。

参数1：传入的参数

参数2：保存查询到的结果每一行中列的个数

参数3：保存查询到数据中每一列的值，用一个指针数组（保存指针的数组，本质是数组）来接

参数4：保存每一列的字段名字，用一个指针数组来接

实际应用

以打印查询到的结果每行列数为例：如果回调函数不加return 0;，那么将只执行一次

将上return 0;，才可以执行全部

如果想要打印查询到的每一列结果

再加上每一列相应的字段名

注意：对于外部传入回调函数的参数是无法修改的（具体原因可能是由于内部机制）

如：我们传入一个flag变量，然后出函数打印结果

我们在回调函数内对flag进行++

但出函数之后，值仍是0

如果查询不到结果，将会什么信息也不会输出

我们可以通过定义一个全局变量标志位进行判断，是否查询到数据

  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3. #include <stdlib.h>
  4. #include <string.h>
  5.  
  6. int flag=0;
  7.  
  8. void print_error(int ret, char *err, sqlite3 *db)
  9. {
  10.     if(ret != SQLITE_OK)
  11.     {
  12.         printf("%s:%s\n",err,sqlite3_errmsg(db));
  13.         exit(-1);
  14.     }
  15.     printf("%s:successfully!\n",err);
  16. }
  17.  
  18. int my_sqlite_callback(void *para,int columnCount,char **columnValue,char**columnName)
  19. {
  20.     printf("columnCount = %d\n", columnCount);
  21.     flag=1;
  22.     for(int i = 0; i < columnCount;i++)
  23.     {
  24.         printf("%s:%s|",columnName[i],columnValue[i]);
  25.     }
  26.     printf("\n");
  27.     return 0;
  28. }
  29.  
  30. int main(int argc, char const *argv[])
  31. {
  32.     if(argc != 2)
  33.     {
  34.         printf("Please input db name!\n");
  35.         exit(-1);
  36.     }
  37.  
  38.     sqlite3 *db;
  39.     char *errmsg;
  40.     char sql[1024] = {0};
  41.  
  42.     int ret = sqlite3_open(argv[1],&db);
  43.  
  44.     print_error(ret,"sqlite open",db);
  45.  
  46.     printf("sqlite open db successfully!\n");
  47.  
  48.  
  49.     strcpy(sql,"select * from student where name = 'zhangsan'");
  50.     sqlite3_exec(db,sql,my_sqlite_callback,NULL,&errmsg);
  51.     print_error(ret,"select",db);
  52.     if(flag==0)
  53.     {
  54.         printf("The data queried is empty!\n");
  55.     }
  56.     sqlite3_close(db);
  57.     return 0;
  58. }

全缓冲查询

API介绍

与sqlite_exec不同，sqlite3_get_table是专门用于查询数据的，通过一次性将所有查询到的数据缓冲起来

参数1：数据库文件句柄

参数2：数据库SQL语句

参数3：三维指针，用于保存查询到的结果

参数4：查询到的结果总共的行数

参数5：查询到的结果总共的列数

参数6：保存查询出错的信息

以三维指针为例，我们可以创建一个变相的二维数组：

可以想象创建一个长方体

char ***result;

result = (char***)malloc(sizeof(char**)*4);创建四个存储空间

*result = (char**)malloc(sizeof(char*)*4);每个存储空间里再创建四个存储空间

**result = (char*)malloc(sizeof(char)*4);每个存储空间里再创建一个字符串数组

最终在逻辑上形成16个连续的存储空间（物理上不连续）

我们可以通过三次for循环来创建

但访问方式仍是一维数组的访问方式，因为通过指针创建的空间，本质还是链式的，不是真正的多维数组

实际应用

实际使用时，我们需要定义一个二维指针，将它的地址作为参数传入，查询到的数据都将保存在二维指针中

发现打印是从字段开始打印的，最后少了一行数据，这是因为保存的数据包括了字段那一行，但是返回的行数nrow只算了实际数据的行数

因此需要改正如下：

这样输出的结果就是正确的了

最后一定要记得调用释放空间函数sqlite3_free_table，因为库函数sqlite3_get_table的内部分配了堆区空间

全缓冲查询程序如下：

  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3. #include <stdlib.h>
  4. #include <string.h>
  5.  
  6. void print_error(int ret, char *err, sqlite3 *db)
  7. {
  8.     if(ret != SQLITE_OK)
  9.     {
  10.         printf("%s:%s\n",err,sqlite3_errmsg(db));
  11.         exit(-1);
  12.     }
  13.     printf("%s:successfully!\n",err);
  14. }
  15.  
  16.  
  17. int main(int argc, char const *argv[])
  18. {
  19.     if(argc != 2)
  20.     {
  21.         printf("Please input db name!\n");
  22.         exit(-1);
  23.     }
  24.  
  25.     sqlite3 *db;
  26.     char *errmsg;
  27.     char sql[1024] = {0};
  28.  
  29.     int ret = sqlite3_open(argv[1],&db);
  30.  
  31.     print_error(ret,"sqlite open",db);
  32.  
  33.     printf("sqlite open db successfully!\n");
  34.  
  35.     char **result;
  36.     int nrow;
  37.     int ncolumn;
  38.     strcpy(sql,"select * from student");
  39.     ret = sqlite3_get_table(db,sql,&result,&nrow,&ncolumn,&errmsg);
  40.     print_error(ret,"select",db);
  41.  
  42.     for(int i = 1; i<=nrow; i++)
  43.     {
  44.         for(int j = 0; j < ncolumn; j++)
  45.         {
  46.             printf("%s|",result[i*ncolumn+j]);
  47.         }
  48.         printf("\n");
  49.     }
  50.  
  51.     sqlite3_free_table(result);
  52.     sqlite3_close(db);
  53.     return 0;
  54. }

字节缓冲查询

API介绍

sqlite3_prepare

作用：把SQL语句转成字节码，由后面的执行函数去执行，将查询到的数据做字节缓冲

参数1：数据库文件句柄

参数2：SQL语句

参数3：SQL语句的最大字节数，一般设为-1

参数4：Statement句柄，即字节序句柄

参数5：SQL语句无用部分的指针，一般设为NULL

字节缓冲查询还涉及到了以下函数：

  • sqlite3_step：从第一行开始查询，每次查询一行，每调用一次该函数会继续查询下一行数据，数据不为空则返回SQLITE_ROW

  • sqlite3_column_count：获取结果的列数

  • sqlite3_column_text：获取程序的结果当前行中每一列的数据

  • sqlite3_finalize：用于销毁字节序句柄

实际应用
  1. #include <stdio.h>
  2. #include <sqlite3.h>
  3. #include <stdlib.h>
  4. #include <string.h>
  5.  
  6. void print_error(int ret, char *err, sqlite3 *db)
  7. {
  8.     if(ret != SQLITE_OK)
  9.     {
  10.         printf("%s:%s\n",err,sqlite3_errmsg(db));
  11.         exit(-1);
  12.     }
  13.     printf("%s:successfully!\n",err);
  14. }
  15.  
  16.  
  17. int main(int argc, char const *argv[])
  18. {
  19.     if(argc != 2)
  20.     {
  21.         printf("Please input db name!\n");
  22.         exit(-1);
  23.     }
  24.  
  25.     sqlite3 *db;
  26.     char *errmsg;
  27.     char sql[1024] = {0};
  28.  
  29.     int ret = sqlite3_open(argv[1],&db);
  30.  
  31.     print_error(ret,"sqlite open",db);
  32.  
  33.     printf("sqlite open db successfully!\n");
  34.  
  35.     
  36.     int rc,i,j;
  37.     int ncolumn;
  38.     sqlite3_stmt *stmt;
  39.     strcpy(sql,"select * from student");
  40.  
  41.     rc = sqlite3_prepare(db,sql,-1,&stmt,NULL);
  42.     if(rc)
  43.     {
  44.         printf("query fail!\n");
  45.     }
  46.     else
  47.     {
  48.         printf("query success!\n");
  49.         rc = sqlite3_step(stmt);//查询成功，则返回值rc==SQLITE_ROW
  50.         ncolumn = sqlite3_column_count(stmt);//获取列数
  51.         while(rc == SQLITE_ROW)
  52.         {
  53.             for(i = 0;i<ncolumn;i++)
  54.             {
  55.                 printf("%s|",sqlite3_column_text(stmt,i));//获取每一列的数据
  56.             }
  57.             printf("\n");
  58.             rc = sqlite3_step(stmt);//继续获取下一行数据
  59.         }
  60.     }
  61.     sqlite3_finalize(stmt);
  62.     sqlite3_close(db);
  63.     return 0;
  64. }

三种查询方式总结

回调函数查询内存开销小，但查询效率相对较低；全缓冲查询的查询效率高，但是内存消耗大；字节缓冲查询兼具查询效率和低开销。（优先使用第三种查询方法）

sqlite实现C语言自定义函数封装

由于数据库提供的API接口过于复杂，使用的过程顺序也很繁琐，所以对于原生态的API在实际工作开发中，会进行一层封装，减少调用传参，减少调用次数，增加代码可读性，提高开发效率。

可封装如下：包括创建数据库、建表、插入数据、查询数据、删除数据

database.h

  1. #ifndef _DATABASE_H_
  2. #define _DATABASE_H_
  3.  
  4. #include <stdio.h>
  5. #include <string.h>
  6. #include <unistd.h>
  7. #include <stdlib.h>
  8. #include <errno.h>
  9. #include <libgen.h>
  10. #include <sqlite3.h>
  11.  
  12. extern int open_database(sqlite3 **db,char *database_name);
  13. extern int create_table(sqlite3 **db,char *table_name,char *table_attribute);
  14. extern int insert_data(sqlite3 **db,char *table_name,char *attr,char *msg);
  15. extern int query_data(sqlite3 **db,char ***azResult,char *table_name);
  16. extern int delete_data(sqlite3 **db,char *table_name);
  17.  
  18. #endif

 database.c

  1. #include "database.h"
  2.  
  3. char            sql[128];
  4. char            *zErrMsg=NULL;
  5. int             nrow=0;
  6. int             ncolumn = 0;
  7.  
  8.  
  9. int open_database(sqlite3 **db,char *database_name)
  10. {
  11.         int             len;
  12.  
  13.         len = sqlite3_open(database_name,db);
  14.         if(len)
  15.         {
  16.                 printf("Open database name %s failure.\n",database_name);
  17.                 sqlite3_close(*db);
  18.                 return -1;
  19.         }
  20.         printf("Open a sqlite3 database name %s successfully!\n",database_name);
  21.  
  22.         return 0;
  23. }
  24.  
  25. int create_table(sqlite3 **db,char *table_name,char *table_attribute)
  26. {
  27.  
  28.  
  29.         snprintf(sql,sizeof(sql),"CREATE TABLE %s(%s);",table_name,table_attribute);
  30.         //log_info("sql=%s\n",sql);
  31.  
  32.         //sql="CREATE TABLE test(TEST CHAR(100));";
  33.  
  34.         if(sqlite3_exec(*db,sql,NULL,NULL,&zErrMsg)!=SQLITE_OK)
  35.         {
  36.                 printf("Table %s already exist\n",table_name);
  37.         }
  38.         else
  39.         {
  40.                 printf("Create table %s successfully\n",table_name);
  41.         }
  42.  
  43. }
  44.  
  45. int insert_data(sqlite3 **db,char *table_name,char *attr,char *msg)
  46. {
  47.         snprintf(sql,sizeof(sql),"INSERT INTO %s(%s) VALUES('%s');",table_name,attr,msg);   //插入数据
  48.  
  49.         if(sqlite3_exec(*db,sql,NULL,NULL,&zErrMsg)!=SQLITE_OK)
  50.         {
  51.                 sqlite3_close(*db);
  52.                 printf("Insert %s to table %s failure:%s\n",msg,table_name,strerror(errno));
  53.                 return -1;
  54.         }
  55.         printf("Insert %s to table %s successfully\n",msg,table_name);
  56.  
  57.         return 0;
  58. }
  59.  
  60.  
  61. int query_data(sqlite3 **db,char ***azResult,char *table_name)
  62. {
  63.         snprintf(sql,sizeof(sql),"select *from %s;",table_name);
  64.         //sql="select *from test";
  65.  
  66.         if(sqlite3_get_table(*db,sql,azResult,&nrow,&ncolumn,&zErrMsg)!=SQLITE_OK)
  67.         {
  68.                 sqlite3_close(*db);
  69.                 printf("Select *from %s failure\n",table_name);
  70.                 return -1;
  71.         }
  72.         printf("There are %d pieces of data in table %s\n",nrow,table_name);
  73.  
  74.         return nrow;
  75. }
  76.  
  77. int delete_data(sqlite3 **db,char *table_name)
  78. {
  79.         snprintf(sql,sizeof(sql),"delete from %s;",table_name);
  80.         //sql="delete from test";
  81.  
  82.         if(sqlite3_exec(*db,sql,NULL,NULL,&zErrMsg)!=SQLITE_OK)
  83.         {
  84.                 sqlite3_close(*db);
  85.                 printf("Delete from %s failure\n",table_name);
  86.                 return -1;
  87.         }
  88.         printf("Delete data from table %s successfully!\n",table_name);
  89.  
  90.         return 0;
  91. }

test_database.c

  1. #include "database.h"
  2.  
  3.  
  4. int main(void)
  5. {
  6.         sqlite3 *db;
  7.         char    **azResult=NULL;
  8.  
  9.         if( open_database(&db,"test.db")<0 )
  10.                 return -1;
  11.  
  12.         if( create_table(&db,"test","TEST CHAR(100)")<0 )
  13.                 return -2;
  14.  
  15.         if( insert_data(&db,"test","TEST","Test nihao")<0 )
  16.                 return -3;
  17.  
  18.         if( query_data(&db,&azResult,"test")<0 )
  19.                 return -4;
  20.  
  21.         if( delete_data(&db,"test")<0 )
  22.                 return -5;
  23.  
  24.         if( query_data(&db,&azResult,"test")<0 )
  25.                 return -6;
  26.  
  27.         return 0;
  28. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/490876
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号