如何用C语言在cassandra数据库中插入JSON

#include <cassandra.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <cjson/cJSON.h>

int main() {
    // 连接到Cassandra数据库
    CassCluster* cluster = cass_cluster_new();
    CassSession* session = cass_session_new();
    CassFuture* connect_future = cass_session_connect(session, cluster);

    // 检查连接是否成功
    CassError rc = cass_future_error_code(connect_future);
    if (rc != CASS_OK) {
        const char* message;
        size_t message_length;
        cass_future_error_message(connect_future, &message, &message_length);
        fprintf(stderr, "无法连接到Cassandra: '%.*s'\n", (int)message_length, message);
        cass_future_free(connect_future);
        cass_cluster_free(cluster);
        cass_session_free(session);
        return -1;
    }

    // 创建JSON数据
    cJSON* json = cJSON_CreateObject();
    cJSON_AddStringToObject(json, "name", "John");
    cJSON_AddNumberToObject(json, "age", 25);
    char* json_str = cJSON_Print(json);

    // 构建CQL语句
    const char* insert_query = "INSERT INTO keyspace.table (id, data) VALUES (?, ?);";
    CassStatement* statement = cass_statement_new(insert_query, 2);
    cass_statement_bind_string(statement, 0, "1");
    cass_statement_bind_string(statement, 1, json_str);

    // 执行CQL语句
    CassFuture* execute_future = cass_session_execute(session, statement);
    rc = cass_future_error_code(execute_future);
    if (rc != CASS_OK) {
        const char* message;
        size_t message_length;
        cass_future_error_message(execute_future, &message, &message_length);
        fprintf(stderr, "插入数据时出错: '%.*s'\n", (int)message_length, message);
    } else {
        printf("数据插入成功！\n");
    }

    // 释放资源
    cJSON_Delete(json);
    free(json_str);
    cass_statement_free(statement);
    cass_future_free(execute_future);
    cass_future_free(connect_future);
    cass_cluster_free(cluster);
    cass_session_free(session);

    return 0;
}