| | |
| | | |
| | | // The name is defined in the job definition |
| | | String jobName = jobDetail.getName(); |
| | | String targetSchemaName = null; |
| | | |
| | | // Log the time the job started |
| | | logger.info(jobName + " fired at " + new Date()); |
| | |
| | | throw new JobExecutionException("Cannot connect source oracle database."); |
| | | } |
| | | |
| | | AbstractOracleJobContext jobContext = prepareJobContext(_filterPath); |
| | | AbstractOracleJobContext jobContext = prepareJobContext(targetSchemaName, _filterPath); |
| | | jobContext.setSourceDataStore(getSourceDataStore()); |
| | | |
| | | try |
| | |
| | | return logger; |
| | | } |
| | | |
| | | protected AbstractOracleJobContext prepareJobContext(String filterPath) |
| | | protected AbstractOracleJobContext prepareJobContext(String targetSchemaName, String filterPath) |
| | | { |
| | | return new OracleUpgradeJobContext(); |
| | | } |