C语言读取data.json文件并存入MySQL数据库小案例

本地有一个data.json文件

data.json

[{"id": 1,"name": "Alice","age": 30},{"id": 2,"name": "Bob","age": 25}
]

在这里插入图片描述

要将 data.json 文件中的数据存储到 MySQL 数据库中，首先需要创建一个相应的数据库表。然后，你可以使用 C 语言和 cJSON 库来读取 JSON 文件并将数据插入到数据库中。

1. 创建 MySQL 表

首先，在 MySQL 中创建一个表来存储数据。可以使用以下 SQL 语句：

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

在这里插入图片描述

2. C 语言代码示例

以下是一个完整的 C 语言示例，使用 cJSON 库读取 data.json 文件并将数据插入到 MySQL 数据库中。

依赖项

确保你已经安装了以下库：

MySQL C API
cJSON

C 代码示例

#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);// 解析 JSONcJSON *json = cJSON_Parse(data);if (json == NULL) {fprintf(stderr, "cJSON_Parse failed\n");free(data);mysql_close(conn);return EXIT_FAILURE;}// 遍历 JSON 数组并插入数据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)# 构建目标
$(TARGET): $(OBJ)$(CC) $(CFLAGS) -o $@ $^ $(LIBS)# 编译 .c 文件为 .o 文件
%.o: %.c$(CC) $(CFLAGS) -c $< -o $@# 清理目标
clean:rm -f $(TARGET) $(OBJ)# 伪目标
.PHONY: all clean