SQLite接口与回调:深入理解

发表时间: 2021-06-22 21:03

1、SQLite接口


1.1 open


SQLITE_API int sqlite3_open(  const char *filename,   /* Database filename (UTF-8) */  sqlite3 **ppDb          /* OUT: SQLite db handle */);


1.2 exec


SQLITE_API int sqlite3_exec(  sqlite3*,                                  /* An open database */  const char *sql,                           /* SQL to be evaluated */  int (*callback)(void*,int,char**,char**),  /* Callback function */  void *,                                    /* 1st argument to callback */  char **errmsg                              /* Error msg written here */);


1.3 close


SQLITE_API int sqlite3_close(sqlite3*);


2、exec中的回调函数


本文主要说的是SQLite中的exec接口与回调,先看exec中的参数。


  • sqlite3* 为open函数打开的数据库返回的句柄
  • const char *sql 为SQL语句
  • int (*callback)(void*,int,char**,char**) 回调函数,通常用来接收SQL语句查询到的数据
  • void *, 这个参数作为回调函数中的第一个参数
  • char **errmsg 如果执行过程中错,就会写到这里


int callback(void* data, int argc, char** argv, char** azColName)


例如我现在有一个数据库,如下图:



首先callback并不只是执行一次exec就会调用一次callback函数,而是根据查询到的结果决定,假如满足SQL语句的结果有100行,则会调用100次回调函数,每一次回调函数用来获取一行记录,后面的测试例程也可以看到。


如上表,我要查询ID为1的记录,callback函数的第一个参数为用户传入的参数即exec函数的第四个参数,第二个参数为查询到的结果中有多少个字段(列),在上表中数量就是4,第三个参数为该字段的值,即(1,Robin,96.0,28),第四个参数为字段名,即(ID,Name,Grade,Age),通过这三个参数刚好可以获取一行数据。获得的数据通过第一个参数传出去。


3、例程代码


下面的代码就是查询上图表中所有的记录,并将数据打印出来


#include <stdio.h>#include <stdlib.h>#include "sqlite3.h"static int callback(void* data, int argc, char** argv, char** azColName) {    int i;    fprintf(stderr, "%s: ", (const char*)data);    for (i = 0; i < argc; i++) {        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");    }    printf("\n");    return 0;}int main(int argc, char* argv[]) {    sqlite3* db;    char* zErrMsg = 0;    int rc;    char* sql;    const char* data = "Callback function called";    /* Open database */    rc = sqlite3_open("typedef.db", &db);    if (rc) {        fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));        exit(0);    } else {        fprintf(stderr, "Opened database successfully\n");    }    /* Create SQL statement */    sql = "SELECT * from typedef";    /* Execute SQL statement */    rc = sqlite3_exec(db, sql, callback, (void*)data, &zErrMsg);    if (rc != SQLITE_OK) {        fprintf(stderr, "SQL error: %s\n", zErrMsg);        sqlite3_free(zErrMsg);    } else {        fprintf(stdout, "Operation done successfully\n");    }    sqlite3_close(db);    return 0;}


执行结果如下


都读到这里了,点个关注不迷路