sqlite3_exec以及回调函数的使用
#include <sqlite3.h>
#include <stdio.h>
static int callback(void *NotUsed, int argc, char **argv, char **azColName) {
for (int i = 0; i < argc; i++) {
printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
}
printf("\n");
return 0;
}
int main() {
sqlite3 *db;
char *zErrMsg = 0;
int rc;
rc = sqlite3_open("example.db", &db);
if (rc) {
fprintf(stderr, "无法打开数据库: %s\n", sqlite3_errmsg(db));
sqlite3_close(db);
return 1;
}
const char *sql = "SELECT * FROM COMPANY;";
rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
if (rc != SQLITE_OK) {
fprintf(stderr, "SQL错误: %s\n", zErrMsg);
sqlite3_free(zErrMsg);
}
sqlite3_close(db);
return 0;
}
这段代码首先定义了一个回调函数callback
,该函数会在执行sqlite3_exec
时,对于查询结果中的每一行调用。然后在main
函数中,它打开了一个名为example.db
的SQLite数据库,并执行了一个SQL查询。如果查询成功,每行数据都会通过回调函数callback
打印出来。如果有错误,它会输出错误信息,并清理数据库连接。
评论已关闭