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

Original pull request: #554.

Author: schauder

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

@@ -44,6 +44,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
@@ -175,4 +176,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

@@ -41,6 +41,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
@@ -204,11 +205,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;
@@ -2105,6 +2106,20 @@ 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.save(person3);
+
+			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

@@ -109,6 +109,7 @@
  * @author Gerrit Meier
  * @author Michael J. Simons
  * @author Philipp Tölle
+ * @author Jens Schauder
  */
 @ExtendWith(Neo4jExtension.class)
 @SpringJUnitConfig
@@ -2033,6 +2034,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()) {