diff --git a/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingNodeTypeRepresentationStrategyTest.java b/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingNodeTypeRepresentationStrategyTest.java index 443142e66..a56c9b4c2 100644 --- a/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingNodeTypeRepresentationStrategyTest.java +++ b/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingNodeTypeRepresentationStrategyTest.java @@ -81,6 +81,8 @@ public class IndexingNodeTypeRepresentationStrategyTest extends EntityTestBase { assertEquals(node(subThing), subThingHits.getSingle()); assertEquals(thing.getClass().getName(), node(thing).getProperty(IndexingNodeTypeRepresentationStrategy.TYPE_PROPERTY_NAME)); assertEquals(subThing.getClass().getName(), node(subThing).getProperty(IndexingNodeTypeRepresentationStrategy.TYPE_PROPERTY_NAME)); + thingHits.close(); + subThingHits.close(); } @Test diff --git a/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingRelationshipTypeRepresentationStrategyTest.java b/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingRelationshipTypeRepresentationStrategyTest.java index 0dc535beb..c77055e81 100644 --- a/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingRelationshipTypeRepresentationStrategyTest.java +++ b/spring-data-neo4j-aspects/src/test/java/org/springframework/data/neo4j/aspects/support/typerepresentation/IndexingRelationshipTypeRepresentationStrategyTest.java @@ -83,6 +83,7 @@ public class IndexingRelationshipTypeRepresentationStrategyTest extends EntityTe Relationship rel = linkHits.getSingle(); assertEquals(rel(link), rel); assertEquals(link.getClass().getName(), rel.getProperty("__type__")); + linkHits.close(); } @Test @@ -104,6 +105,7 @@ public class IndexingRelationshipTypeRepresentationStrategyTest extends EntityTe IndexHits linkHits = typesIndex.get(IndexingNodeTypeRepresentationStrategy.INDEX_KEY, link.getClass().getName()); assertNull(linkHits.getSingle()); + linkHits.close(); } @Test diff --git a/spring-data-neo4j-cross-store/src/main/java/org/springframework/data/neo4j/cross_store/support/node/CrossStoreNodeEntityState.java b/spring-data-neo4j-cross-store/src/main/java/org/springframework/data/neo4j/cross_store/support/node/CrossStoreNodeEntityState.java index 5579ea0dd..6c5e42246 100644 --- a/spring-data-neo4j-cross-store/src/main/java/org/springframework/data/neo4j/cross_store/support/node/CrossStoreNodeEntityState.java +++ b/spring-data-neo4j-cross-store/src/main/java/org/springframework/data/neo4j/cross_store/support/node/CrossStoreNodeEntityState.java @@ -64,6 +64,7 @@ public class CrossStoreNodeEntityState extends Defaul final String foreignId = createForeignId(id); IndexHits indexHits = getForeignIdIndex().get(FOREIGN_ID, foreignId); Node node = indexHits.hasNext() ? indexHits.next() : null; + indexHits.close(); if (node == null) { node = template.createNode(); persistForeignId(node, id); diff --git a/spring-data-neo4j-rest/src/test/java/org/springframework/data/neo4j/rest/support/RestIndexTest.java b/spring-data-neo4j-rest/src/test/java/org/springframework/data/neo4j/rest/support/RestIndexTest.java index 4fc537be9..7d75c0dc5 100644 --- a/spring-data-neo4j-rest/src/test/java/org/springframework/data/neo4j/rest/support/RestIndexTest.java +++ b/spring-data-neo4j-rest/src/test/java/org/springframework/data/neo4j/rest/support/RestIndexTest.java @@ -37,6 +37,7 @@ public class RestIndexTest extends RestTestBase { IndexHits hits = nodeIndex().get("name", "test"); Assert.assertEquals("index results", true, hits.hasNext()); Assert.assertEquals(node(), hits.next()); + hits.close(); } @Test @@ -45,6 +46,7 @@ public class RestIndexTest extends RestTestBase { IndexHits hits = nodeIndex().query("name", "tes*"); Assert.assertEquals("index results", true, hits.hasNext()); Assert.assertEquals(node(), hits.next()); + hits.close(); } @Test @@ -53,12 +55,14 @@ public class RestIndexTest extends RestTestBase { IndexHits hits = nodeIndex().query("age", "age:[30 TO 40]"); Assert.assertEquals("index results", true, hits.hasNext()); Assert.assertEquals(node(), hits.next()); + hits.close(); } @Test public void testNotFoundInNodeIndex() { IndexHits hits = nodeIndex().get("foo", "bar"); Assert.assertEquals("no index results", false, hits.hasNext()); + hits.close(); } @Test @@ -68,12 +72,14 @@ public class RestIndexTest extends RestTestBase { IndexHits hits = relationshipIndex().get("name", value); Assert.assertEquals("index results", true, hits.hasNext()); Assert.assertEquals(relationship(), hits.next()); + hits.close(); } @Test public void testNotFoundInRelationshipIndex() { IndexHits hits = relationshipIndex().get("foo", "bar"); Assert.assertEquals("no index results", false, hits.hasNext()); + hits.close(); } @Test @@ -86,6 +92,8 @@ public class RestIndexTest extends RestTestBase { nodeIndex().remove(node(), "time", value); IndexHits hitsAfterRemove = nodeIndex().get("time", value); Assert.assertEquals("not found in index results", false, hitsAfterRemove.hasNext()); + hits.close(); + hitsAfterRemove.close(); } @Test @@ -98,6 +106,8 @@ public class RestIndexTest extends RestTestBase { relationshipIndex().remove(relationship(), "time", value); IndexHits hitsAfterRemove = relationshipIndex().get("time", value); Assert.assertEquals("not found in index results", false, hitsAfterRemove.hasNext()); + hits.close(); + hitsAfterRemove.close(); } private Index nodeIndex() {