C語言讀取data.json文件并存入MySQL數(shù)據(jù)庫小案例(推薦)

更新時間：2024年10月12日 09:49:02 作者：etsuyou

本文介紹如何使用C語言結(jié)合cJSON庫讀取JSON文件,并將數(shù)據(jù)存儲到MySQL數(shù)據(jù)庫中,示例代碼包括創(chuàng)建MySQL表的SQL語句和C語言代碼,以及如何編譯和運行程序,確保已安裝必要的庫以支持程序運行

1. 創(chuàng)建 MySQL 表

首先，在 MySQL 中創(chuàng)建一個表來存儲數(shù)據(jù)?？梢允褂靡韵?SQL 語句：

CREATE TABLE users (
    id INT PRIMARY KEY,
    name VARCHAR(100),
    age INT
);

2. C 語言代碼示例

以下是一個完整的 C 語言示例，使用 cJSON 庫讀取 data.json 文件并將數(shù)據(jù)插入到 MySQL 數(shù)據(jù)庫中。

依賴項

確保你已經(jīng)安裝了以下庫：

MySQL C API
cJSON

代碼示例

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
#include "cJSON.h"
// MySQL 配置
#define DB_HOST "xxx.xxx.xxx.xxx"
#define DB_USER "root"
#define DB_PASSWORD "xxxxxx"
#define DB_NAME "xxxxx"
void insert_user(MYSQL *conn, int id, const char *name, int age) {
    char query[256];
    snprintf(query, sizeof(query), "INSERT INTO users (id, name, age) VALUES (%d, '%s', %d)", id, name, age);
    if (mysql_query(conn, query)) {
        fprintf(stderr, "INSERT failed: %s\n", mysql_error(conn));
    }
}
int main() {
    // MySQL 連接
    MYSQL *conn;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed\n");
        return EXIT_FAILURE;
    }
    if (mysql_real_connect(conn, DB_HOST, DB_USER, DB_PASSWORD, DB_NAME, 0, NULL, 0) == NULL) {
        fprintf(stderr, "mysql_real_connect() failed\n");
        mysql_close(conn);
        return EXIT_FAILURE;
    }
    // 讀取 JSON 文件
    FILE *file = fopen("data.json", "r");
    if (!file) {
        perror("Could not open file");
        mysql_close(conn);
        return EXIT_FAILURE;
    }
    fseek(file, 0, SEEK_END);
    long length = ftell(file);
    fseek(file, 0, SEEK_SET);
    char *data = malloc(length);
    fread(data, 1, length, file);
    fclose(file);
    // 解析 JSON
    cJSON *json = cJSON_Parse(data);
    if (json == NULL) {
        fprintf(stderr, "cJSON_Parse failed\n");
        free(data);
        mysql_close(conn);
        return EXIT_FAILURE;
    }
    // 遍歷 JSON 數(shù)組并插入數(shù)據(jù)
    cJSON *user;
    cJSON_ArrayForEach(user, json) {
        int id = cJSON_GetObjectItem(user, "id")->valueint;
        const char *name = cJSON_GetObjectItem(user, "name")->valuestring;
        int age = cJSON_GetObjectItem(user, "age")->valueint;
        insert_user(conn, id, name, age);
    }
    // 清理
    cJSON_Delete(json);
    free(data);
    mysql_close(conn);
    return EXIT_SUCCESS;
}

3. 編譯和運行

新建一個makefile文件：

# 定義變量
CC = gcc
CFLAGS = -Wall -g
LIBS = -lm -lmysqlclient  # 添加 MySQL 客戶端庫
TARGET = json_to_mysql
SRC = main.c cJSON.c
OBJ = $(SRC:.c=.o)
# 默認目標
all: $(TARGET)
# 構(gòu)建目標
$(TARGET): $(OBJ)
	$(CC) $(CFLAGS) -o $@ $^ $(LIBS)
# 編譯 .c 文件為 .o 文件
%.o: %.c
	$(CC) $(CFLAGS) -c $< -o $@
# 清理目標
clean:
	rm -f $(TARGET) $(OBJ)
# 偽目標
.PHONY: all clean

輸入make編譯：