Inject table name for logs (fixes #96)

bekk · Jul 9, 2024 · 6081a5c · 6081a5c
1 parent d5a72e1
commit 6081a5c
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 5 deletions.
diff --git a/...ter/src/main/java/no/bekk/dbscheduler/uistarter/autoconfigure/UiApiAutoConfiguration.java b/...ter/src/main/java/no/bekk/dbscheduler/uistarter/autoconfigure/UiApiAutoConfiguration.java
@@ -76,12 +76,14 @@ LogLogic logLogic(
       DataSource dataSource,
       Caching caching,
       DbSchedulerCustomizer customizer,
-      DbSchedulerUiProperties properties) {
+      DbSchedulerUiProperties properties,
+      @Value("${db-scheduler-log.table-name:scheduled_execution_logs}") String logTableName) {
     return new LogLogic(
         dataSource,
         customizer.serializer().orElse(Serializer.DEFAULT_JAVA_SERIALIZER),
         caching,
-        properties.isTaskData());
+        properties.isTaskData(),
+        logTableName);
   }
 
   @Bean

diff --git a/db-scheduler-ui/src/main/java/no/bekk/dbscheduler/ui/service/LogLogic.java b/db-scheduler-ui/src/main/java/no/bekk/dbscheduler/ui/service/LogLogic.java
@@ -42,12 +42,19 @@ public class LogLogic {
   private final NamedParameterJdbcTemplate namedParameterJdbcTemplate;
   private final Caching caching;
   private final LogModelRowMapper logModelRowMapper;
-
-  public LogLogic(DataSource dataSource, Serializer serializer, Caching caching, boolean showData) {
+  private final String logTableName;
+
+  public LogLogic(
+      DataSource dataSource,
+      Serializer serializer,
+      Caching caching,
+      boolean showData,
+      String logTableName) {
     this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
     // currently we have no paging in the UI
     this.namedParameterJdbcTemplate.getJdbcTemplate().setMaxRows(DEFAULT_LIMIT);
     this.caching = caching;
+    this.logTableName = logTableName;
     this.logModelRowMapper =
         new LogModelRowMapper(
             showData, serializer == null ? Serializer.DEFAULT_JAVA_SERIALIZER : serializer);
@@ -79,7 +86,7 @@ public LogPollResponse pollLogs(TaskDetailsRequestParams requestParams) {
   }
 
   public List<LogModel> getLogsDirectlyFromDB(TaskDetailsRequestParams requestParams) {
-    QueryBuilder queryBuilder = QueryBuilder.selectFromTable("scheduled_execution_logs");
+    QueryBuilder queryBuilder = QueryBuilder.selectFromTable(logTableName);
     if (requestParams.getStartTime() != null) {
       queryBuilder.andCondition(
           new TimeCondition(