|
|
|
@ -105,7 +105,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
SampleEntity second = new SampleEntity(23L, "Alfred E."); |
|
|
|
SampleEntity second = new SampleEntity(23L, "Alfred E."); |
|
|
|
SampleEntity third = new SampleEntity(23L, "Neumann"); |
|
|
|
SampleEntity third = new SampleEntity(23L, "Neumann"); |
|
|
|
|
|
|
|
|
|
|
|
when(callbacks.callback(any(Class.class), any(), any())).thenReturn(second, third); |
|
|
|
when(callbacks.callback(any(Class.class), any(), any(Object.class))).thenReturn(second, third); |
|
|
|
|
|
|
|
|
|
|
|
SampleEntity last = template.save(first); |
|
|
|
SampleEntity last = template.save(first); |
|
|
|
|
|
|
|
|
|
|
|
@ -119,7 +119,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert() { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert() { |
|
|
|
|
|
|
|
|
|
|
|
EntityWithVersion entity = new EntityWithVersion(1L); |
|
|
|
EntityWithVersion entity = new EntityWithVersion(1L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -134,7 +134,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert_whenVersionPropertyIsImmutable() { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert_whenVersionPropertyIsImmutable() { |
|
|
|
|
|
|
|
|
|
|
|
EntityWithImmutableVersion entity = new EntityWithImmutableVersion(1L, null); |
|
|
|
EntityWithImmutableVersion entity = new EntityWithImmutableVersion(1L, null); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -149,7 +149,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert_whenVersionPropertyIsPrimitiveType() { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert_whenVersionPropertyIsPrimitiveType() { |
|
|
|
|
|
|
|
|
|
|
|
EntityWithPrimitiveVersion entity = new EntityWithPrimitiveVersion(1L); |
|
|
|
EntityWithPrimitiveVersion entity = new EntityWithPrimitiveVersion(1L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -164,7 +164,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert__whenVersionPropertyIsImmutableAndPrimitiveType() { |
|
|
|
void savePreparesInstanceWithInitialVersion_onInsert__whenVersionPropertyIsImmutableAndPrimitiveType() { |
|
|
|
|
|
|
|
|
|
|
|
EntityWithImmutablePrimitiveVersion entity = new EntityWithImmutablePrimitiveVersion(1L, 0L); |
|
|
|
EntityWithImmutablePrimitiveVersion entity = new EntityWithImmutablePrimitiveVersion(1L, 0L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -182,7 +182,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
when(dataAccessStrategy.updateWithVersion(any(), any(), any())).thenReturn(true); |
|
|
|
when(dataAccessStrategy.updateWithVersion(any(), any(), any())).thenReturn(true); |
|
|
|
EntityWithVersion entity = new EntityWithVersion(1L); |
|
|
|
EntityWithVersion entity = new EntityWithVersion(1L); |
|
|
|
entity.setVersion(1L); |
|
|
|
entity.setVersion(1L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -199,7 +199,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
when(dataAccessStrategy.updateWithVersion(any(), any(), any())).thenReturn(true); |
|
|
|
when(dataAccessStrategy.updateWithVersion(any(), any(), any())).thenReturn(true); |
|
|
|
EntityWithVersion entity = new EntityWithVersion(1L); |
|
|
|
EntityWithVersion entity = new EntityWithVersion(1L); |
|
|
|
entity.setVersion(1L); |
|
|
|
entity.setVersion(1L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -215,7 +215,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
|
|
|
|
|
|
|
|
when(dataAccessStrategy.updateWithVersion(any(), any(), any())).thenReturn(true); |
|
|
|
when(dataAccessStrategy.updateWithVersion(any(), any(), any())).thenReturn(true); |
|
|
|
EntityWithImmutableVersion entity = new EntityWithImmutableVersion(1L, 1L); |
|
|
|
EntityWithImmutableVersion entity = new EntityWithImmutableVersion(1L, 1L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.save(entity); |
|
|
|
template.save(entity); |
|
|
|
|
|
|
|
|
|
|
|
@ -229,7 +229,7 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
void deletePreparesChangeWithPreviousVersion_onDeleteByInstance() { |
|
|
|
void deletePreparesChangeWithPreviousVersion_onDeleteByInstance() { |
|
|
|
|
|
|
|
|
|
|
|
EntityWithImmutableVersion entity = new EntityWithImmutableVersion(1L, 1L); |
|
|
|
EntityWithImmutableVersion entity = new EntityWithImmutableVersion(1L, 1L); |
|
|
|
when(callbacks.callback(any(), any(), any())).thenReturn(entity, entity); |
|
|
|
when(callbacks.callback(any(), any(), any(Object.class))).thenReturn(entity, entity); |
|
|
|
|
|
|
|
|
|
|
|
template.delete(entity, EntityWithImmutableVersion.class); |
|
|
|
template.delete(entity, EntityWithImmutableVersion.class); |
|
|
|
|
|
|
|
|
|
|
|
@ -265,10 +265,10 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
|
|
|
|
|
|
|
|
when(dataAccessStrategy.findAll(SampleEntity.class)).thenReturn(asList(alfred1, neumann1)); |
|
|
|
when(dataAccessStrategy.findAll(SampleEntity.class)).thenReturn(asList(alfred1, neumann1)); |
|
|
|
|
|
|
|
|
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred1), any())).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred1), any(Object[].class))).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred2), any())).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred2), any(Object[].class))).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann1), any())).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann1), any(Object[].class))).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann2), any())).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann2), any(Object[].class))).thenReturn(neumann2); |
|
|
|
|
|
|
|
|
|
|
|
Iterable<SampleEntity> all = template.findAll(SampleEntity.class); |
|
|
|
Iterable<SampleEntity> all = template.findAll(SampleEntity.class); |
|
|
|
|
|
|
|
|
|
|
|
@ -289,10 +289,10 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
|
|
|
|
|
|
|
|
when(dataAccessStrategy.findAll(SampleEntity.class, Sort.by("name"))).thenReturn(asList(alfred1, neumann1)); |
|
|
|
when(dataAccessStrategy.findAll(SampleEntity.class, Sort.by("name"))).thenReturn(asList(alfred1, neumann1)); |
|
|
|
|
|
|
|
|
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred1), any())).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred1), any(Object[].class))).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred2), any())).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred2), any(Object[].class))).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann1), any())).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann1), any(Object[].class))).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann2), any())).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann2), any(Object[].class))).thenReturn(neumann2); |
|
|
|
|
|
|
|
|
|
|
|
Iterable<SampleEntity> all = template.findAll(SampleEntity.class, Sort.by("name")); |
|
|
|
Iterable<SampleEntity> all = template.findAll(SampleEntity.class, Sort.by("name")); |
|
|
|
|
|
|
|
|
|
|
|
@ -315,10 +315,10 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
|
|
|
|
|
|
|
|
when(dataAccessStrategy.findAll(SampleEntity.class, PageRequest.of(0, 20))).thenReturn(asList(alfred1, neumann1)); |
|
|
|
when(dataAccessStrategy.findAll(SampleEntity.class, PageRequest.of(0, 20))).thenReturn(asList(alfred1, neumann1)); |
|
|
|
|
|
|
|
|
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred1), any())).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred1), any(Object[].class))).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred2), any())).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(alfred2), any(Object[].class))).thenReturn(alfred2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann1), any())).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann1), any(Object[].class))).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann2), any())).thenReturn(neumann2); |
|
|
|
when(callbacks.callback(any(Class.class), eq(neumann2), any(Object[].class))).thenReturn(neumann2); |
|
|
|
|
|
|
|
|
|
|
|
Iterable<SampleEntity> all = template.findAll(SampleEntity.class, PageRequest.of(0, 20)); |
|
|
|
Iterable<SampleEntity> all = template.findAll(SampleEntity.class, PageRequest.of(0, 20)); |
|
|
|
|
|
|
|
|
|
|
|
@ -334,7 +334,8 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
@AllArgsConstructor |
|
|
|
@AllArgsConstructor |
|
|
|
private static class SampleEntity { |
|
|
|
private static class SampleEntity { |
|
|
|
|
|
|
|
|
|
|
|
@Column("id1") @Id private Long id; |
|
|
|
@Column("id1") |
|
|
|
|
|
|
|
@Id private Long id; |
|
|
|
|
|
|
|
|
|
|
|
private String name; |
|
|
|
private String name; |
|
|
|
} |
|
|
|
} |
|
|
|
@ -343,7 +344,8 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
@RequiredArgsConstructor |
|
|
|
@RequiredArgsConstructor |
|
|
|
private static class EntityWithVersion { |
|
|
|
private static class EntityWithVersion { |
|
|
|
|
|
|
|
|
|
|
|
@Column("id1") @Id private final Long id; |
|
|
|
@Column("id1") |
|
|
|
|
|
|
|
@Id private final Long id; |
|
|
|
|
|
|
|
|
|
|
|
@Version private Long version; |
|
|
|
@Version private Long version; |
|
|
|
} |
|
|
|
} |
|
|
|
@ -352,7 +354,8 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
@RequiredArgsConstructor |
|
|
|
@RequiredArgsConstructor |
|
|
|
private static class EntityWithImmutableVersion { |
|
|
|
private static class EntityWithImmutableVersion { |
|
|
|
|
|
|
|
|
|
|
|
@Column("id1") @Id private final Long id; |
|
|
|
@Column("id1") |
|
|
|
|
|
|
|
@Id private final Long id; |
|
|
|
|
|
|
|
|
|
|
|
@Version private final Long version; |
|
|
|
@Version private final Long version; |
|
|
|
} |
|
|
|
} |
|
|
|
@ -361,7 +364,8 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
@RequiredArgsConstructor |
|
|
|
@RequiredArgsConstructor |
|
|
|
private static class EntityWithPrimitiveVersion { |
|
|
|
private static class EntityWithPrimitiveVersion { |
|
|
|
|
|
|
|
|
|
|
|
@Column("id1") @Id private final Long id; |
|
|
|
@Column("id1") |
|
|
|
|
|
|
|
@Id private final Long id; |
|
|
|
|
|
|
|
|
|
|
|
@Version private long version; |
|
|
|
@Version private long version; |
|
|
|
} |
|
|
|
} |
|
|
|
@ -370,7 +374,8 @@ public class JdbcAggregateTemplateUnitTests { |
|
|
|
@RequiredArgsConstructor |
|
|
|
@RequiredArgsConstructor |
|
|
|
private static class EntityWithImmutablePrimitiveVersion { |
|
|
|
private static class EntityWithImmutablePrimitiveVersion { |
|
|
|
|
|
|
|
|
|
|
|
@Column("id1") @Id private final Long id; |
|
|
|
@Column("id1") |
|
|
|
|
|
|
|
@Id private final Long id; |
|
|
|
|
|
|
|
|
|
|
|
@Version private final long version; |
|
|
|
@Version private final long version; |
|
|
|
} |
|
|
|
} |
|
|
|
|