5分钟学会SQLite中的exec接口与回调

2022年8月10日 365点热度 0人点赞 0条评论

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;}