当前位置: 首页 > news >正文

sqlite创建数据库,创建表,插入数据,查询数据的C++ demo

sqlite的API可参考:SQLite – C/C++ | 菜鸟教程

sqlite的官网API可参考:Introduction

#include <iostream>
#include <sqlite3.h>
#include <string>// 回调函数,用于查询结果的输出
static int callback(void* data, int argc, char** argv, char** azColName) {// 第一次调用时输出表名static bool firstCall = true;static std::string tableName = reinterpret_cast<const char*>(data);if (firstCall) {std::cout << "\n表名: " << tableName << std::endl;std::cout << "--------------------------------" << std::endl;// 输出列名for (int i = 0; i < argc; i++) {std::cout << azColName[i] << "\t";}std::cout << "\n--------------------------------" << std::endl;firstCall = false;}// 输出数据行for (int i = 0; i < argc; i++) {std::cout << (argv[i] ? argv[i] : "") << "\t";}std::cout << std::endl;return 0;
}int main() {sqlite3* db;char* errMsg = nullptr;int rc;// 1. 打开或创建数据库rc = sqlite3_open("demo.db", &db);if (rc) {std::cerr << "无法打开数据库: " << sqlite3_errmsg(db) << std::endl;return rc;}std::cout << "成功打开/创建数据库 demo.db" << std::endl;// 2. 创建表const char* createTableSQL ="CREATE TABLE IF NOT EXISTS Users (""ID INTEGER PRIMARY KEY AUTOINCREMENT,""Name TEXT NOT NULL,""Age INTEGER,""Email TEXT UNIQUE NOT NULL);";rc = sqlite3_exec(db, createTableSQL, nullptr, nullptr, &errMsg);printf("%s\n",createTableSQL);if (rc != SQLITE_OK) {std::cerr << "SQL错误: " << errMsg << std::endl;sqlite3_free(errMsg);} else {std::cout << "表 Users 创建成功或已存在" << std::endl;}// 3. 插入数据const char* insertDataSQL ="INSERT INTO Users (Name, Age, Email) VALUES ""('张三', 25, 'zhangsan@example.com'),""('李四', 30, 'lisi@example.com'),""('王五', 28, 'wangwu@example.com');";rc = sqlite3_exec(db, insertDataSQL, nullptr, nullptr, &errMsg);if (rc != SQLITE_OK) {std::cerr << "SQL错误: " << errMsg << std::endl;sqlite3_free(errMsg);} else {std::cout << "成功插入 3 条数据到 Users 表" << std::endl;}// 4. 查询数据std::string tableName = "Users";const char* selectDataSQL = "SELECT * FROM Users;";std::cout << "\n正在查询数据..." << std::endl;rc = sqlite3_exec(db, selectDataSQL, callback, const_cast<char*>(tableName.c_str()), &errMsg);if (rc != SQLITE_OK) {std::cerr << "SQL错误: " << errMsg << std::endl;sqlite3_free(errMsg);}// 5. 关闭数据库sqlite3_close(db);std::cout << "\n数据库连接已关闭" << std::endl;return 0;
}

CMake如下:

cmake_minimum_required(VERSION 3.5)project(testDB LANGUAGES CXX)set(CMAKE_CXX_STANDARD 11)
set(CMAKE_CXX_STANDARD_REQUIRED ON)add_executable(testDB main.cpp)
target_link_libraries(testDB sqlite3)

运行结果如下:

sqlite3_exec函数介绍

sqlite3_exec() 是 SQLite C 接口中的一个便捷函数,用于执行一个或多个 SQL 语句,并可选择性地处理查询结果。它是 sqlite3_prepare_v2()sqlite3_step() 和 sqlite3_finalize() 的封装,适合执行不需要复杂处理的 SQL 命令。


函数原型

int sqlite3_exec(
sqlite3 *db, /* 数据库连接对象 */
const char *sql, /* 要执行的 SQL 语句 */
int (*callback)( /* 回调函数,处理查询结果 */
void*, /* 回调函数的第一个参数(由sqlite3_exec的第四个参数传入) */
int, /* 结果行的列数 */
char**, /* 当前行的数据数组 */
char** /* 列名数组 */
),
void *data, /* 传递给回调函数的第一个参数 */
char **errmsg /* 错误信息(需手动释放) */
);

参数详解

1. db
  • 类型sqlite3*
  • 作用: 已打开的数据库连接对象(通过 sqlite3_open() 获得)。
  • 注意: 如果为 `` 或无效连接,函数返回 SQLITE_MISUSE
2. sql
  • 类型const char*
  • 作用: 要执行的 SQL 语句,可以是单个语句或多个语句(用分号 ; 分隔)。
  • 示例:

    sql

    "CREATE TABLE test (id INTEGER); INSERT INTO test VALUES (1);"
  • 注意:
    • 如果 SQL 有语法错误,sqlite3_exec() 会返回错误码,并通过 errmsg 返回错误信息。
    • 不支持参数绑定(如 ? 或 :name),需直接拼接 SQL 字符串(需注意 SQL 注入风险)。
3. callback
  • 类型: 函数指针 int (*callback)(void*, int, char**, char**)
  • 作用: 处理查询结果的回调函数。对 SELECT 查询的每一行结果调用一次;对 INSERT/UPDATE/DELETE 等操作不调用(除非返回影响行数)。
  • 回调函数参数:
    • void* data: 由 sqlite3_exec 的第四个参数 data 传入(通常用于传递上下文)。
    • int argc: 当前行的列数。
    • char** argv: 当前行的数据数组(argv[i] 是第 i 列的值,字符串形式)。
    • char** azColName: 列名数组(azColName[i] 是第 i 列的名称)。
  • 返回值:
    • 返回 0 表示继续处理后续行。
    • 返回非零值会中断查询,sqlite3_exec() 会立即返回 SQLITE_ABORT
  • 示例:
    static int callback(void *data, int argc, char **argv, char **colNames) {
    for (int i = 0; i < argc; i++) {
    printf("%s = %s\n", colNames[i], argv[i] ? argv[i] : "");
    }
    return 0;
    }
4. data
  • 类型void*
  • 作用: 传递给回调函数的第一个参数(callback 的 void* data)。
  • 用途: 通常用于传递上下文信息(如输出文件名、表名等)。
  • 示例:
    const char* tableName = "Users";
    sqlite3_exec(db, "SELECT * FROM Users;", callback, (void*)tableName, &errMsg);
5. errmsg
  • 类型char**
  • 作用: 指向错误信息字符串的指针。如果执行失败,SQLite 会分配错误信息(需手动释放)。
  • 注意:
    • 成功时 *errmsg 为 ``。
    • 失败时需调用 sqlite3_free(*errmsg) 释放内存。
    • 如果传入的 errmsg 为 ``,错误信息不会被返回。
  • 示例:
    char *errMsg = nullptr;
    int rc = sqlite3_exec(db, "INVALID SQL", nullptr, nullptr, &errMsg);
    if (rc != SQLITE_OK) {
    std::cerr << "Error: " << errMsg << std::endl;
    sqlite3_free(errMsg); // 必须释放!
    }

返回值

  • SQLITE_OK (0): 执行成功。
  • 其他错误码(如 SQLITE_ERRORSQLITE_MISUSE): 表示执行失败,可通过 errmsg 获取详情。

典型用法

1. 执行非查询语句(如 CREATE/INSERT)
char *errMsg = nullptr;
int rc = sqlite3_exec(db,
"CREATE TABLE IF NOT EXISTS test (id INTEGER, name TEXT);"
"INSERT INTO test VALUES (1, 'Alice');",
nullptr, nullptr, &errMsg);
if (rc != SQLITE_OK) {
fprintf(stderr, "SQL error: %s\n", errMsg);
sqlite3_free(errMsg);
}
2. 执行查询并处理结果
static int printRow(void *unused, int argc, char **argv, char **colNames) {
for (int i = 0; i < argc; i++) {
printf("%s: %s\n", colNames[i], argv[i] ? argv[i] : "");
}
printf("---\n");
return 0;
}
sqlite3_exec(db, "SELECT * FROM test;", printRow, nullptr, &errMsg);

注意事项

  1. SQL 注入风险:
    sqlite3_exec 直接执行 SQL 字符串,避免拼接用户输入。如需参数化查询,应使用 sqlite3_prepare_v2() + sqlite3_bind_*()

  2. 错误处理:
    始终检查返回值,并释放 errmsg(如果非)。

  3. 性能:
    不适合大量数据操作(每次调用会重新解析 SQL)。高频操作建议使用预处理语句(Prepared Statements)。

  4. 多语句执行:
    可通过分号 ; 分隔多个 SQL 语句,但某条语句失败时,后续语句不会执行。


其他函数

如果需要更精细的控制(如参数绑定、事务处理),建议使用:

  1. sqlite3_prepare_v2()
  2. sqlite3_bind_*()
  3. sqlite3_step()
  4. sqlite3_finalize()

例如:

sqlite3_stmt *stmt;
sqlite3_prepare_v2(db, "INSERT INTO test VALUES (?, ?)", -1, &stmt, nullptr);
sqlite3_bind_int(stmt, 1, 2);
sqlite3_bind_text(stmt, 2, "Bob", -1, SQLITE_STATIC);
sqlite3_step(stmt);
sqlite3_finalize(stmt);

sqlite的demo可参考:SQLite3 - Linux C上数据库开发(基本操作,这篇够了)_linux 上c语言使用sqlite3-CSDN博客

Sqlite3小结(小型数据库中增删改查的操作)_如何获得sqlite3库表的记录的大小-CSDN博客

参加上面的连接查看数据代码也可以写成下面代码:

//获取行数int nrow,ncolumn;char selectCmd[]="select * from Users;";char **result;if(sqlite3_get_table(db,selectCmd,&result,&nrow,&ncolumn,&errMsg)!=0){std::cerr << "SQL错误: " << errMsg << std::endl;sqlite3_free(errMsg);}printf("nrow is %d, ncolumn is %d\n",nrow,ncolumn);//测试输出int i,j=0;for(i=1;i<=nrow;i++)//result内结果包含表头信息,因此result[0]是表头信息,实际数据范围为result[1]~result[nrow]{for(j=0;j<ncolumn;j++){printf("%s:%s\n",result[j],result[i*ncolumn+j]);}printf("------------------\n");}

运行结果如下:

http://www.dtcms.com/a/348582.html

相关文章:

  • 商密保护迷思:经营秘密到底需不需要鉴定?
  • 对称二叉树
  • 机械学习综合练习项目
  • jar包项目自启动设置ubuntu
  • [论文阅读] 软件工程 | GPS算法:用“路径摘要”当向导,软件模型检测从此告别“瞎找bug”
  • 服务器硬件电路设计之 SPI 问答(四):3 线 SPI、Dual SPI 与 Qual SPI 的奥秘
  • 春秋云镜 Hospital
  • Vue 3多语言应用开发实战:vue-i18n深度解析与最佳实践
  • 线程包括哪些状态?线程状态之间是如何变化的?
  • yggjs_rlayout框架v0.1.2使用教程 02 TechLayout 布局组件
  • 拿AI下围棋 -- 开源项目leela-zero
  • ​Mac用户安装JDK 22完整流程(Intel版dmg文件安装指南附安装包下载)​
  • mysql历史社区版本下载
  • 面试题及解答:掌握Linux下常用性能分析工具
  • (Redis)过期删除策略
  • 半年网络安全转型学习计划表(每天3小时)
  • Highcharts推出OEM许可证中国区正式上线:赋能企业级嵌入式数据可视化解决方案
  • 如何使用 DeepSeek 助力工作​。​
  • 数据可视化——matplotlib库
  • EPWpy教程:一个脚本完成能带、声子、电声耦合、弛豫时间计算
  • [自用笔记]上传本地项目至github
  • 联想win11笔记本音频失效,显示差号(x)
  • 【嵌入式DIY实例-ESP32篇】-物联网电能表
  • 硬件开发_基于物联网的宠物猫饲养系统
  • 中介者模式与几个C++应用实例
  • 【高等数学】第十章 重积分——第二节 二重积分的计算法
  • 交通拥堵识别准确率↑22.5%!陌讯多模态时序融合算法在智慧交通的落地优化
  • Spring AOP面向切面的底层原理、注解、切入点表达式、连接点获取方法名参数值等
  • C++STL底层原理:探秘标准模板库的内部机制
  • 从全栈开发到微服务架构:一次真实的Java面试实录