|
47 | 47 | * @author Oliver Gierke
|
48 | 48 | * @author Maciej Walkowiak
|
49 | 49 | * @author Evgeni Dimitrov
|
| 50 | + * @author Mark Paluch |
50 | 51 | */
|
51 | 52 | public class JdbcRepositoryQueryUnitTests {
|
52 | 53 |
|
@@ -153,31 +154,31 @@ public void customResultSetExtractorAndRowMapperGetCombined() {
|
153 | 154 | .matches(crse -> crse.rowMapper != null, "RowMapper is not expected to be null");
|
154 | 155 | }
|
155 | 156 |
|
156 |
| - @Test // DATAJDBC-263 |
| 157 | + @Test // DATAJDBC-263, DATAJDBC-354 |
157 | 158 | public void publishesSingleEventWhenQueryReturnsSingleAggregate() {
|
158 | 159 |
|
159 | 160 | doReturn("some sql statement").when(queryMethod).getAnnotatedQuery();
|
160 | 161 | doReturn(false).when(queryMethod).isCollectionQuery();
|
161 | 162 | doReturn(new DummyEntity(1L)).when(operations).queryForObject(anyString(), any(SqlParameterSource.class),
|
162 | 163 | any(RowMapper.class));
|
163 | 164 | doReturn(true).when(context).hasPersistentEntityFor(DummyEntity.class);
|
164 |
| - when(context.getRequiredPersistentEntity(DummyEntity.class).getIdentifierAccessor(any()).getRequiredIdentifier()) |
| 165 | + when(context.getRequiredPersistentEntity(DummyEntity.class).getIdentifierAccessor(any()).getIdentifier()) |
165 | 166 | .thenReturn("some identifier");
|
166 | 167 |
|
167 | 168 | new JdbcRepositoryQuery(publisher, context, queryMethod, operations, defaultRowMapper).execute(new Object[] {});
|
168 | 169 |
|
169 | 170 | verify(publisher).publishEvent(any(AfterLoadEvent.class));
|
170 | 171 | }
|
171 | 172 |
|
172 |
| - @Test // DATAJDBC-263 |
| 173 | + @Test // DATAJDBC-263, DATAJDBC-354 |
173 | 174 | public void publishesAsManyEventsAsReturnedAggregates() {
|
174 | 175 |
|
175 | 176 | doReturn("some sql statement").when(queryMethod).getAnnotatedQuery();
|
176 | 177 | doReturn(true).when(queryMethod).isCollectionQuery();
|
177 | 178 | doReturn(Arrays.asList(new DummyEntity(1L), new DummyEntity(1L))).when(operations).query(anyString(),
|
178 | 179 | any(SqlParameterSource.class), any(RowMapper.class));
|
179 | 180 | doReturn(true).when(context).hasPersistentEntityFor(DummyEntity.class);
|
180 |
| - when(context.getRequiredPersistentEntity(DummyEntity.class).getIdentifierAccessor(any()).getRequiredIdentifier()) |
| 181 | + when(context.getRequiredPersistentEntity(DummyEntity.class).getIdentifierAccessor(any()).getIdentifier()) |
181 | 182 | .thenReturn("some identifier");
|
182 | 183 |
|
183 | 184 | new JdbcRepositoryQuery(publisher, context, queryMethod, operations, defaultRowMapper).execute(new Object[] {});
|
|
0 commit comments