Improved loading speed of data model extensions

FraunhoferIOSB · Nov 24, 2023 · e561b23 · e561b23
1 parent 9d6e84f
commit e561b23
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/...java/de/fraunhofer/iosb/ilt/frostserver/persistence/pgjooq/MariadbPersistenceManager.java b/...java/de/fraunhofer/iosb/ilt/frostserver/persistence/pgjooq/MariadbPersistenceManager.java
@@ -141,6 +141,8 @@ static final Moment parseMoment(String value) {
     private DSLContext dslContext;
     private String schemaPriority;
 
+    private final Map<Name, Table<?>> tableCache = new HashMap<>();
+
     /**
      * Tracker for the amount of data fetched form the DB by this PM.
      */
@@ -708,6 +710,10 @@ public Table<?> getDbTable(String tableName) {
 
     @Override
     public Table<?> getDbTable(Name tableName) {
+        return tableCache.computeIfAbsent(tableName, (t) -> readDbTableFromDb(tableName));
+    }
+
+    public Table<?> readDbTableFromDb(Name tableName) {
         final Meta meta = dslContext.meta();
         final List<Table<?>> tables = meta.getTables(tableName);
         if (tables.isEmpty()) {

diff --git a/...ava/de/fraunhofer/iosb/ilt/frostserver/persistence/pgjooq/PostgresPersistenceManager.java b/...ava/de/fraunhofer/iosb/ilt/frostserver/persistence/pgjooq/PostgresPersistenceManager.java
@@ -141,6 +141,8 @@ static final Moment parseMoment(String value) {
     private DSLContext dslContext;
     private String schemaPriority;
 
+    private final Map<Name, Table<?>> tableCache = new HashMap<>();
+
     /**
      * Tracker for the amount of data fetched form the DB by this PM.
      */
@@ -703,6 +705,10 @@ public Table<?> getDbTable(String tableName) {
 
     @Override
     public Table<?> getDbTable(Name tableName) {
+        return tableCache.computeIfAbsent(tableName, (t) -> readDbTableFromDb(tableName));
+    }
+
+    public Table<?> readDbTableFromDb(Name tableName) {
         final Meta meta = dslContext.meta();
         final List<Table<?>> tables = meta.getTables(tableName);
         if (tables.isEmpty()) {