Function execute_with_clause

src/cypher/cypher.c:4104–4148

}

static void execute_with_clause(cbm_query_t *q, binding_t **bindings_ptr, int *bind_count_ptr) {
    cbm_return_clause_t *wc = q->with_clause;
    if (!wc) {
        return;
    }
    binding_t *bindings = *bindings_ptr;
    int bind_count = *bind_count_ptr;

    binding_t *vbindings = malloc((bind_count + SKIP_ONE) * sizeof(binding_t));
    int vcount = 0;

    bool has_agg = false;
    for (int i = 0; i < wc->count; i++) {
        if (is_aggregate_func(wc->items[i].func)) {
            has_agg = true;
            break;
        }
    }

    if (has_agg) {
        execute_with_aggregate(wc, bindings, bind_count, &vbindings, &vcount);
    } else {
        execute_with_simple(wc, bindings, bind_count, vbindings, &vcount);
    }

    /* WITH DISTINCT: dedup projected rows (no-op for aggregation, which already
     * collapses to one row per group). */
    if (wc->distinct) {
        with_apply_distinct(wc, vbindings, &vcount);
    }

    with_sort_skip_limit(wc, vbindings, &vcount);

    for (int bi = 0; bi < bind_count; bi++) {
        binding_free(&bindings[bi]);
    }
    free(bindings);

    if (q->post_with_where) {
        filter_bindings_where(q->post_with_where, vbindings, &vcount);
    }

    *bindings_ptr = vbindings;
    *bind_count_ptr = vcount;
}

/* ── Execute a single query (no UNION recursion) ──────────────── */