eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-20 12:45:35 +00:00
Code Activity

bug5014: added replication support for ExpeditionDeviceConfiguration; security ID solely based on UUID now

Browse Source
This commit is contained in:
Axel Uhl
2020-06-16 18:39:27 +02:00
parent e99cf6397c
commit b0bd5d2f12
13 changed files with 130 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.expeditionconnector.persistence/src/com/sap/sailing/expeditionconnector/persistence/MongoObjectFactory.java
+3 -1
View File
@@ -1,9 +1,11 @@
package com.sap.sailing.expeditionconnector.persistence;
import java.util.UUID;
import com.sap.sailing.expeditionconnector.ExpeditionDeviceConfiguration;
public interface MongoObjectFactory {
void storeExpeditionDeviceConfiguration(ExpeditionDeviceConfiguration expeditionDeviceConfiguration);
void removeExpeditionDeviceConfiguration(ExpeditionDeviceConfiguration expeditionDeviceConfiguration);
void removeExpeditionDeviceConfiguration(UUID expeditionDeviceConfigurationId);
}
java/com.sap.sailing.expeditionconnector.persistence/src/com/sap/sailing/expeditionconnector/persistence/impl/MongoObjectFactoryImpl.java
+6 -5
View File
@@ -1,5 +1,6 @@
package com.sap.sailing.expeditionconnector.persistence.impl;
import java.util.UUID;
import java.util.logging.Level;
import java.util.logging.Logger;
@@ -25,14 +26,14 @@ public class MongoObjectFactoryImpl implements MongoObjectFactory {
expeditionDeviceConfigurationsCollection.createIndex(index, new IndexOptions().name("uuidindex").unique(true).background(false));
}
private Document getExpeditionDeviceConfigurationDBKey(ExpeditionDeviceConfiguration expeditionDeviceConfiguration) {
final Document basicDBObject = new Document(FieldNames.EXPEDITION_DEVICE_CONFIGURATION_UUID.name(), expeditionDeviceConfiguration.getDeviceUuid());
private Document getExpeditionDeviceConfigurationDBKey(UUID expeditionDeviceConfigurationId) {
final Document basicDBObject = new Document(FieldNames.EXPEDITION_DEVICE_CONFIGURATION_UUID.name(), expeditionDeviceConfigurationId);
return basicDBObject;
}
@Override
public void storeExpeditionDeviceConfiguration(ExpeditionDeviceConfiguration expeditionDeviceConfiguration) {
final Document key = getExpeditionDeviceConfigurationDBKey(expeditionDeviceConfiguration);
final Document key = getExpeditionDeviceConfigurationDBKey(expeditionDeviceConfiguration.getDeviceUuid());
final Document expeditionDeviceConfigurationDBObject = new Document();
expeditionDeviceConfigurationDBObject.put(FieldNames.EXPEDITION_DEVICE_CONFIGURATION_UUID.name(), expeditionDeviceConfiguration.getDeviceUuid());
expeditionDeviceConfigurationDBObject.put(FieldNames.EXPEDITION_DEVICE_CONFIGURATION_NAME.name(), expeditionDeviceConfiguration.getName());
@@ -56,7 +57,7 @@ public class MongoObjectFactoryImpl implements MongoObjectFactory {
}
@Override
public void removeExpeditionDeviceConfiguration(ExpeditionDeviceConfiguration expeditionDeviceConfiguration) {
expeditionDeviceConfigurationsCollection.withWriteConcern(WriteConcern.ACKNOWLEDGED).deleteOne(getExpeditionDeviceConfigurationDBKey(expeditionDeviceConfiguration));
public void removeExpeditionDeviceConfiguration(UUID expeditionDeviceConfigurationId) {
expeditionDeviceConfigurationsCollection.withWriteConcern(WriteConcern.ACKNOWLEDGED).deleteOne(getExpeditionDeviceConfigurationDBKey(expeditionDeviceConfigurationId));
}
}