DATAGRAPH-1428 - Implement deleteAllById(Iterable<ID> ids).

Author: schauder

src/main/java/org/springframework/data/neo4j/repository/support/SimpleNeo4jRepository.java

@@ -43,6 +43,7 @@
  * @author Gerrit Meier
  * @author Michael J. Simons
  * @author Ján Šúr
+ * @author Jens Schauder
  * @since 6.0
  * @param <T> the type of the domain class managed by this repository
  * @param <ID> the type of the unique identifier of the domain class
@@ -168,4 +169,11 @@ public void deleteAll(Iterable<? extends T> entities) {
 
 		this.neo4jOperations.deleteAllById(ids, this.entityInformation.getJavaType());
 	}
+
+	@Override
+	@Transactional
+	public void deleteAllById(Iterable<? extends ID> ids) {
+
+		this.neo4jOperations.deleteAllById(ids, this.entityInformation.getJavaType());
+	}
 }

src/main/java/org/springframework/data/neo4j/repository/support/SimpleReactiveNeo4jRepository.java

@@ -40,6 +40,7 @@
  *
  * @author Gerrit Meier
  * @author Michael J. Simons
+ * @author Jens Schauder
  * @since 6.0
  * @param <T> the type of the domain class managed by this repository
  * @param <ID> the type of the unique identifier of the domain class
@@ -195,11 +196,20 @@ public Mono<Void> deleteAll() {
 	public Mono<Void> deleteAll(Iterable<? extends T> entities) {
 
 		Assert.notNull(entities, "The given Iterable of entities must not be null!");
+
 		List<ID> ids = StreamSupport.stream(entities.spliterator(), false).map(this.entityInformation::getId)
 				.collect(Collectors.toList());
 		return this.neo4jOperations.deleteAllById(ids, this.entityInformation.getJavaType());
 	}
 
+	@Override
+	public Mono<Void> deleteAllById(Iterable<? extends ID> ids) {
+
+		Assert.notNull(ids, "The given Iterable of ids must not be null!");
+
+		return this.neo4jOperations.deleteAllById(ids, this.entityInformation.getJavaType());
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.repository.reactive.ReactiveCrudRepository#deleteAll(org.reactivestreams.Publisher)

src/test/java/org/springframework/data/neo4j/integration/imperative/RepositoryIT.java

@@ -20,6 +20,7 @@
 import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
 import static org.assertj.core.api.Assertions.tuple;
 
+import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
@@ -1892,6 +1893,18 @@ void deleteAllEntities(@Autowired PersonRepository repository) {
 			assertThat(repository.existsById(id2)).isFalse();
 		}
 
+		@Test // DATAGRAPH-1428
+		void deleteAllById(@Autowired PersonRepository repository) {
+
+			PersonWithAllConstructor person3 = new PersonWithAllConstructor(id1, TEST_PERSON1_NAME, TEST_PERSON1_FIRST_NAME,
+					TEST_PERSON_SAMEVALUE, true, 1L, TEST_PERSON1_BORN_ON, "something", Arrays.asList("a", "b"), NEO4J_HQ,
+					Instant.now());
+
+			repository.deleteAllById(Arrays.asList(person1.getId(), person3.getId()));
+
+			assertThat(repository.findAll()).extracting(PersonWithAllConstructor::getId).containsExactly(id2);
+		}
+
 		@Test
 		void deleteAll(@Autowired PersonRepository repository) {
 

src/test/java/org/springframework/data/neo4j/integration/reactive/ReactiveRepositoryIT.java

@@ -104,6 +104,7 @@
  * @author Gerrit Meier
  * @author Michael J. Simons
  * @author Philipp Tölle
+ * @author Jens Schauder
  */
 @ExtendWith(Neo4jExtension.class)
 @SpringJUnitConfig
@@ -1910,6 +1911,13 @@ void deleteAllEntitiesPublisher(@Autowired ReactivePersonRepository repository)
 					.concatWith(repository.existsById(id2)).as(StepVerifier::create).expectNext(false, false).verifyComplete();
 		}
 
+		@Test // DATAGRAPH-1428
+		void deleteAllById(@Autowired ReactivePersonRepository repository) {
+
+			repository.deleteAllById(Arrays.asList(person1.getId(), person2.getId())).then(repository.existsById(id1))
+					.concatWith(repository.existsById(id2)).as(StepVerifier::create).expectNext(false, false).verifyComplete();
+		}
+
 		@Test
 		void deleteSimpleRelationship(@Autowired ReactiveRelationshipRepository repository) {
 			try (Session session = createSession()) {