Browse Source

Minor refactoring for DedicatedEventsJpaDaoConfig

pull/11368/head
ViacheslavKlimov 2 years ago
parent
commit
9569812b5f
  1. 9
      dao/src/main/java/org/thingsboard/server/dao/config/DedicatedEventsJpaDaoConfig.java

9
dao/src/main/java/org/thingsboard/server/dao/config/DedicatedEventsJpaDaoConfig.java

@ -46,6 +46,7 @@ import java.util.Objects;
public class DedicatedEventsJpaDaoConfig { public class DedicatedEventsJpaDaoConfig {
public static final String EVENTS_PERSISTENCE_UNIT = "events"; public static final String EVENTS_PERSISTENCE_UNIT = "events";
public static final String EVENTS_DATA_SOURCE = EVENTS_PERSISTENCE_UNIT + "DataSource";
public static final String EVENTS_TRANSACTION_MANAGER = EVENTS_PERSISTENCE_UNIT + "TransactionManager"; public static final String EVENTS_TRANSACTION_MANAGER = EVENTS_PERSISTENCE_UNIT + "TransactionManager";
public static final String EVENTS_TRANSACTION_TEMPLATE = EVENTS_PERSISTENCE_UNIT + "TransactionTemplate"; public static final String EVENTS_TRANSACTION_TEMPLATE = EVENTS_PERSISTENCE_UNIT + "TransactionTemplate";
public static final String EVENTS_JDBC_TEMPLATE = EVENTS_PERSISTENCE_UNIT + "JdbcTemplate"; public static final String EVENTS_JDBC_TEMPLATE = EVENTS_PERSISTENCE_UNIT + "JdbcTemplate";
@ -57,14 +58,14 @@ public class DedicatedEventsJpaDaoConfig {
} }
@ConfigurationProperties(prefix = "spring.datasource.events.hikari") @ConfigurationProperties(prefix = "spring.datasource.events.hikari")
@Bean @Bean(EVENTS_DATA_SOURCE)
public DataSource eventsDataSource(@Qualifier("eventsDataSourceProperties") DataSourceProperties eventsDataSourceProperties) { public DataSource eventsDataSource(@Qualifier("eventsDataSourceProperties") DataSourceProperties eventsDataSourceProperties) {
return eventsDataSourceProperties.initializeDataSourceBuilder().type(HikariDataSource.class).build(); return eventsDataSourceProperties.initializeDataSourceBuilder().type(HikariDataSource.class).build();
} }
@Bean @Bean
public LocalContainerEntityManagerFactoryBean eventsEntityManagerFactory(@Qualifier("eventsDataSource") DataSource eventsDataSource, public LocalContainerEntityManagerFactoryBean eventsEntityManagerFactory(@Qualifier(EVENTS_DATA_SOURCE) DataSource eventsDataSource,
EntityManagerFactoryBuilder builder) { EntityManagerFactoryBuilder builder) {
return builder return builder
.dataSource(eventsDataSource) .dataSource(eventsDataSource)
.packages(LifecycleEventEntity.class, StatisticsEventEntity.class, ErrorEventEntity.class, RuleNodeDebugEventEntity.class, RuleChainDebugEventEntity.class, AuditLogEntity.class) .packages(LifecycleEventEntity.class, StatisticsEventEntity.class, ErrorEventEntity.class, RuleNodeDebugEventEntity.class, RuleChainDebugEventEntity.class, AuditLogEntity.class)
@ -83,7 +84,7 @@ public class DedicatedEventsJpaDaoConfig {
} }
@Bean(EVENTS_JDBC_TEMPLATE) @Bean(EVENTS_JDBC_TEMPLATE)
public JdbcTemplate eventsJdbcTemplate(@Qualifier("eventsDataSource") DataSource eventsDataSource) { public JdbcTemplate eventsJdbcTemplate(@Qualifier(EVENTS_DATA_SOURCE) DataSource eventsDataSource) {
return new JdbcTemplate(eventsDataSource); return new JdbcTemplate(eventsDataSource);
} }

Loading…
Cancel
Save