Function with_agg_accumulate

src/cypher/cypher.c:3903–3922

Accumulate aggregation values for a binding */

/* Accumulate aggregation values for a binding */
static void with_agg_accumulate(with_agg_t *agg, cbm_return_clause_t *wc, binding_t *b) {
    for (int ci = 0; ci < wc->count; ci++) {
        if (!is_aggregate_func(wc->items[ci].func)) {
            continue;
        }
        agg->counts[ci]++;
        const char *raw = binding_get_virtual(b, wc->items[ci].variable, wc->items[ci].property);
        if (wc->items[ci].distinct && strcmp(wc->items[ci].func, "COUNT") == 0) {
            distinct_list_add(&agg->distinct_lists[ci], &agg->distinct_n[ci], raw);
        }
        double dv = strtod(raw, NULL);
        agg->sums[ci] += dv;
        if (dv < agg->mins[ci]) {
            agg->mins[ci] = dv;
        }
        if (dv > agg->maxs[ci]) {
            agg->maxs[ci] = dv;
        }
    }
}

/* Format a WITH aggregation value into buf */
static void with_agg_format(const char *func, with_agg_t *agg, int ci, char *buf, size_t buf_sz) {