c如何将数据库数据写入json文件格式

C语言实现数据库数据写入JSON文件格式的完整指南

在当今的数据处理领域，将数据库中的数据导出为JSON格式已成为一种常见需求，JSON格式因其轻量级、易读性和广泛的语言支持而备受青睐,本文将详细介绍如何使用C语言从数据库读取数据并将其写入JSON文件的全过程。

准备工作

在开始之前,我们需要准备以下工具和库：

C语言开发环境：如GCC、Clang等编译器
数据库连接库：根据使用的数据库选择，如MySQL的libmysqlclient、PostgreSQL的libpq、SQLite的sqlite3等
JSON处理库：推荐使用cJSON（轻量级且易用）

以MySQL数据库为例,首先需要安装MySQL开发库和cJSON库：

# Ubuntu/Debian系统
sudo apt-get install libmysqlclient-dev libjson-c-dev
# CentOS/RHEL系统
sudo yum install mysql-devel json-c-devel

连接数据库

我们需要建立与数据库的连接,以下是一个连接MySQL数据库的示例代码：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
MYSQL* connect_to_database(const char* host, const char* user, const char* password, const char* database) {
    MYSQL* mysql = mysql_init(NULL);
    if (mysql == NULL) {
        fprintf(stderr, "mysql_init() failed\n");
        return NULL;
    }
    if (mysql_real_connect(mysql, host, user, password, database, 0, NULL, 0) == NULL) {
        fprintf(stderr, "mysql_real_connect() failed: %s\n", mysql_error(mysql));
        mysql_close(mysql);
        return NULL;
    }
    return mysql;
}

执行查询并获取结果

连接数据库后,执行SQL查询并获取结果集：

MYSQL_RES* execute_query(MYSQL* mysql, const char* query) {
    if (mysql_query(mysql, query) != 0) {
        fprintf(stderr, "mysql_query() failed: %s\n", mysql_error(mysql));
        return NULL;
    }
    MYSQL_RES* result = mysql_store_result(mysql);
    if (result == NULL) {
        if (mysql_field_count(mysql) == 0) {
            // 查询不返回结果（如INSERT、UPDATE等）
            return NULL;
        } else {
            fprintf(stderr, "mysql_store_result() failed: %s\n", mysql_error(mysql));
            return NULL;
        }
    }
    return result;
}

使用cJSON构建JSON数据

cJSON是一个轻量级的JSON解析器，非常适合在C语言中使用,以下是使用cJSON构建JSON数据的示例：

#include <cjson/cJSON.h>
cJSON* result_to_json(MYSQL_RES* result) {
    MYSQL_ROW row;
    int num_fields = mysql_num_fields(result);
    MYSQL_FIELD* fields = mysql_fetch_fields(result);
    cJSON* json_array = cJSON_CreateArray();
    while ((row = mysql_fetch_row(result)) != NULL) {
        cJSON* json_object = cJSON_CreateObject();
        for (int i = 0; i < num_fields; i++) {
            cJSON_AddStringToObject(json_object, fields[i].name, row[i] ? row[i] : "NULL");
        }
        cJSON_AddItemToArray(json_array, json_object);
    }
    return json_array;
}

将JSON数据写入文件

构建好JSON数据后,我们需要将其写入文件：

int write_json_to_file(const char* filename, cJSON* json) {
    FILE* fp = fopen(filename, "w");
    if (fp == NULL) {
        fprintf(stderr, "Failed to open file %s\n", filename);
        return -1;
    }
    char* json_string = cJSON_Print(json);
    if (json_string == NULL) {
        fprintf(stderr, "Failed to generate JSON string\n");
        fclose(fp);
        return -1;
    }
    fprintf(fp, "%s\n", json_string);
    fclose(fp);
    free(json_string);
    return 0;
}

完整示例代码

将以上各部分组合起来,形成一个完整的示例：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
#include <cjson/cJSON.h>
MYSQL* connect_to_database(const char* host, const char* user, const char* password, const char* database) {
    // ...（同上）
}
MYSQL_RES* execute_query(MYSQL* mysql, const char* query) {
    // ...（同上）
}
cJSON* result_to_json(MYSQL_RES* result) {
    // ...（同上）
}
int write_json_to_file(const char* filename, cJSON* json) {
    // ...（同上）
}
void free_resources(MYSQL* mysql, MYSQL_RES* result, cJSON* json) {
    if (json) cJSON_Delete(json);
    if (result) mysql_free_result(result);
    if (mysql) mysql_close(mysql);
}
int main() {
    const char* host = "localhost";
    const char* user = "root";
    const char* password = "password";
    const char* database = "testdb";
    const char* query = "SELECT id, name, email FROM users";
    const char* output_file = "users.json";
    // 连接数据库
    MYSQL* mysql = connect_to_database(host, user, password, database);
    if (mysql == NULL) {
        return EXIT_FAILURE;
    }
    // 执行查询
    MYSQL_RES* result = execute_query(mysql, query);
    if (result == NULL) {
        free_resources(mysql, NULL, NULL);
        return EXIT_FAILURE;
    }
    // 转换为JSON
    cJSON* json = result_to_json(result);
    if (json == NULL) {
        free_resources(mysql, result, NULL);
        return EXIT_FAILURE;
    }
    // 写入文件
    if (write_json_to_file(output_file, json) != 0) {
        free_resources(mysql, result, json);
        return EXIT_FAILURE;
    }
    printf("Data successfully written to %s\n", output_file);
    // 释放资源
    free_resources(mysql, result, json);
    return EXIT_SUCCESS;
}

编译与运行

使用以下命令编译上述代码：

gcc -o db_to_json db_to_json.c -lmysqlclient -lcjson

然后运行生成的可执行文件：

./db_to_json

执行成功后，将在当前目录下生成一个名为users.json的文件,其中包含从数据库查询到的JSON格式数据。

进阶优化

处理复杂数据类型：上述示例仅处理了字符串类型，实际应用中可能需要处理整数、浮点数、日期时间等类型。

// 修改result_to_json函数中的部分代码
for (int i = 0; i < num_fields; i++) {
    switch (fields[i].type) {
        case MYSQL_TYPE_DECIMAL:
        case MYSQL_TYPE_NEWDECIMAL:
        case MYSQL_TYPE_FLOAT:
        case MYSQL_TYPE_DOUBLE:
            cJSON_AddNumberToObject(json_object, fields[i].name, atof(row[i]));
            break;
        case MYSQL_TYPE_TINY:
        case MYSQL_TYPE_SHORT:
        case MYSQL_TYPE_LONG:
        case MYSQL_TYPE_INT24:
        case MYSQL_TYPE_YEAR:
        case MYSQL_TYPE_BIT:
            cJSON_AddNumberToObject(json_object, fields[i].name, atoi(row[i]));
            break;
        default:
            cJSON_AddStringToObject(json_object, fields[i].name, row[i] ? row[i] : "NULL");
    }
}