操作数据库的API

操作数据库的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**)：回调函数 NULL
 void *：给回调函数提供参数 NULL
 char **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;
}