Заявление:
- Весенняя загрузочная версия 2.2.13.RELEASE
- postgresql версии 42.2.10
- кварц версия 2.3.2
- кварцевая версия 2.3.2
Я реализовал кварц заданий, который вызывает метод, реализованный в bean-компоненте @Service. В этом методе есть взаимодействие с двумя базами данных (Oracle и PostgreSql). Каждая БД инициализируется пулом соединений Hikari.
БД Postgresql в bean-компоненте конфигурации:
@Bean(value="sreDataSource")
public DataSource dataSource() {
HikariConfig hikariConfig = new HikariConfig();
hikariConfig.setDriverClassName(driverClassName);
hikariConfig.setJdbcUrl(datasourceUrl);
hikariConfig.setUsername(datasourceUsername);
hikariConfig.setPassword(datasourcePassword);
hikariConfig.setConnectionInitSql("set time zone 'UTC'");
hikariConfig.setMaximumPoolSize(maxPoolSize);
hikariConfig.setConnectionTestQuery("SELECT 1");
hikariConfig.setPoolName("springHikariCP");
return new HikariDataSource(hikariConfig);
}
/**
* @return {@link JdbcTemplate}
*/
@Bean(value="sreJdbcTemplate")
public JdbcTemplate jdbcTemplate() {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource());
jdbcTemplate.setFetchSize(Integer.parseInt(fetchSize));
jdbcTemplate.setQueryTimeout(60);
return jdbcTemplate;
}
/**
* Create the namedJdbcTemplate bean for the SRE database
* @return {@link NamedParameterJdbcTemplate}
*/
@Bean(value="sreNamedParameterJdbcTemplate")
public NamedParameterJdbcTemplate namedParameterJdbcTemplate() {
return new NamedParameterJdbcTemplate(jdbcTemplate());
}
/**
* @param dataSource
* @return {@link PlatformTransactionManager}
*/
@Bean(value="sreTransactionManager")
public PlatformTransactionManager transactionManager(@Qualifier("sreDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
/**
* @param sreTransactionManager
* @param assetTransactionManager
* @return {@link ChainedTransactionManager}
*/
@Bean(value="chainedTransactionManager")
public ChainedTransactionManager transactionManager(@Qualifier("sreTransactionManager") PlatformTransactionManager sreTransactionManager,
@Qualifier("assetTransactionManager") PlatformTransactionManager assetTransactionManager) {
return new ChainedTransactionManager(sreTransactionManager, assetTransactionManager);
}
БД Oracle в bean-компоненте конфигурации:
/**
* Datasource
* @return Datasource
*/
@Bean(value="assetDataSource")
public DataSource dataSource() {
HikariConfig hikariConfig = new HikariConfig();
hikariConfig.setDriverClassName(driverClassName);
hikariConfig.setJdbcUrl(datasourceUrl);
hikariConfig.setUsername(datasourceUsername);
hikariConfig.setPassword(datasourcePassword);
hikariConfig.addDataSourceProperty("oracle.jdbc.timezoneAsRegion", "false");
hikariConfig.setMaximumPoolSize(maxPoolSize);
hikariConfig.setConnectionTestQuery("SELECT 1 from dual");
hikariConfig.setPoolName("springHikariAssetCp");
return new HikariDataSource(hikariConfig);
}
/**
* JDBCTemplate
* @return JDBCTemplate
*/
@Bean(value="assetJdbcTemplate")
public JdbcTemplate jdbcTemplate() {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource());
jdbcTemplate.setFetchSize(Integer.parseInt(fetchSize));
jdbcTemplate.setQueryTimeout(60);
return jdbcTemplate;
}
/**
* Create the namedJdbcTemplate bean for the RMD database
* @return NamedParameterJdbcTemplate
*/
@Bean(value="assetNamedParameterJdbcTemplate")
public NamedParameterJdbcTemplate namedParameterJdbcTemplate() {
return new NamedParameterJdbcTemplate(jdbcTemplate());
}
/**
* Create transaction manager
* @param dataSource Datasource
* @return transaction manager
*/
@Bean(value="assetTransactionManager")
public PlatformTransactionManager transactionManager(@Qualifier("assetDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
Служебный компонент вызывается из кварца заданий в кластере. Служебный компонент определяется следующим образом:
/**
* @author sgalgani
*
*/
@Service("processSreService")
@Transactional("chainedTransactionManager")
public class ProcessSreServiceImpl implements ProcessSreService {
private static final Logger LOGGER = LogManager.getLogger(ProcessSreServiceImpl.class);
@Autowired
@Qualifier("historianService")
private HistorianService historianService;
@Autowired
@Qualifier("sreEvolutionService")
private SreEvolutionService sreEvolutionService;
@Autowired
@Qualifier("assetService")
private AssetService assetService;
@Autowired
@Qualifier("configService")
private ConfigService configService;
@Autowired
@Qualifier("engineSupportService")
private EngineSupportService engineSupportService;
@Autowired
@Qualifier("tagAvailabilityService")
private TagAvailabilityService tagAvailabilityService;
@Autowired
@Qualifier("engineTransformService")
private EngineTransformService engineTransformService;
@Autowired
@Qualifier("quarantineService")
private QuarantineService quarantineService;
@Autowired
@Qualifier("simpleRuleEventService")
private SimpleRuleEventService simpleRuleEventService;
@Value("${save.oracle.temporary.results}")
private boolean saveOracleTemporaryResults;
@Value("${enable.save.local.db.alerts}")
private boolean enableSaveLocalDbAlerts;
@Value("${simple.rule.event.service.enable}")
private boolean simpleRuleEventServiceEnable;
@SuppressWarnings("javadoc")
@Override
@Transactional(value = "chainedTransactionManager", rollbackFor = Exception.class, timeout = 120)
public void processSre(Sre sre, List<TagLastTimestamp> tagsLastTimestamp, Metric metrics) throws Exception {
LOGGER.info("[processSre] for JobId : {} and lineup: {} ",sre.getId(), sre.getLineupId() );
После аварийного переключения БД на Amazon RDS postgresql (потеря соединения с БД) я бы ожидал исключения тайм-аута транзакции через 120 секунд, но тайм-аут не работает, почему?
