Skip to content

Commit e2bf36a

Browse files
authored
Restore disabled JdbcJobDaoTests (#5174)
Signed-off-by: Yanming Zhou <[email protected]>
1 parent 0343720 commit e2bf36a

File tree

2 files changed

+5
-22
lines changed

2 files changed

+5
-22
lines changed

spring-batch-core/src/test/java/org/springframework/batch/core/repository/dao/AbstractJobDaoTests.java

Lines changed: 5 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@
4343
/**
4444
* @author Dave Syer
4545
* @author Mahmoud Ben Hassine
46+
* @author Yanming Zhou
4647
*
4748
*/
4849
public abstract class AbstractJobDaoTests {
@@ -92,7 +93,7 @@ void onSetUpInTransaction() {
9293

9394
// Create an execution
9495
jobExecutionStartTime = LocalDateTime.now();
95-
jobExecution = new JobExecution(1L, jobInstance, jobParameters);
96+
jobExecution = jobExecutionDao.createJobExecution(jobInstance, jobParameters);
9697
jobExecution.setStartTime(jobExecutionStartTime);
9798
jobExecution.setStatus(BatchStatus.STARTED);
9899
jobExecutionDao.updateJobExecution(jobExecution);
@@ -112,7 +113,7 @@ void testVersionIsNotNullForJobExecution() {
112113
int version = jdbcTemplate.queryForObject(
113114
"select version from BATCH_JOB_EXECUTION where JOB_EXECUTION_ID=" + jobExecution.getId(),
114115
Integer.class);
115-
assertEquals(0, version);
116+
assertEquals(1, version);
116117
}
117118

118119
@Transactional
@@ -193,7 +194,7 @@ void testUpdateInvalidJobExecution() {
193194
// id is invalid
194195
JobExecution execution = new JobExecution(29432L, jobInstance, jobParameters);
195196
execution.incrementVersion();
196-
assertThrows(NoSuchObjectException.class, () -> jobExecutionDao.updateJobExecution(execution));
197+
assertThrows(RuntimeException.class, () -> jobExecutionDao.updateJobExecution(execution));
197198
}
198199

199200
@Transactional
@@ -254,10 +255,8 @@ private void validateJobExecution(JobExecution lhs, JobExecution rhs) {
254255
@Transactional
255256
@Test
256257
void testGetLastJobExecution() {
257-
assertEquals(null, jobExecutionDao.getLastJobExecution(jobInstance));
258258

259-
JobExecution lastExecution = new JobExecution(1L, jobInstance, jobParameters);
260-
lastExecution.setStatus(BatchStatus.STARTED);
259+
JobExecution lastExecution = jobExecutionDao.getLastJobExecution(jobInstance);
261260

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

294-
@Transactional
295-
@Test
296-
void testSaveAddsVersionAndId() {
297-
298-
JobExecution jobExecution = new JobExecution(1L, jobInstance, jobParameters);
299-
300-
assertNull(jobExecution.getId());
301-
assertNull(jobExecution.getVersion());
302-
303-
jobExecutionDao.updateJobExecution(jobExecution);
304-
305-
assertNotNull(jobExecution.getId());
306-
assertNotNull(jobExecution.getVersion());
307-
}
308-
309293
@Transactional
310294
@Test
311295
void testUpdateIncrementsVersion() {

spring-batch-core/src/test/java/org/springframework/batch/core/repository/dao/jdbc/JdbcJobDaoTests.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232

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

3837
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 ";

0 commit comments

Comments
 (0)