gCubeSystem
/
accounting-analytics-persistence-postgresql
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fixing lib

This commit is contained in:
Luca Frosini 2021-03-18 17:05:33 +01:00
parent bf5e518232
commit cc4427a12b
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQL.java
View File

@ -74,7 +74,7 @@ public class AccountingPersistenceQueryPostgreSQL implements AccountingPersisten
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);
}

10
src/main/java/org/gcube/accounting/analytics/persistence/postgresql/Query.java
View File

@ -23,7 +23,7 @@ public class Query extends PostgreSQLQuery {
public static final String DATE_OF_TIMESERIES_AS_FIELD = AggregatedRecord.START_TIME;
private Class<? extends AggregatedRecord<?, ?>> clz;
private final RecordToDBFields recordToDBMapper;
private final RecordToDBFields recordToDBFields;
private List<String> requestedTableField;
@ -33,7 +33,7 @@ public class Query extends PostgreSQLQuery {
public Query(Class<? extends AggregatedRecord<?, ?>> clz) throws Exception {
this.clz = clz;
this.recordToDBMapper = RecordToDBMapping.getRecordToDB(clz);
this.recordToDBFields = RecordToDBMapping.getRecordToDBFields(clz);
}
public List<String> getRequestedTableField() {
@ -61,11 +61,11 @@ public class Query extends PostgreSQLQuery {
public RecordToDBFields getRecordToDBMapper() {
return recordToDBMapper;
return recordToDBFields;
}
protected String getTableField(String fieldName) {
return recordToDBMapper.getTableField(fieldName);
return recordToDBFields.getTableField(fieldName);
}
protected void appendTableField(String fieldName) {
@ -220,7 +220,7 @@ public class Query extends PostgreSQLQuery {
addEmittedFields();
stringBuffer.append(" FROM ");
stringBuffer.append(recordToDBMapper.getTableName());
stringBuffer.append(recordToDBFields.getTableName());
addTemporalConstraintToQuery();