Skip to content

Commit 253bb40

Browse files
committed
Added test
1 parent 5d55ac7 commit 253bb40

File tree

1 file changed

+21
-1
lines changed

1 file changed

+21
-1
lines changed

spring-data-r2dbc/src/test/java/org/springframework/data/r2dbc/repository/ConvertingR2dbcRepositoryIntegrationTests.java

+21-1
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import io.r2dbc.spi.ConnectionFactory;
2121
import io.r2dbc.spi.Row;
22+
import reactor.core.publisher.Mono;
2223
import reactor.test.StepVerifier;
2324

2425
import java.util.Arrays;
@@ -51,6 +52,7 @@
5152
* Integration tests for {@link ConvertedRepository} that uses {@link Converter}s on entity-level.
5253
*
5354
* @author Mark Paluch
55+
* @author Sebastian Wieland
5456
*/
5557
@ExtendWith(SpringExtension.class)
5658
public class ConvertingR2dbcRepositoryIntegrationTests {
@@ -122,8 +124,26 @@ void shouldInsertAndReadItems() {
122124
}).verifyComplete();
123125
}
124126

125-
interface ConvertedRepository extends ReactiveCrudRepository<ConvertedEntity, Integer> {
127+
@Test
128+
void shouldNotUseConverterForCountQueries() {
129+
ConvertedEntity entity = new ConvertedEntity();
130+
entity.name = "name";
126131

132+
repository.save(entity) //
133+
.as(StepVerifier::create) //
134+
.expectNextCount(1) //
135+
.verifyComplete();
136+
137+
repository.countWithCustomQuery() //
138+
.as(StepVerifier::create) //
139+
.consumeNextWith(actual -> {
140+
assertThat(actual).isEqualTo(1L);
141+
}).verifyComplete();
142+
}
143+
144+
interface ConvertedRepository extends ReactiveCrudRepository<ConvertedEntity, Integer> {
145+
@Query("SELECT COUNT(*) FROM CONVERTED_ENTITY")
146+
Mono<Long> countWithCustomQuery();
127147
}
128148

129149
static class ConvertedEntity {

0 commit comments

Comments
 (0)