From f7b07cdfa038d9198177f06823ea8e47f0c38189 Mon Sep 17 00:00:00 2001
From: Brad Baker <bbaker@atlassian.com>
Date: Sat, 23 Jul 2022 16:06:08 +1000
Subject: [PATCH] DF SelectionSet Benchmark

---
 .../benchmark/DFSelectionSetBenchmark.java    | 117 ++++++++++++++++++
 1 file changed, 117 insertions(+)
 create mode 100644 src/test/java/benchmark/DFSelectionSetBenchmark.java

diff --git a/src/test/java/benchmark/DFSelectionSetBenchmark.java b/src/test/java/benchmark/DFSelectionSetBenchmark.java
new file mode 100644
index 0000000000..1e54b32647
--- /dev/null
+++ b/src/test/java/benchmark/DFSelectionSetBenchmark.java
@@ -0,0 +1,117 @@
+package benchmark;
+
+import com.google.common.base.Charsets;
+import com.google.common.io.Resources;
+import graphql.execution.CoercedVariables;
+import graphql.language.Document;
+import graphql.normalized.ExecutableNormalizedField;
+import graphql.normalized.ExecutableNormalizedOperation;
+import graphql.normalized.ExecutableNormalizedOperationFactory;
+import graphql.parser.Parser;
+import graphql.schema.DataFetchingFieldSelectionSet;
+import graphql.schema.DataFetchingFieldSelectionSetImpl;
+import graphql.schema.GraphQLOutputType;
+import graphql.schema.GraphQLSchema;
+import graphql.schema.SelectedField;
+import graphql.schema.idl.SchemaGenerator;
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Fork;
+import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Mode;
+import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.annotations.Threads;
+import org.openjdk.jmh.annotations.Warmup;
+import org.openjdk.jmh.infra.Blackhole;
+
+import java.io.IOException;
+import java.net.URL;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+import static com.google.common.io.Resources.getResource;
+
+@State(Scope.Benchmark)
+@BenchmarkMode(Mode.Throughput)
+@Warmup(iterations = 2)
+@Measurement(iterations = 2, timeUnit = TimeUnit.NANOSECONDS)
+public class DFSelectionSetBenchmark {
+
+    @State(Scope.Benchmark)
+    public static class MyState {
+
+        public ExecutableNormalizedField normalisedField;
+        public GraphQLOutputType outputFieldType;
+        GraphQLSchema schema;
+        Document document;
+
+        @Setup
+        public void setup() {
+            try {
+                String schemaString = readFromClasspath("large-schema-2.graphqls");
+                schema = SchemaGenerator.createdMockedSchema(schemaString);
+
+                String query = readFromClasspath("large-schema-2-query.graphql");
+                document = Parser.parse(query);
+
+                ExecutableNormalizedOperation executableNormalizedOperation = ExecutableNormalizedOperationFactory.createExecutableNormalizedOperation(schema, document, null, CoercedVariables.emptyVariables());
+
+                normalisedField = executableNormalizedOperation.getTopLevelFields().get(0);
+
+                outputFieldType = schema.getObjectType("Object42");
+
+            } catch (Exception e) {
+                System.out.println(e);
+                throw new RuntimeException(e);
+            }
+        }
+
+        private String readFromClasspath(String file) throws IOException {
+            URL url = getResource(file);
+            return Resources.toString(url, Charsets.UTF_8);
+        }
+    }
+
+    @Benchmark
+    @Warmup(iterations = 2)
+    @Measurement(iterations = 5, time = 10)
+    @Threads(1)
+    @Fork(3)
+    @BenchmarkMode(Mode.AverageTime)
+    @OutputTimeUnit(TimeUnit.MILLISECONDS)
+    public void benchMarkAvgTime(MyState myState, Blackhole blackhole) {
+        List<SelectedField> fields = getSelectedFields(myState);
+        blackhole.consume(fields);
+    }
+
+    @Benchmark
+    @Warmup(iterations = 2)
+    @Measurement(iterations = 5, time = 10)
+    @Threads(1)
+    @Fork(3)
+    @BenchmarkMode(Mode.Throughput)
+    @OutputTimeUnit(TimeUnit.MILLISECONDS)
+    public void benchMarkThroughput(MyState myState, Blackhole blackhole) {
+        List<SelectedField> fields = getSelectedFields(myState);
+        blackhole.consume(fields);
+    }
+
+    private List<SelectedField> getSelectedFields(MyState myState) {
+        DataFetchingFieldSelectionSet dataFetchingFieldSelectionSet = DataFetchingFieldSelectionSetImpl.newCollector(myState.schema, myState.outputFieldType, () -> myState.normalisedField);
+        return dataFetchingFieldSelectionSet.getFields("wontBeFound");
+    }
+
+    public static void mainX(String[] args) throws InterruptedException {
+        MyState myState = new MyState();
+        myState.setup();
+
+        while (true) {
+            List<SelectedField> selectedFields = new DFSelectionSetBenchmark().getSelectedFields(myState);
+            Thread.sleep(500);
+        }
+    }
+
+}