Spring/spring-data-r2dbc
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#498 - Implements ReactiveCrudRepository.deleteAllById.

Browse Source 
See also: DATACMNS-800.
Original pull request: #501.
This commit is contained in:
Jens Schauder
2020-11-13 15:50:26 +01:00
committed by Mark Paluch
parent 1d5e5cc6c3
commit 843c402e00
2 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/test/java/org/springframework/data/r2dbc/repository/support/AbstractSimpleR2dbcRepositoryIntegrationTests.java
View File

@@ -16,6 +16,7 @@
package org.springframework.data.r2dbc.repository.support;
import static org.assertj.core.api.Assertions.*;
import static org.testcontainers.shaded.com.google.common.primitives.Ints.*;
import lombok.AllArgsConstructor;
import lombok.Data;
@@ -57,6 +58,7 @@ import org.springframework.r2dbc.core.DatabaseClient;
* @author Mark Paluch
* @author Bogdan Ilchyshyn
* @author Stephen Cohen
* @author Jens Schauder
*/
public abstract class AbstractSimpleR2dbcRepositoryIntegrationTests extends R2dbcIntegrationTestSupport {
@@ -465,6 +467,20 @@ public abstract class AbstractSimpleR2dbcRepositoryIntegrationTests extends R2db
assertThat(count).isEqualTo(0);
}
@Test // gh-498
void shouldDeleteAllById() {
jdbc.execute("INSERT INTO legoset (name, manual) VALUES('SCHAUFELRADBAGGER', 12)");
Integer id = jdbc.queryForObject("SELECT id FROM legoset", Integer.class);
repository.deleteAllById(asList(id)) //
.as(StepVerifier::create) //
.verifyComplete();
Integer count = jdbc.queryForObject("SELECT COUNT(*) FROM legoset", Integer.class);
assertThat(count).isEqualTo(0);
}
@Data
@Table("legoset")
@AllArgsConstructor