Skip to content

Commit d22a145

Browse files
authored
[VP7iRcuF] Introduce helper methods from neo4j (#187)
* Copy over relevant parts of org.neo4j.internal.helpers.collection to reduce dependencies of internal Neo4j APIs * Use Pair from apache instead of Neo4j * Remove unused benchmarking code related to auto-indexing which does not exist in Neo4j anymore.
1 parent a066155 commit d22a145

File tree

109 files changed

+1617
-326
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

109 files changed

+1617
-326
lines changed

common/build.gradle

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,7 @@ dependencies {
8484
testImplementation group: 'org.neo4j', name: 'neo4j-kernel', version: neo4jVersionEffective, classifier: "tests"
8585
testImplementation group: 'org.assertj', name: 'assertj-core', version: '3.13.2'
8686
testImplementation group: 'org.mockito', name: 'mockito-core', version: '4.2.0'
87+
testImplementation group: 'pl.pragmatists', name: 'JUnitParams', version: '1.1.1'
8788

8889
configurations.all {
8990
exclude group: 'org.slf4j', module: 'slf4j-nop'

common/src/jmh/java/apoc/AsyncIndexingGraphDatabaseState.java

Lines changed: 0 additions & 16 deletions
This file was deleted.

common/src/jmh/java/apoc/GraphDatabaseState.java

Lines changed: 0 additions & 47 deletions
This file was deleted.

common/src/jmh/java/apoc/IndexTrackingGraphDatabaseState.java

Lines changed: 0 additions & 28 deletions
This file was deleted.

common/src/jmh/java/apoc/IndexUpdateBenchmarks.java

Lines changed: 0 additions & 44 deletions
This file was deleted.

common/src/jmh/java/apoc/SyncIndexingGraphDatabaseState.java

Lines changed: 0 additions & 12 deletions
This file was deleted.

common/src/main/java/apoc/algo/PathFindingUtils.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
package apoc.algo;
22

33
import apoc.path.RelationshipTypeAndDirections;
4+
import org.apache.commons.lang3.tuple.Pair;
45
import org.neo4j.graphalgo.EstimateEvaluator;
56
import org.neo4j.graphdb.Direction;
67
import org.neo4j.graphdb.Node;
78
import org.neo4j.graphdb.PathExpander;
89
import org.neo4j.graphdb.PathExpanderBuilder;
910
import org.neo4j.graphdb.RelationshipType;
10-
import org.neo4j.internal.helpers.collection.Pair;
1111
import org.neo4j.values.storable.PointValue;
1212

1313
public class PathFindingUtils {
@@ -62,17 +62,17 @@ public static PathExpander<Double> buildPathExpander(String relationshipsAndDire
6262
PathExpanderBuilder builder = PathExpanderBuilder.empty();
6363
for (Pair<RelationshipType, Direction> pair : RelationshipTypeAndDirections
6464
.parse(relationshipsAndDirections)) {
65-
if (pair.first() == null) {
66-
if (pair.other() == null) {
65+
if (pair.getLeft() == null) {
66+
if (pair.getRight() == null) {
6767
builder = PathExpanderBuilder.allTypesAndDirections();
6868
} else {
69-
builder = PathExpanderBuilder.allTypes(pair.other());
69+
builder = PathExpanderBuilder.allTypes(pair.getRight());
7070
}
7171
} else {
72-
if (pair.other() == null) {
73-
builder = builder.add(pair.first());
72+
if (pair.getRight() == null) {
73+
builder = builder.add(pair.getLeft());
7474
} else {
75-
builder = builder.add(pair.first(), pair.other());
75+
builder = builder.add(pair.getLeft(), pair.getRight());
7676
}
7777
}
7878
}

common/src/main/java/apoc/convert/ConvertUtils.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package apoc.convert;
22

3-
import org.neo4j.internal.helpers.collection.Iterators;
4-
3+
import apoc.util.collection.Iterables;
4+
import apoc.util.collection.Iterators;
55
import java.lang.reflect.Array;
66
import java.util.ArrayList;
77
import java.util.Collection;
@@ -19,8 +19,8 @@ public static List convertToList(Object list) {
1919
if (list == null) return null;
2020
else if (list instanceof List) return (List) list;
2121
else if (list instanceof Collection) return new ArrayList((Collection)list);
22-
else if (list instanceof Iterable) return Iterators.addToCollection(((Iterable)list).iterator(),(List)new ArrayList<>(100));
23-
else if (list instanceof Iterator) return Iterators.addToCollection((Iterator)list,(List)new ArrayList<>(100));
22+
else if (list instanceof Iterable) return Iterables.asList((Iterable)list);
23+
else if (list instanceof Iterator) return Iterators.asList((Iterator)list);
2424
else if (list.getClass().isArray()) {
2525
final Object[] objectArray;
2626
if (list.getClass().getComponentType().isPrimitive()) {

common/src/main/java/apoc/export/cypher/formatter/AbstractCypherFormatter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import apoc.export.util.ExportFormat;
55
import apoc.export.util.Reporter;
66
import apoc.util.Util;
7+
import apoc.util.collection.Iterables;
78
import org.apache.commons.lang3.StringUtils;
89
import org.neo4j.graphdb.Direction;
910
import org.neo4j.graphdb.GraphDatabaseService;
@@ -12,7 +13,6 @@
1213
import org.neo4j.graphdb.Relationship;
1314
import org.neo4j.graphdb.RelationshipType;
1415
import org.neo4j.graphdb.Transaction;
15-
import org.neo4j.internal.helpers.collection.Iterables;
1616

1717
import java.io.PrintWriter;
1818
import java.util.*;

common/src/main/java/apoc/export/cypher/formatter/CypherFormatterUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,10 @@
22

33
import apoc.export.util.FormatUtils;
44
import apoc.util.Util;
5+
import apoc.util.collection.Iterables;
56
import org.neo4j.graphdb.Label;
67
import org.neo4j.graphdb.Node;
78
import org.neo4j.graphdb.Relationship;
8-
import org.neo4j.internal.helpers.collection.Iterables;
99
import org.neo4j.values.storable.DurationValue;
1010
import org.neo4j.values.storable.Value;
1111
import org.neo4j.values.storable.Values;

0 commit comments

Comments
 (0)