操作数据库的API

API官方地址：操作数据库的API

打开数据库

首先要加入头文件
#include "sqlite3.h"

int sqlite3_open(const char *filename,   //数据库的路径sqlite3 **ppDb          //sqlite数据库句柄，二级指针
);
返回值：
成功：SQLITE_OK
失败：将返回错误代码

int main()
{// 创建句柄sqlite3 *DB;// 打开数据库int ret = sqlite3_open("./data.db", &DB);if (ret != SQLITE_OK){printf("数据库打开失败！\n");return -1;}return 0;
}
gcc 17.c sqlite3.c -o main -lpthread -ldl  //文件运行后缀  -lpthread -ldl

关闭数据库

int sqlite3_close(sqlite3*);
参数：
sqlite3*：打开数据库的句柄指针
返回值：
成功：SQLITE_OK
失败：错误代码
------------------------------------------
//关闭数据库ret = sqlite3_close(DB);if(ret!=SQLITE_OK){printf("数据库关闭失败！\n");return -1;}

执行sql语句

执行（sqlite3_exec）

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 */
);
参数：sqlite3*：打开数据库的句柄const char *sql：需要执行的sql语句int (*callback)(void*,int,char**,char**)：回调函数 NULLvoid *：给回调函数提供参数 NULLchar **errmsg ：错误信息 NULL如果sql语句是查询语句，则需要回调函数获取数据，非查询语句可以直接写NULL
int (*callback)(void* arg,int col,char** str,char** name)参数：void* arg：提供的参数 int col：返回结果有多少列char** str：字段列对应的数据char** name：对应的字段名

查询（sqlite3_get_table）

int sqlite3_get_table(sqlite3 *db,          /* An open database */const char *zSql,     /* SQL to be evaluated */char ***pazResult,    /* Results of the query */int *pnRow,           /* Number of result rows written here */int *pnColumn,        /* Number of result columns written here */char **pzErrmsg       /* Error msg written here */
);
参数：sqlite3 *db：数据库句柄const char *zSql：需要执行的sql语句char ***pazResult：返回查询的结果int *pnRow：结果的行数int *pnColumn：结果的列数char **pzErrmsg：错误信息  NULL

注意：主要记住这里的两级三级指针，传参

查询有两种方法，可以参考以下代码

#include <stdio.h>
#include "sqlite3.h"// 建表
int create_table(sqlite3 *DB)
{char *sql = "create table if not exists students(name text unique,age int)";int ret = sqlite3_exec(DB, sql, NULL, NULL, NULL);if (ret != SQLITE_OK){printf("建表失败！\n");return -1;}
}
// 新增数据
int add_data(sqlite3 *DB)
{char name[20] = {0};int age = 0;char bufsql[100] = {0}; // 保存sql语句printf("请输入姓名年龄：");scanf("%s %d", name, &age);sprintf(bufsql, "insert into students values('%s',%d)", name, age);int ret = sqlite3_exec(DB, bufsql, NULL, NULL, NULL);if (ret != SQLITE_OK){printf("插入数据失败！\n");return -1;}
}
// 删除数据
int delete_data(sqlite3 *DB)
{char name[20] = {0};char bufsql[100] = {0}; // 保存sql语句printf("请输入要删除的数据：");scanf("%s", name);sprintf(bufsql, "delete from students where name='%s'", name);int ret = sqlite3_exec(DB, bufsql, NULL, NULL, NULL);
}
// 回调函数
int callback(void *arg, int col, char **str, char **name)
{for (int i = 0; i < col; ++i){printf("name[%d]:data[%d]==>%s,%s\n", i, i, name[i], str[i]);}return 0; // 注意，查询成功要返回0，否则只能查出一条数据
}
// 查询数据
int show_data(sqlite3 *DB)
{char bufsql[100] = "select * from students";int ret = sqlite3_exec(DB, bufsql, callback, NULL, NULL);if (ret != SQLITE_OK){printf("查询失败！\n");return -1;}return 0;
}
// 查询第二种方法
int show_data2(sqlite3 *DB)
{char **Result;int row, col;int ret = sqlite3_get_table(DB, "select * from students", &Result, &row, &col, NULL);if (ret != SQLITE_OK){printf("查询失败！\n");return -1;}else{printf("获取到sql语句的行和列的数量：%d %d\n", row, col);for (int i = 0; i < (row + 1) * col; i += 2){printf("%s %s\n", Result[i], Result[i + 1]);}}
}
int main()
{// 创建句柄sqlite3 *DB;// 打开数据库int ret = sqlite3_open("../db/stuinfo.db", &DB);if (ret != SQLITE_OK){printf("数据库打开失败！\n");return -1;}// 建表create_table(DB);// // 加入数据add_data(DB);// // 删除数据delete_data(DB);// 查询数据show_data2(DB);int res = sqlite3_close(db);if (res != SQLITE_OK){printf("close db failed\n");return -1;}return 0;
}