Skip to content

Commit de69c46

Browse files
committed
Issue #491 : Added unit test coverage
1 parent bc6be51 commit de69c46

File tree

1 file changed

+23
-0
lines changed

1 file changed

+23
-0
lines changed

quartz-core/src/test/java/org/quartz/impl/jdbcjobstore/StdJDBCDelegateTest.java

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
*/
1616
package org.quartz.impl.jdbcjobstore;
1717

18+
import static org.junit.Assert.assertThat;
1819
import static org.mockito.Matchers.any;
1920
import static org.mockito.Matchers.anyString;
2021
import static org.mockito.Mockito.mock;
@@ -27,7 +28,9 @@
2728
import java.sql.PreparedStatement;
2829
import java.sql.ResultSet;
2930
import java.sql.SQLException;
31+
import java.util.List;
3032

33+
import org.hamcrest.collection.IsIterableWithSize;
3134
import org.quartz.JobPersistenceException;
3235
import org.quartz.TriggerKey;
3336
import org.quartz.spi.OperableTrigger;
@@ -135,6 +138,26 @@ public void testSelectSimpleTriggerWithDeleteBeforeSelectExtendedProps() throws
135138
verify(persistenceDelegate).loadExtendedTriggerProperties(any(Connection.class), any(TriggerKey.class));
136139
}
137140

141+
public void testSelectTriggerToAcquireHonorsMaxCount() throws SQLException {
142+
143+
StdJDBCDelegate jdbcDelegate = new StdJDBCDelegate();
144+
145+
Connection conn = mock(Connection.class);
146+
PreparedStatement preparedStatement = mock(PreparedStatement.class);
147+
ResultSet resultSet = mock(ResultSet.class);
148+
149+
when(conn.prepareStatement(anyString())).thenReturn(preparedStatement);
150+
151+
when(preparedStatement.executeQuery()).thenReturn(resultSet);
152+
153+
when(resultSet.next()).thenReturn(true);
154+
when(resultSet.getString(anyString())).thenReturn("test");
155+
156+
List<TriggerKey> triggerKeys = jdbcDelegate.selectTriggerToAcquire(conn, Long.MAX_VALUE, Long.MIN_VALUE, 10);
157+
158+
assertThat(triggerKeys, IsIterableWithSize.<TriggerKey>iterableWithSize(10));
159+
}
160+
138161
static class TestStdJDBCDelegate extends StdJDBCDelegate {
139162

140163
private final TriggerPersistenceDelegate testDelegate;

0 commit comments

Comments
 (0)