From 3a5e2b385419dd1ceca0e2fd6ac7fafe238ee265 Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Fri, 26 Mar 2021 10:26:42 +0100
Subject: [PATCH] Fixed code

---
 .../persistence/PersistencePostgreSQL.java      | 17 ++---------------
 1 file changed, 2 insertions(+), 15 deletions(-)

diff --git a/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java b/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java
index b061371..ad43ef6 100644
--- a/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java
+++ b/src/main/java/org/gcube/documentstore/persistence/PersistencePostgreSQL.java
@@ -4,13 +4,9 @@
 package org.gcube.documentstore.persistence;
 
 import java.sql.Statement;
-import java.util.Map;
 
 import org.gcube.accounting.utility.postgresql.PostgreSQLQuery;
-import org.gcube.accounting.utility.postgresql.RecordToDBMapping;
-import org.gcube.documentstore.records.AggregatedRecord;
 import org.gcube.documentstore.records.Record;
-import org.gcube.documentstore.records.RecordUtility;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -24,17 +20,8 @@ public class PersistencePostgreSQL extends PersistenceBackend {
 	protected StatementMap statementMap;
 
 	@Override
-	protected void prepareConnection(PersistenceBackendConfiguration configuration) throws Exception {
-		statementMap = new StatementMap(configuration);
-		Map<String, Class<? extends AggregatedRecord<?,?>>> aggregatedRecords = RecordUtility.getAggregatedRecordClassesFound();
-		for(String typeName : aggregatedRecords.keySet()) {
-			try {
-				Class<? extends AggregatedRecord<?,?>> clz = aggregatedRecords.get(typeName); 
-				RecordToDBMapping.addRecordToDB(clz, configuration);
-			} catch (Exception e) {
-				new RuntimeException(e);
-			}
-		}
+	public void prepareConnection(PersistenceBackendConfiguration configuration) throws Exception {
+		this.statementMap = new StatementMap(configuration);
 	}
 
 	@Override