added mongodb command builder for tsbs

src/main/java/de/uulm/omi/dbms/workload/api/impl/WorkloadApiServiceImpl.java

@@ -320,7 +320,7 @@ public class WorkloadApiServiceImpl extends WorkloadApiService {
     String loadCommand = "";
     loadCommand = TSBSCommandBuilder.generateLoadCommand(TSBS_BINARY, properties.getProperty(WorkloadApiProperties.WORKLOAD_DATA_FOLDER), workload.getDbms(), workload.getTsbsLoadExecution(),workload.getDbEndpoints());
     loadCommand += " &> " + properties.getProperty(WorkloadApiProperties.WORKLOAD_RESULTS_FOLDER) + TSBS_RESULT_FOLDER + taskId.trim() + "_load.txt";
-    
+
 
     workloadProcess
         .startWorkload(TSBS_BINARY, UNIX_SHELL, UNIX_COMMAND_PARAM, loadCommand, taskId,

src/main/java/de/uulm/omi/workload/tsbs/TSBSCommandBuilder.java

@@ -229,6 +229,8 @@ public class TSBSCommandBuilder {
             queriesCommand += timescaledbCommand(dbmsProperties, dbEndpoints,query);
         }else if(dbms.equals(DbmsEnum.CASSANDRA)){
             queriesCommand += cassandraCommand(dbmsProperties,dbEndpoints,query);
+        }else if(dbms.equals(DbmsEnum.MONGODB)){
+            queriesCommand += mongodbCommand(dbmsProperties,dbEndpoints,query);
         }
 
         else {
@@ -238,6 +240,27 @@ public class TSBSCommandBuilder {
         return queriesCommand;
     }
 
+    private static String mongodbCommand(List<TSDBMSDBMSProperties> dbmsProperties,
+        DBEndpoints dbEndpoints, Phase query){
+
+        String mongodbCommand = " ";
+
+        StringJoiner mongosHosts = new StringJoiner(",");
+
+        for (DBEndpoint dbEndpoint: dbEndpoints) {
+            mongosHosts.add(dbEndpoint.getIpAddress()+ ":27017");
+            LOGGER.warn("Custom ports for MongoDB currently not supported, using default port 27017!");
+
+        }
+
+        mongodbCommand += "--url " + mongosHosts;
+
+        //TODO: check for supported but optional MongoDB commands
+        //TODO: check if TSBS needs to be extended to support dedicated write and read consistency settings
+
+        return mongodbCommand;
+
+    }
 
     private static String influxCommand(
         List<TSDBMSDBMSProperties> dbmsProperties,