Function executeQuery

packages/graph/src/test/distinct-aggregates.test.ts:39–56

(graph: Graph<typeof schema>, queryString: string)

}

function executeQuery(graph: Graph<typeof schema>, queryString: string): unknown[] {
  const parsed = parse(queryString);
  // Handle MultiStatement (for CREATE, etc)
  if (parsed.type === "MultiStatement") {
    const results: unknown[] = [];
    for (const stmt of (parsed as MultiStatement).statements) {
      const ast = stmt as Query;
      const steps = anyAstToSteps(ast);
      const traverser = createTraverser(steps);
      results.push(...traverser.traverse(graph, []));
    }
    return results;
  }
  const ast = parsed as Query;
  const steps = anyAstToSteps(ast);
  const traverser = createTraverser(steps);
  return Array.from(traverser.traverse(graph, []));
}

describe("DISTINCT in aggregate functions", () => {
  let graph: Graph<typeof schema>;