diff --git a/src/main/java/org/gcube/dataaccess/algorithms/drmalgorithms/SubmitQuery.java b/src/main/java/org/gcube/dataaccess/algorithms/drmalgorithms/SubmitQuery.java index 6e0ded8..f2104d3 100644 --- a/src/main/java/org/gcube/dataaccess/algorithms/drmalgorithms/SubmitQuery.java +++ b/src/main/java/org/gcube/dataaccess/algorithms/drmalgorithms/SubmitQuery.java @@ -552,7 +552,7 @@ public class SubmitQuery extends StandardLocalExternalAlgorithm { // sf, config.getPersistencePath()); result = mgt - .submitQuery(query, dbconnection); + .submitQuery(query, dbconnection, config.getPersistencePath()); } if (driverInfo.toLowerCase().contains("mysql")) { @@ -563,7 +563,7 @@ public class SubmitQuery extends StandardLocalExternalAlgorithm { // sf, config.getPersistencePath()); result = mgt - .submitQuery(query, dbconnection); + .submitQuery(query, dbconnection, config.getPersistencePath()); } if (result == null) { @@ -575,7 +575,8 @@ public class SubmitQuery extends StandardLocalExternalAlgorithm { HashMap mapResult = new HashMap(); mapResult = mgt.getMapQueryResult(); - +// System.out.println("map size alg with header: " + mapResult.size()); + String encoded = null; encoded = new String(mapResult.get("HEADERS").getBytes(), "UTF-8"); @@ -594,8 +595,8 @@ public class SubmitQuery extends StandardLocalExternalAlgorithm { .getBytes(), "UTF-8"); // // check the encoded value - // AnalysisLogger.getLogger().debug( - // "In RandomSampleOnTable->string encoded: " + encoded); +// AnalysisLogger.getLogger().debug( +// "In RandomSampleOnTable->string encoded: " + encoded); PrimitiveType val1 = new PrimitiveType(String.class.getName(), encoded, PrimitiveTypes.STRING, "Row", "Row"); @@ -603,16 +604,16 @@ public class SubmitQuery extends StandardLocalExternalAlgorithm { // //check value contained in map // String value = (String) val1.getContent(); // - // AnalysisLogger.getLogger().debug( - // "In RandomSampleOnTable->value: " + value); +// AnalysisLogger.getLogger().debug( +// "In RandomSampleOnTable->value: " + value); } // to add the file - // PrimitiveType fileResult = new - // PrimitiveType(File.class.getName(), - // mgt.getFileQueryResult(), PrimitiveTypes.FILE, "File", - // "File"); - // mapResults.put("File", fileResult); + PrimitiveType fileResult = new + PrimitiveType(File.class.getName(), + mgt.getFileQueryResult(), PrimitiveTypes.FILE, "File", + "File"); + mapResults.put("File", fileResult); } return mapResults; }