diff --git a/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java b/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java
index 1b67f33..a66d215 100644
--- a/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java
+++ b/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java
@@ -30,7 +30,7 @@ public class PersistencePostgreSQL extends PersistenceBackend {
 		for(String typeName : aggregatedRecords.keySet()) {
 			try {
 				Class<? extends AggregatedRecord<?,?>> clz = aggregatedRecords.get(typeName); 
-				RecordToDBMapping.getRecordToDB(clz);
+				RecordToDBMapping.addRecordToDB(clz, configuration);
 			} catch (Exception e) {
 				new RuntimeException(e);
 			}
diff --git a/src/main/java/org/gcube/documentstore/persistence/StatementMap.java b/src/main/java/org/gcube/documentstore/persistence/StatementMap.java
index 93014c6..5c84f47 100644
--- a/src/main/java/org/gcube/documentstore/persistence/StatementMap.java
+++ b/src/main/java/org/gcube/documentstore/persistence/StatementMap.java
@@ -31,7 +31,7 @@ public class StatementMap {
 		for(String typeName : aggregatedRecords.keySet()) {
 			try {
 				Class<? extends AggregatedRecord<?,?>> clz = aggregatedRecords.get(typeName); 
-				RecordToDBMapping.getRecordToDB(clz);
+				RecordToDBMapping.addRecordToDB(clz, configuration);
 			} catch (Exception e) {
 				new RuntimeException(e);
 			}