Compare commits

...

3 Commits

Author SHA1 Message Date
Luca Frosini bff3c2bed7 Improved changelog information 2024-03-11 17:16:56 +01:00
Luca Frosini bea1660252 Removed static usage 2024-02-29 16:13:50 +01:00
luca.frosini 2ffffd1515 Ignored MacOs File 2023-06-21 11:31:20 +02:00
4 changed files with 14 additions and 6 deletions

1
.gitignore vendored
View File

@ -28,3 +28,4 @@ hs_err_pid*
/.project
/.settings
/.DS_Store

View File

@ -2,6 +2,11 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
# Changelog for Document Store Backend Connector Library for PostgreSQL
## [v1.0.1-SNAPSHOT]
- Enhanced accounting-postgresql-utilities range
- Removed usage of static variable
## [v1.0.0]

View File

@ -10,7 +10,7 @@
<groupId>org.gcube.data.publishing</groupId>
<artifactId>document-store-lib-postgresql</artifactId>
<version>1.0.0</version>
<version>1.0.1-SNAPSHOT</version>
<name>Document Store Backend Connector Library for PostgreSQL</name>
<description>Document Store Backend Connector Library for PostgreSQL</description>
@ -51,7 +51,7 @@
<dependency>
<groupId>org.gcube.accounting</groupId>
<artifactId>accounting-postgresql-utilities</artifactId>
<version>[1.0.0, 2.0.0-SNAPSHOT)</version>
<version>[2.0.0-SNAPSHOT, 3.0.0-SNAPSHOT)</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.postgresql/postgresql -->
<dependency>

View File

@ -24,14 +24,16 @@ public class StatementMap {
};
private PersistenceBackendConfiguration configuration;
private RecordToDBMapping recordToDBMapping;
public StatementMap(PersistenceBackendConfiguration configuration) {
this.configuration = configuration;
this.recordToDBMapping = new RecordToDBMapping();
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);
recordToDBMapping.addRecordToDB(clz, configuration);
} catch (Exception e) {
new RuntimeException(e);
}
@ -39,10 +41,10 @@ public class StatementMap {
}
protected Connection getConnection(Class<? extends AggregatedRecord<?, ?>> clz) throws Exception {
RecordToDBConnection recordDBInfo = RecordToDBMapping.getRecordDBInfo(clz);
RecordToDBConnection recordDBInfo = recordToDBMapping.getRecordDBInfo(clz);
if(recordDBInfo == null) {
RecordToDBMapping.addRecordToDB(clz, configuration);
recordDBInfo = RecordToDBMapping.getRecordDBInfo(clz);
recordToDBMapping.addRecordToDB(clz, configuration);
recordDBInfo = recordToDBMapping.getRecordDBInfo(clz);
}
return recordDBInfo.getConnection();
}