-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #20 from CJSCommonPlatform/update-to-latest-framework
Added a page size when reading stream of events
- Loading branch information
Showing
12 changed files
with
295 additions
and
28 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
133 changes: 133 additions & 0 deletions
133
.../uk/gov/justice/services/eventsourcing/repository/jdbc/event/EventJdbcRepositoryTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,133 @@ | ||
| package uk.gov.justice.services.eventsourcing.repository.jdbc.event; | ||
|
|
||
| import static java.util.UUID.randomUUID; | ||
| import static org.hamcrest.CoreMatchers.is; | ||
| import static org.junit.Assert.assertThat; | ||
| import static org.junit.Assert.fail; | ||
| import static org.mockito.Mockito.mock; | ||
| import static org.mockito.Mockito.verify; | ||
| import static org.mockito.Mockito.when; | ||
| import static uk.gov.justice.services.eventsourcing.repository.jdbc.event.EventJdbcRepository.SQL_FIND_BY_STREAM_ID; | ||
| import static uk.gov.justice.services.eventsourcing.repository.jdbc.event.EventJdbcRepository.SQL_FIND_BY_STREAM_ID_AND_POSITION; | ||
| import static uk.gov.justice.services.eventsourcing.repository.jdbc.event.EventJdbcRepository.SQL_FIND_BY_STREAM_ID_AND_POSITION_BY_PAGE; | ||
|
|
||
| import uk.gov.justice.services.eventsourcing.repository.jdbc.EventInsertionStrategy; | ||
| import uk.gov.justice.services.jdbc.persistence.JdbcDataSourceProvider; | ||
| import uk.gov.justice.services.jdbc.persistence.JdbcRepositoryException; | ||
| import uk.gov.justice.services.jdbc.persistence.JdbcRepositoryHelper; | ||
|
|
||
| import java.sql.SQLException; | ||
| import java.util.UUID; | ||
|
|
||
| import javax.sql.DataSource; | ||
|
|
||
| import org.junit.Before; | ||
| import org.junit.Test; | ||
| import org.junit.runner.RunWith; | ||
| import org.mockito.Mock; | ||
| import org.mockito.runners.MockitoJUnitRunner; | ||
| import org.slf4j.Logger; | ||
|
|
||
| @RunWith(MockitoJUnitRunner.class) | ||
| public class EventJdbcRepositoryTest { | ||
|
|
||
| @Mock | ||
| private EventInsertionStrategy eventInsertionStrategy; | ||
|
|
||
| @Mock | ||
| private JdbcRepositoryHelper jdbcRepositoryHelper; | ||
|
|
||
| @Mock | ||
| private JdbcDataSourceProvider jdbcDataSourceProvider; | ||
|
|
||
| @Mock | ||
| private Logger logger; | ||
|
|
||
| private String jndiDatasource; | ||
| private EventJdbcRepository eventJdbcRepository; | ||
|
|
||
| @Before | ||
| public void setup() throws Exception { | ||
| eventJdbcRepository = new EventJdbcRepository(eventInsertionStrategy, jdbcRepositoryHelper, jdbcDataSourceProvider, jndiDatasource, logger); | ||
| } | ||
|
|
||
| @Test | ||
| public void shouldLogAndThrowExceptionIfSqlExceptionIsThrownInInsert() throws Exception { | ||
| final UUID streamId = randomUUID(); | ||
| final DataSource dataSource = mock(DataSource.class); | ||
| final SQLException sqlException = new SQLException(); | ||
| final String statement = "STATEMENT"; | ||
| final Event event = mock(Event.class); | ||
|
|
||
| when(jdbcDataSourceProvider.getDataSource(jndiDatasource)).thenReturn(dataSource); | ||
| when(eventInsertionStrategy.insertStatement()).thenReturn(statement); | ||
| when(jdbcRepositoryHelper.preparedStatementWrapperOf(dataSource, statement)).thenThrow(sqlException); | ||
| when(event.getSequenceId()).thenReturn(5L); | ||
| when(event.getStreamId()).thenReturn(streamId); | ||
|
|
||
| try { | ||
| eventJdbcRepository.insert(event); | ||
| fail(); | ||
| } catch (final JdbcRepositoryException e) { | ||
| assertThat(e.getMessage(), is("Exception while storing sequence 5 of stream " + streamId)); | ||
| verify(logger).error("Error persisting event to the database", sqlException); | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| public void shouldLogAndThrowExceptionIfSqlExceptionIsThrownInFindByStreamIdOrderByPositionAsc() throws Exception { | ||
| final UUID streamId = randomUUID(); | ||
| final DataSource dataSource = mock(DataSource.class); | ||
| final SQLException sqlException = new SQLException(); | ||
|
|
||
| when(jdbcDataSourceProvider.getDataSource(jndiDatasource)).thenReturn(dataSource); | ||
| when(jdbcRepositoryHelper.preparedStatementWrapperOf(dataSource, SQL_FIND_BY_STREAM_ID)).thenThrow(sqlException); | ||
|
|
||
| try { | ||
| eventJdbcRepository.findByStreamIdOrderByPositionAsc(streamId); | ||
| fail(); | ||
| } catch (final JdbcRepositoryException e) { | ||
| assertThat(e.getMessage(), is("Exception while reading stream " + streamId)); | ||
| verify(logger).warn("Failed to read stream {}", streamId, sqlException); | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| public void shouldLogAndThrowExceptionIfSqlExceptionIsThrownInFindByStreamIdFromPositionOrderByPositionAsc() throws Exception { | ||
| final UUID streamId = randomUUID(); | ||
| final long position = 2L; | ||
| final DataSource dataSource = mock(DataSource.class); | ||
| final SQLException sqlException = new SQLException(); | ||
|
|
||
| when(jdbcDataSourceProvider.getDataSource(jndiDatasource)).thenReturn(dataSource); | ||
| when(jdbcRepositoryHelper.preparedStatementWrapperOf(dataSource, SQL_FIND_BY_STREAM_ID_AND_POSITION)).thenThrow(sqlException); | ||
|
|
||
| try { | ||
| eventJdbcRepository.findByStreamIdFromPositionOrderByPositionAsc(streamId, position); | ||
| fail(); | ||
| } catch (final JdbcRepositoryException e) { | ||
| assertThat(e.getMessage(), is("Exception while reading stream " + streamId)); | ||
| verify(logger).warn("Failed to read stream {}", streamId, sqlException); | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| public void shouldLogAndThrowExceptionIfSqlExceptionIsThrownInFindByStreamIdFromPositionOrderByPositionAscWithPage() throws Exception { | ||
| final UUID streamId = randomUUID(); | ||
| final long position = 2L; | ||
| final int pageSize = 10; | ||
| final DataSource dataSource = mock(DataSource.class); | ||
| final SQLException sqlException = new SQLException(); | ||
|
|
||
| when(jdbcDataSourceProvider.getDataSource(jndiDatasource)).thenReturn(dataSource); | ||
| when(jdbcRepositoryHelper.preparedStatementWrapperOf(dataSource, SQL_FIND_BY_STREAM_ID_AND_POSITION_BY_PAGE)).thenThrow(sqlException); | ||
|
|
||
| try { | ||
| eventJdbcRepository.findByStreamIdFromPositionOrderByPositionAsc(streamId, position, pageSize); | ||
| fail(); | ||
| } catch (final JdbcRepositoryException e) { | ||
| assertThat(e.getMessage(), is("Exception while reading stream " + streamId)); | ||
| verify(logger).warn("Failed to read stream {}", streamId, sqlException); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.