Fixed bug

This commit is contained in:
Luca Frosini 2021-03-19 13:12:21 +01:00
parent 3c27c95cf3
commit dc8e1fafdd
1 changed files with 7 additions and 1 deletions

View File

@ -37,11 +37,17 @@ public class RecordToDBMapping {
recordToDBInfo.put(type, recordDBInfo);
}
@SuppressWarnings("unchecked")
public static synchronized RecordToDBFields getRecordToDBFields(Class<? extends Record> clz) throws Exception {
String type = getRecordTypeByClass(clz);
RecordToDBFields recordToDBFields = classToRecordToDBMapper.get(type);
if(recordToDBFields == null) {
Class<? extends AggregatedRecord<?,?>> aggregatedRecordClass = RecordUtility.getAggregatedRecordClass(type);
Class<? extends AggregatedRecord<?,?>> aggregatedRecordClass;
if(AggregatedRecord.class.isAssignableFrom(clz)) {
aggregatedRecordClass = (Class<? extends AggregatedRecord<?, ?>>) clz;
}else {
aggregatedRecordClass = RecordUtility.getAggregatedRecordClass(type);
}
recordToDBFields = new RecordToDBFields(type, aggregatedRecordClass);
classToRecordToDBMapper.put(type, recordToDBFields);
}