Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Increase code coverage - SQL Builder #337

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Increase code coverage - SQL Builder #337

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
56 changes: 55 additions & 1 deletion adapters/jdbc/src/test/java/org/atomhopper/jdbc/query/SqlBuilderTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,11 @@ public static class WhenCallingSearchSql {
private String result_next_with_cats_and_prefix = "(SELECT * FROM entries WHERE feed = ? AND datelastupdated = ? AND id < ? AND( categories @> ?::varchar[] AND tenantId = ? )) UNION ALL (SELECT * FROM entries WHERE feed = ? AND datelastupdated < ? AND( categories @> ?::varchar[] AND tenantId = ? )ORDER BY datelastupdated DESC, id DESC LIMIT 1) ORDER BY datelastupdated DESC, id DESC LIMIT 1";
private String result_next_with_cats_not_prefix = "(SELECT * FROM entries WHERE feed = ? AND datelastupdated = ? AND id < ? AND NOT ( categories @> ?::varchar[] AND tenantId = ? )) UNION ALL (SELECT * FROM entries WHERE feed = ? AND datelastupdated < ? AND NOT ( categories @> ?::varchar[] AND tenantId = ? )ORDER BY datelastupdated DESC, id DESC LIMIT 1) ORDER BY datelastupdated DESC, id DESC LIMIT 1";
private String result_next_with_cats_or_prefix = "(SELECT * FROM entries WHERE feed = ? AND datelastupdated = ? AND id < ? AND( categories @> ?::varchar[] OR tenantId = ? )) UNION ALL (SELECT * FROM entries WHERE feed = ? AND datelastupdated < ? AND( categories @> ?::varchar[] OR tenantId = ? )ORDER BY datelastupdated DESC, id DESC LIMIT 1) ORDER BY datelastupdated DESC, id DESC LIMIT 1";

private String result_forward_feed_delay = "(SELECT * FROM entries WHERE feed = ? AND datelastupdated = ? AND id > ? AND datelastupdated < now() - interval '1 seconds' ) UNION ALL (SELECT * FROM entries WHERE feed = ? AND datelastupdated > ? AND datelastupdated < now() - interval '1 seconds' ORDER BY datelastupdated ASC, id ASC LIMIT ?) ORDER BY datelastupdated ASC, id ASC LIMIT ?";
private String result_head_feed_delay = "SELECT * FROM entries WHERE feed = ? AND datelastupdated < now() - interval '1 seconds' ORDER BY datelastupdated DESC, id DESC LIMIT ?";
private String result_last_feed_delay = "SELECT * FROM entries WHERE feed = ? AND datelastupdated < now() - interval '1 seconds' ORDER BY datelastupdated ASC, id ASC LIMIT ?";


private DateTimeFormatter isoDTF = ISODateTimeFormat.dateTime();

private Map<String, String> map;
Expand All @@ -74,6 +78,17 @@ public void ShouldGetSqlForForward() throws Exception {

Assert.assertEquals(result_forward, result);
}

@Test
public void ShouldGetSqlForForwardwithFeedDelay() throws Exception {

SearchToSqlConverter searchToSqlConverter = new SearchToSqlConverter( map, PREFIX_SPLIT );
String result = new SqlBuilder( searchToSqlConverter )
.searchType(SearchType.FEED_FORWARD).feedHeadDelayInSeconds(1)
.toString();

Assert.assertEquals(result_forward_feed_delay, result);
}

@Test
public void ShouldGetSqlForBackward() throws Exception {
Expand All @@ -96,6 +111,17 @@ public void ShouldGetSqlForHead() throws Exception {

Assert.assertEquals(result_head, result);
}

@Test
public void ShouldGetSqlForHeadwithFeedDelay() throws Exception {
SearchToSqlConverter searchToSqlConverter = new SearchToSqlConverter( map, PREFIX_SPLIT );

String result = new SqlBuilder( searchToSqlConverter )
.searchType( SearchType.FEED_HEAD ).feedHeadDelayInSeconds(1)
.toString();

Assert.assertEquals(result_head_feed_delay, result);
}

@Test
public void ShouldGetSqlForLast() throws Exception {
Expand All @@ -107,6 +133,17 @@ public void ShouldGetSqlForLast() throws Exception {

Assert.assertEquals(result_last, result);
}

@Test
public void ShouldGetSqlForLastWithFeedDelay() throws Exception {
SearchToSqlConverter searchToSqlConverter = new SearchToSqlConverter( map, PREFIX_SPLIT );

String result = new SqlBuilder( searchToSqlConverter )
.searchType( SearchType.LAST_PAGE ).feedHeadDelayInSeconds(1)
.toString();

Assert.assertEquals(result_last_feed_delay, result);
}

@Test
public void ShouldGetSqlForNext() throws Exception {
Expand Down Expand Up @@ -396,5 +433,22 @@ public void shouldGetSelectWithTimestamp() throws Exception {
Assert.assertTrue("result string has timezone", result.contains("current_setting('TIMEZONE')"));
Assert.assertTrue("result string has correct time", result.contains(timestamp));
}

@Test
public void shouldGetSelectWithTimestampWithFeedDelay() throws Exception {
String startingTimestamp = "2014-03-03T08:51:32.000Z";
DateTime startAt = isoDTF.parseDateTime(startingTimestamp);
SearchToSqlConverter searchToSqlConverter = new SearchToSqlConverter( map, PREFIX_SPLIT );

String result = new SqlBuilder( searchToSqlConverter )
.searchType( SearchType.BY_TIMESTAMP_BACKWARD )
.startingTimestamp(startAt).feedHeadDelayInSeconds(1)
.toString();

String timestamp = startAt.getHourOfDay() + ":" + startAt.getMinuteOfHour() + ":" + startAt.getSecondOfMinute();
Assert.assertTrue("result string has timezone", result.contains("current_setting('TIMEZONE')"));
Assert.assertTrue("result string has correct time", result.contains(timestamp));
}

}
}