Function cbm_cypher_execute

src/cypher/cypher.c:4467–4528

/* ── Main entry point ─────────────────────────────────────────── */

int cbm_cypher_execute(cbm_store_t *store, const char *query, const char *project, int max_rows,
                       cbm_cypher_result_t *out) {
    memset(out, 0, sizeof(*out));
    if (max_rows <= 0) {
        max_rows = CYPHER_RESULT_CEILING;
    }

    cbm_query_t *q = NULL;
    char *err = NULL;
    if (cbm_cypher_parse(query, &q, &err) < 0) {
        out->error = err;
        return CBM_NOT_FOUND;
    }

    result_builder_t rb = {0};
    // cppcheck-suppress knownConditionTrueFalse
    if (execute_single(store, q, project, max_rows, &rb) < 0) {
        cbm_query_free(q);
        return CBM_NOT_FOUND;
    }

    /* UNION chain */
    cbm_query_t *uq = q->union_next;
    while (uq) {
        result_builder_t rb2 = {0};
        // cppcheck-suppress knownConditionTrueFalse
        if (execute_single(store, uq, project, max_rows, &rb2) < 0) {
            rb_free(&rb);
            rb_free(&rb2);
            cbm_query_free(q);
            return CBM_NOT_FOUND;
        }
        /* Concatenate rows from rb2 into rb */
        for (int i = 0; i < rb2.row_count; i++) {
            rb_add_row(&rb, rb2.rows[i]);
        }
        rb_free(&rb2);

        uq = uq->union_next;
    }

    /* UNION (not ALL) deduplication */
    if (q->union_next && !q->union_all) {
        rb_apply_distinct(&rb);
    }

    /* Check ceiling */
    if (rb.row_count >= CYPHER_RESULT_CEILING) {
        rb_free(&rb);
        cbm_query_free(q);
        out->error = heap_strdup("result exceeded 100k rows — use narrower filters or add LIMIT");
        return CBM_NOT_FOUND;
    }

    out->columns = rb.columns;
    out->col_count = rb.col_count;
    out->rows = rb.rows;
    out->row_count = rb.row_count;