当前位置：首页 > 行业动态 > 正文

如何实现 C 语言循环读取数据库数据？

admin
行业动态
2025-01-16
3

c 循环读取数据库数据，通过不断执行查询语句获取所需信息。

在C语言中实现循环读取数据库数据，通常需要借助数据库的API库，如MySQL的libmysqlclient，下面是一个详细的步骤说明和示例代码，展示如何在C语言中使用MySQL C API进行数据库连接、执行查询并循环读取结果集。

一、安装和配置MySQL开发库

在使用MySQL C API之前，首先需要确保已经安装了MySQL开发库，在Linux系统上，可以使用以下命令安装：

sudo apt-get install libmysqlclient-dev

二、编写C程序

以下是一个完整的C程序示例，用于连接MySQL数据库、执行查询并循环读取结果集中的数据：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
// 函数声明
void connect_to_database(MYSQL *conn);
void execute_query(MYSQL *conn, const char *query);
void fetch_results(MYSQL *conn);
void close_connection(MYSQL *conn);
int main() {
    MYSQL *conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    connect_to_database(conn);
    execute_query(conn, "SELECT * FROM your_table");
    fetch_results(conn);
    close_connection(conn);
    return 0;
}
void connect_to_database(MYSQL *conn) {
    if (mysql_real_connect(conn, "localhost", "root", "password", "testdb", 0, NULL, 0) == NULL) {
        fprintf(stderr, "mysql_real_connect() failed
");
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
}
void execute_query(MYSQL *conn, const char *query) {
    if (mysql_query(conn, query)) {
        fprintf(stderr, "SELECT * FROM your_table failed. Error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
}
void fetch_results(MYSQL *conn) {
    MYSQL_RES *res = mysql_store_result(conn);
    if (res == NULL) {
        fprintf(stderr, "mysql_store_result() failed. Error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    int num_fields = mysql_num_fields(res);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res))) {
        for(int i = 0; i < num_fields; i++) {
            printf("%s ", row[i] ? row[i] : "NULL");
        }
        printf("
");
    }
    mysql_free_result(res);
}
void close_connection(MYSQL *conn) {
    mysql_close(conn);
}

三、详细步骤说明

1、初始化数据库连接：使用mysql_init初始化一个数据库连接对象，然后使用mysql_real_connect建立与数据库的实际连接，如果连接失败，会打印错误消息并退出程序。

2、执行SQL查询：使用mysql_query函数执行SQL查询语句，如果查询失败，会打印错误消息并退出程序。

如何实现 C 语言循环读取数据库数据？

3、循环读取结果集：使用mysql_store_result获取查询结果集，然后使用mysql_fetch_row循环读取每一行数据，每行数据可以包含多个字段，通过遍历每个字段来打印结果，使用mysql_free_result释放结果集资源。

4、关闭数据库连接：使用mysql_close关闭数据库连接以释放资源。

四、错误处理和资源管理

在数据库操作过程中，错误处理和资源管理是非常重要的，确保在出现错误时正确处理并释放资源，以避免内存泄漏和其他问题，在每次调用数据库函数后检查返回值，并在出现错误时打印错误消息并退出程序，在完成数据库操作后，及时释放结果集和关闭数据库连接。

五、完整示例代码

以下是上述步骤的完整示例代码：

如何实现 C 语言循环读取数据库数据？

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
// 函数声明
void connect_to_database(MYSQL *conn);
void execute_query(MYSQL *conn, const char *query);
void fetch_results(MYSQL *conn);
void close_connection(MYSQL *conn);
int main() {
    MYSQL *conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    connect_to_database(conn);
    execute_query(conn, "SELECT * FROM your_table");
    fetch_results(conn);
    close_connection(conn);
    return 0;
}
void connect_to_database(MYSQL *conn) {
    if (mysql_real_connect(conn, "localhost", "root", "password", "testdb", 0, NULL, 0) == NULL) {
        fprintf(stderr, "mysql_real_connect() failed
");
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
}
void execute_query(MYSQL *conn, const char *query) {
    if (mysql_query(conn, query)) {
        fprintf(stderr, "SELECT * FROM your_table failed. Error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
}
void fetch_results(MYSQL *conn) {
    MYSQL_RES *res = mysql_store_result(conn);
    if (res == NULL) {
        fprintf(stderr, "mysql_store_result() failed. Error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    int num_fields = mysql_num_fields(res);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res))) {
        for(int i = 0; i < num_fields; i++) {
            printf("%s ", row[i] ? row[i] : "NULL");
        }
        printf("
");
    }
    mysql_free_result(res);
}
void close_connection(MYSQL *conn) {
    mysql_close(conn);
}