Merge branch 'racecommittee_app'

This commit is contained in:
Axel Uhl committed 2013-09-20 09:59:17 +02:00
commit 873d5344fc
6 files changed
+15 -8

No files matched your search

@@ -1009,11 +1009,8 @@ public class DomainObjectFactoryImpl implements DomainObjectFactory {
query.put(FieldNames.RACE_LOG_IDENTIFIER.name(), TripleSerializer.serialize(identifier.getIdentifier()));
loadRaceLogEvents(result, query);
// query for obsolete events
query.put(FieldNames.RACE_LOG_IDENTIFIER.name(), MongoUtils.escapeDollarAndDot(String.format("%s.%s.%s",
identifier.getTemplate().getParentObjectName(),
identifier.getRaceColumnName(),
identifier.getFleetName())));
// query for events with deprecated identifier format
query.put(FieldNames.RACE_LOG_IDENTIFIER.name(), MongoUtils.escapeDollarAndDot(identifier.getDeprecatedIdentifier()));
loadRaceLogEvents(result, query);
} catch (Throwable t) {
// something went wrong during DB access; report, then use empty new race log
@@ -12,6 +12,8 @@ public interface RaceLogIdentifier extends Serializable {
Triple<String, String, String> getIdentifier();
String getDeprecatedIdentifier();
RaceLogIdentifierTemplate getTemplate();
}
@@ -25,6 +25,14 @@ public class RaceLogIdentifierImpl implements RaceLogIdentifier {
return new Util.Triple<String, String, String>(template.getParentObjectName(), raceColumnName, fleetName);
}
@Override
public String getDeprecatedIdentifier() {
return String.format("%s.%s.%s",
this.getTemplate().getParentObjectName(),
this.getRaceColumnName(),
this.getFleetName());
}
@Override
public RaceLogIdentifierTemplate getTemplate() {
return template;
@@ -108,7 +108,7 @@ public class StoreAndLoadRaceLogsTest extends AbstractMongoDBTest {
}
@Test
public void testdLoadObsoleteAndNewIdentifier() {
public void testLoadObsoleteAndNewIdentifier() {
// event1 stored with obsolete identifier
DBObject dbEvent1 = (DBObject) com.mongodb.util.JSON.parse(createOldFormatRaceLogEventJson(UUID.randomUUID()));
mongoFactory.getRaceLogCollection().insert(dbEvent1);
@@ -270,7 +270,7 @@ public class TestStoringAndRetrievingRaceLogInLeaderboards extends RaceLogMongoD
result.put(FieldNames.RACE_LOG_EVENT_CLASS.name(), RaceLogFinishPositioningConfirmedEvent.class.getSimpleName());
DBObject raceLogResult = new BasicDBObject();
raceLogResult.put(FieldNames.RACE_LOG_IDENTIFIER.name(), MongoUtils.escapeDollarAndDot(raceColumn.getRaceLogIdentifier(defaultFleet).getIdentifier().toString()));
raceLogResult.put(FieldNames.RACE_LOG_IDENTIFIER.name(), MongoUtils.escapeDollarAndDot(raceColumn.getRaceLogIdentifier(defaultFleet).getDeprecatedIdentifier()));
raceLogResult.put(FieldNames.RACE_LOG_EVENT.name(), result);
MongoObjectFactoryImpl factoryImpl = (MongoObjectFactoryImpl) mongoObjectFactory;
@@ -337,7 +337,7 @@ public class TestStoringAndRetrievingRaceLogInRegatta extends RaceLogMongoDBTest
result.put(FieldNames.RACE_LOG_EVENT_CLASS.name(), RaceLogFinishPositioningConfirmedEvent.class.getSimpleName());
DBObject raceLogResult = new BasicDBObject();
raceLogResult.put(FieldNames.RACE_LOG_IDENTIFIER.name(), MongoUtils.escapeDollarAndDot(raceColumn.getRaceLogIdentifier(fleet).getIdentifier().toString()));
raceLogResult.put(FieldNames.RACE_LOG_IDENTIFIER.name(), MongoUtils.escapeDollarAndDot(raceColumn.getRaceLogIdentifier(fleet).getDeprecatedIdentifier()));
raceLogResult.put(FieldNames.RACE_LOG_EVENT.name(), result);
MongoObjectFactoryImpl factoryImpl = (MongoObjectFactoryImpl) mongoObjectFactory;