Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@
/**
* @author Dave Syer
* @author Mahmoud Ben Hassine
* @author Yanming Zhou
*
*/
public abstract class AbstractJobDaoTests {
Expand Down Expand Up @@ -92,7 +93,7 @@ void onSetUpInTransaction() {

// Create an execution
jobExecutionStartTime = LocalDateTime.now();
jobExecution = new JobExecution(1L, jobInstance, jobParameters);
jobExecution = jobExecutionDao.createJobExecution(jobInstance, jobParameters);
jobExecution.setStartTime(jobExecutionStartTime);
jobExecution.setStatus(BatchStatus.STARTED);
jobExecutionDao.updateJobExecution(jobExecution);
Expand All @@ -112,7 +113,7 @@ void testVersionIsNotNullForJobExecution() {
int version = jdbcTemplate.queryForObject(
"select version from BATCH_JOB_EXECUTION where JOB_EXECUTION_ID=" + jobExecution.getId(),
Integer.class);
assertEquals(0, version);
assertEquals(1, version);
}

@Transactional
Expand Down Expand Up @@ -193,7 +194,7 @@ void testUpdateInvalidJobExecution() {
// id is invalid
JobExecution execution = new JobExecution(29432L, jobInstance, jobParameters);
execution.incrementVersion();
assertThrows(NoSuchObjectException.class, () -> jobExecutionDao.updateJobExecution(execution));
assertThrows(RuntimeException.class, () -> jobExecutionDao.updateJobExecution(execution));
}

@Transactional
Expand Down Expand Up @@ -254,10 +255,8 @@ private void validateJobExecution(JobExecution lhs, JobExecution rhs) {
@Transactional
@Test
void testGetLastJobExecution() {
assertEquals(null, jobExecutionDao.getLastJobExecution(jobInstance));

JobExecution lastExecution = new JobExecution(1L, jobInstance, jobParameters);
lastExecution.setStatus(BatchStatus.STARTED);
JobExecution lastExecution = jobExecutionDao.getLastJobExecution(jobInstance);

int JUMP_INTO_FUTURE = 1000; // makes sure start time is 'greatest'
lastExecution.setCreateTime(LocalDateTime.now().plus(JUMP_INTO_FUTURE, ChronoUnit.MILLIS));
Expand Down Expand Up @@ -291,21 +290,6 @@ void testCreationAddsVersion() {
assertNotNull(jobInstance.getVersion());
}

@Transactional
@Test
void testSaveAddsVersionAndId() {

JobExecution jobExecution = new JobExecution(1L, jobInstance, jobParameters);

assertNull(jobExecution.getId());
assertNull(jobExecution.getVersion());

jobExecutionDao.updateJobExecution(jobExecution);

assertNotNull(jobExecution.getId());
assertNotNull(jobExecution.getVersion());
}

@Transactional
@Test
void testUpdateIncrementsVersion() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@

@SpringJUnitConfig(locations = { "sql-dao-test.xml" })
// TODO refactor using black-box testing instead of white-box testing
@Disabled
public class JdbcJobDaoTests extends AbstractJobDaoTests {

public static final String LONG_STRING = "A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String A very long String ";
Expand Down