From abec9f97f819fc8d193c20a5e2be98545bc9e3d8 Mon Sep 17 00:00:00 2001 From: Luca Frosini Date: Mon, 5 Feb 2024 16:32:08 +0100 Subject: [PATCH] Creating management of source and destination persistence --- .../persistence/AggregatorPersistence.java | 4 --- .../persistence/AggregatorPersistenceDst.java | 8 ++++++ .../persistence/AggregatorPersistenceSrc.java | 8 ++++++ .../AggregatorPersitenceConfiguration.java | 27 ------------------- 4 files changed, 16 insertions(+), 31 deletions(-) create mode 100644 src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceDst.java create mode 100644 src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceSrc.java delete mode 100644 src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersitenceConfiguration.java diff --git a/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistence.java b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistence.java index 4955b64..eb9359e 100644 --- a/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistence.java +++ b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistence.java @@ -5,8 +5,4 @@ package org.gcube.accounting.aggregator.persistence; */ public interface AggregatorPersistence { - public static final int KEY_VALUES_LIMIT = 25; - - public void prepareConnection(AggregatorPersitenceConfiguration configuration) throws Exception; - } diff --git a/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceDst.java b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceDst.java new file mode 100644 index 0000000..843bf35 --- /dev/null +++ b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceDst.java @@ -0,0 +1,8 @@ +package org.gcube.accounting.aggregator.persistence; + +/** + * @author Luca Frosini (ISTI - CNR) + */ +public interface AggregatorPersistenceDst extends AggregatorPersistence { + +} diff --git a/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceSrc.java b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceSrc.java new file mode 100644 index 0000000..70a8d04 --- /dev/null +++ b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersistenceSrc.java @@ -0,0 +1,8 @@ +package org.gcube.accounting.aggregator.persistence; + +/** + * @author Luca Frosini (ISTI - CNR) + */ +public interface AggregatorPersistenceSrc extends AggregatorPersistence { + +} diff --git a/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersitenceConfiguration.java b/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersitenceConfiguration.java deleted file mode 100644 index 28963f5..0000000 --- a/src/main/java/org/gcube/accounting/aggregator/persistence/AggregatorPersitenceConfiguration.java +++ /dev/null @@ -1,27 +0,0 @@ -package org.gcube.accounting.aggregator.persistence; - -import org.gcube.accounting.persistence.AccountingPersistenceConfiguration; - -/** - * @author Luca Frosini (ISTI-CNR) - * @author Alessandro Pieve (ISTI-CNR) - */ -public class AggregatorPersitenceConfiguration extends AccountingPersistenceConfiguration { - - /** - * Default Constructor - */ - public AggregatorPersitenceConfiguration() { - super(); - } - - /** - * @param persistence The class of the persistence to instantiate - * @throws Exception if fails - */ - @SuppressWarnings({ "rawtypes" }) - public AggregatorPersitenceConfiguration(Class persistence) throws Exception { - super((Class) persistence); - } - -} \ No newline at end of file