C语言编程中，如何遍历数据库表并处理每一条记录数据？

在C语言编程中,由于语言本身并不包含直接操作数据库的内置功能，遍历数据库表需要借助第三方数据库接口库，SQLite是一个极佳的选择，它是一个轻量级、无服务器、自包含的SQL数据库引擎，以其简洁的C语言API和零配置的特性而闻名，本文将以SQLite为例，详细介绍如何在C语言中连接数据库、执行查询并遍历返回的结果集。

准备工作：集成SQLite库

在开始编码之前,需要将SQLite的库文件集成到您的项目中，最简单的方式是下载其“amalgamation”源码包，其中包含了sqlite3.c和sqlite3.h两个核心文件，您只需将这两个文件与您的主程序源文件放在同一目录下，然后在编译时一并包含即可。

假设您的主程序是main.c，编译命令如下：

gcc main.c sqlite3.c -o db_program -lpthread -ldl

此命令会将您的代码与SQLite的源码编译链接在一起,生成一个可执行文件db_program。-lpthread和-ldl是SQLite在某些系统上依赖的库。

核心流程：遍历数据库表的四部曲

遍历数据库表通常遵循一个标准的流程：连接数据库、准备SQL语句、单步执行并提取数据、最后释放资源。

第一步：连接数据库

需要打开一个数据库连接,如果数据库文件不存在，SQLite会自动创建一个，这通过sqlite3_open()函数实现。

sqlite3 *db; // 数据库连接句柄
int rc = sqlite3_open("example.db", &db);
if (rc != SQLITE_OK) {
    fprintf(stderr, "无法打开数据库: %sn", sqlite3_errmsg(db));
    return 1;
}

此代码尝试打开（或创建）一个名为example.db的数据库文件，如果成功，db将指向一个有效的数据库连接句柄；否则，它会打印错误信息。

第二步：准备SQL语句

直接执行SQL字符串虽然可行,但更安全、更高效的做法是使用“预处理语句”，预处理语句可以将SQL模板编译成字节码，不仅能防止SQL注入攻击，还能在多次执行时提高性能，这通过sqlite3_prepare_v2()函数完成。

const char *sql = "SELECT id, name, score FROM students;";
sqlite3_stmt *stmt; // 预处理语句句柄
rc = sqlite3_prepare_v2(db, sql, -1, &stmt, NULL);
if (rc != SQLITE_OK) {
    fprintf(stderr, "SQL语句准备失败: %sn", sqlite3_errmsg(db));
    sqlite3_close(db);
    return 1;
}

这里,我们将一个SELECT查询编译成一个sqlite3_stmt对象，参数-1表示自动计算SQL字符串的长度。

第三步：单步执行并遍历结果集

这是遍历的核心环节,使用sqlite3_step()函数来执行预处理语句，当查询返回数据时，sqlite3_step()每次会返回一行数据，直到所有行都被处理完毕。

while ((rc = sqlite3_step(stmt)) == SQLITE_ROW) {
    // 在循环体内，我们可以从当前行提取数据
    int id = sqlite3_column_int(stmt, 0); // 获取第一列（id）
    const unsigned char *name = sqlite3_column_text(stmt, 1); // 获取第二列（name）
    double score = sqlite3_column_double(stmt, 2); // 获取第三列（score）
    printf("ID: %d, Name: %s, Score: %.2fn", id, name, score);
}
if (rc != SQLITE_DONE) {
    fprintf(stderr, "遍历过程中出错: %sn", sqlite3_errmsg(db));
}

• sqlite3_step(stmt)的返回值SQLITE_ROW表示成功获取到一行数据。
• sqlite3_column_*()系列函数用于从当前行中提取特定列的数据，函数的第二个参数是列的索引，从0开始。
• 当所有行都处理完毕后,sqlite3_step()将返回SQLITE_DONE，循环结束。

第四步：释放资源

在C语言中,资源管理至关重要，完成数据库操作后，必须释放预处理语句和关闭数据库连接，以避免内存泄漏。

sqlite3_finalize(stmt); // 释放预处理语句
sqlite3_close(db);      // 关闭数据库连接

完整示例代码

下面的代码整合了上述所有步骤,包括创建表、插入数据、遍历数据并最终清理资源。

#include <stdio.h>
#include <sqlite3.h>
int main() {
    sqlite3 *db;
    sqlite3_stmt *stmt;
    int rc;
    // 1. 打开数据库
    rc = sqlite3_open("school.db", &db);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "无法打开数据库: %sn", sqlite3_errmsg(db));
        return 1;
    }
    // 创建表（如果不存在）
    const char *createTableSQL = "CREATE TABLE IF NOT EXISTS students ("
                                 "id INTEGER PRIMARY KEY AUTOINCREMENT, "
                                 "name TEXT NOT NULL, "
                                 "score REAL);";
    rc = sqlite3_exec(db, createTableSQL, 0, 0, NULL);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "创建表失败: %sn", sqlite3_errmsg(db));
        sqlite3_close(db);
        return 1;
    }
    // 插入一些示例数据
    sqlite3_exec(db, "INSERT INTO students (name, score) VALUES ('张三', 95.5);", 0, 0, NULL);
    sqlite3_exec(db, "INSERT INTO students (name, score) VALUES ('李四', 88.0);", 0, 0, NULL);
    sqlite3_exec(db, "INSERT INTO students (name, score) VALUES ('王五', 76.5);", 0, 0, NULL);
    // 2. 准备查询语句
    const char *selectSQL = "SELECT id, name, score FROM students;";
    rc = sqlite3_prepare_v2(db, selectSQL, -1, &stmt, NULL);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "SQL语句准备失败: %sn", sqlite3_errmsg(db));
        sqlite3_close(db);
        return 1;
    }
    printf("遍历学生表:n");
    printf("---------------------------------n");
    // 3. 遍历结果集
    while ((rc = sqlite3_step(stmt)) == SQLITE_ROW) {
        int id = sqlite3_column_int(stmt, 0);
        const unsigned char *name = sqlite3_column_text(stmt, 1);
        double score = sqlite3_column_double(stmt, 2);
        printf("ID: %d, 姓名: %s, 分数: %.2fn", id, name, score);
    }
    if (rc != SQLITE_DONE) {
        fprintf(stderr, "遍历过程中出错: %sn", sqlite3_errmsg(db));
    }
    printf("---------------------------------n");
    printf("遍历完成，n");
    // 4. 释放资源
    sqlite3_finalize(stmt);
    sqlite3_close(db);
    return 0;
}

关键API函数速查表

为了方便查阅,以下列出了本文涉及的核心SQLite C API函数。

函数名	功能描述	关键参数/返回值
sqlite3_open()	打开或创建一个SQLite数据库文件。	(const char *filename, sqlite3 **ppDb)，返回SQLITE_OK表示成功。
sqlite3_prepare_v2()	将SQL文本编译成一个预处理语句。	(sqlite3 *db, const char *zSql, int nByte, sqlite3 **ppStmt, const char **pzTail)
sqlite3_step()	执行预处理语句，单步前进到结果集的下一行。	(sqlite3 *stmt)，返回SQLITE_ROW（有数据）、SQLITE_DONE（完成）等。
sqlite3_column_int()	从当前行获取指定列的整数值。	(sqlite3 *stmt, int iCol)，iCol为列索引（从0开始）。
sqlite3_column_text()	从当前行获取指定列的文本值。	(sqlite3 *stmt, int iCol)，返回const unsigned char *。
sqlite3_column_double()	从当前行获取指定列的双精度浮点值。	(sqlite3 *stmt, int iCol)。
sqlite3_finalize()	销毁一个预处理语句，释放相关资源。	(sqlite3 *stmt)。
sqlite3_close()	关闭数据库连接。	(sqlite3 *db)。
sqlite3_errmsg()	获取最近一次数据库操作的错误描述。	(sqlite3 *db)，返回错误信息字符串。

---

相关问答FAQs

问题1：如果我的数据量非常大，一次性遍历所有数据会很慢，有什么优化方法吗？

解答： 对于海量数据，一次性加载所有记录确实会消耗大量内存和时间，优化方法主要有以下几种：

1. 在SQL查询中加入WHERE条件，只检索您需要的数据，而不是整个表。SELECT * FROM students WHERE score > 90;。
2. 分页查询： 使用LIMIT和OFFSET关键字实现分页加载，每次只加载20条记录：SELECT * FROM students ORDER BY id LIMIT 20 OFFSET 0;（第一页），... LIMIT 20 OFFSET 20;（第二页），以此类推，这样可以显著减少单次查询的数据量和内存占用。
3. 创建索引： 为经常用于查询条件（WHERE子句）或排序（ORDER BY子句）的列创建索引，可以极大加快查询速度。CREATE INDEX idx_student_score ON students(score);。

问题2：除了SQLite，C语言还可以连接其他数据库吗？比如MySQL或PostgreSQL。

解答： 当然可以，几乎所有主流的数据库系统都提供了官方或第三方的C语言客户端库，其基本操作流程与SQLite非常相似，都遵循“连接-准备-执行-遍历-清理”的模式，但具体的API函数名称和用法会有所不同。

• MySQL： 可以使用其官方的C客户端库libmysqlclient，您需要包含mysql.h，并使用如mysql_init()、mysql_real_connect()、mysql_query()、mysql_store_result()、mysql_fetch_row()等函数。
• PostgreSQL： 可以使用其官方的C客户端库libpq，您需要包含libpq-fe.h，并使用如PQconnectdb()、PQexec()、PQntuples()、PQgetvalue()等函数。

选择哪种数据库取决于您的项目需求（如并发性、数据规模、功能复杂性等），SQLite适用于嵌入式或中小型应用，而MySQL和PostgreSQL则更适合需要高并发、复杂事务和强大功能的服务器端应用。