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

如何高效地从C语言中导出数据库表数据？

admin
行业动态
2025-01-26
3937

### 导出数据库表数据方法多样，包括SQL查询、数据库管理工具、编程语言及备份恢复工具等，各有优缺点，适用于不同场景。

在C语言中导出数据库表数据通常涉及到以下几个步骤：连接数据库、执行SQL查询、处理查询结果以及将结果写入文件，以下是详细的步骤和示例代码，以MySQL数据库为例。

如何高效地从C语言中导出数据库表数据？第1张

准备工作

确保你已经安装了MySQL开发库，并且你的C程序能够连接到MySQL服务器，你还需要包含必要的头文件并链接相应的库。

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>

连接数据库

使用mysql_real_connect()函数连接到MySQL数据库，你需要提供主机名、用户名、密码、数据库名等参数。

MYSQL *conn;
conn = mysql_init(NULL);
if (conn == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}
if (mysql_real_connect(conn, "localhost", "user", "password", "database", 0, NULL, 0) == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

执行SQL查询

使用mysql_query()函数执行SQL查询，获取要导出的表数据。

if (mysql_query(conn, "SELECT * FROM your_table")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

处理查询结果

使用mysql_store_result()函数获取查询结果集，然后遍历结果集并将数据写入文件。

MYSQL_RES *res;
MYSQL_ROW row;
FILE *file;
res = mysql_store_result(conn);
if (res == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
file = fopen("output.csv", "w");
if (file == NULL) {
    fprintf(stderr, "Can't open file
");
    mysql_free_result(res);
    mysql_close(conn);
    exit(1);
}
// 获取列数
int num_fields = mysql_num_fields(res);
MYSQL_FIELD *field;
// 写入列名
for (int i = 0; i < num_fields; i++) {
    field = mysql_fetch_field_direct(res, i);
    fprintf(file, "%s", (i == 0) ? "" : ",");
    fprintf(file, "%s", field->name);
}
fprintf(file, "
");
// 写入行数据
while ((row = mysql_fetch_row(res))) {
    for (int i = 0; i < num_fields; i++) {
        fprintf(file, "%s", (i == 0) ? "" : ",");
        if (row[i]) {
            fprintf(file, "%s", row[i]);
        } else {
            fprintf(file, "NULL");
        }
    }
    fprintf(file, "
");
}
// 清理资源
fclose(file);
mysql_free_result(res);
mysql_close(conn);

完整示例代码

以下是完整的C程序示例，用于从MySQL数据库导出表数据到CSV文件。

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    FILE *file;
    MYSQL_FIELD *field;
    int num_fields;
    // 初始化连接
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_real_connect(conn, "localhost", "user", "password", "database", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 执行查询
    if (mysql_query(conn, "SELECT * FROM your_table")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 获取结果集
    res = mysql_store_result(conn);
    if (res == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 打开文件
    file = fopen("output.csv", "w");
    if (file == NULL) {
        fprintf(stderr, "Can't open file
");
        mysql_free_result(res);
        mysql_close(conn);
        exit(1);
    }
    // 写入列名
    num_fields = mysql_num_fields(res);
    for (int i = 0; i < num_fields; i++) {
        field = mysql_fetch_field_direct(res, i);
        fprintf(file, "%s", (i == 0) ? "" : ",");
        fprintf(file, "%s", field->name);
    }
    fprintf(file, "
");
    // 写入行数据
    while ((row = mysql_fetch_row(res))) {
        for (int i = 0; i < num_fields; i++) {
            fprintf(file, "%s", (i == 0) ? "" : ",");
            if (row[i]) {
                fprintf(file, "%s", row[i]);
            } else {
                fprintf(file, "NULL");
            }
        }
        fprintf(file, "
");
    }
    // 清理资源
    fclose(file);
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}