gCubeSystem
/
ecological-engine
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

IOHelper 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngine@92556 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Gianpaolo Coro 2014-03-03 14:18:50 +00:00
parent e2d41b8acb
commit ef44fa2376
2 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/org/gcube/contentmanagement/graphtools/utils/HttpRequest.java
View File

@ -3,6 +3,8 @@ package org.gcube.contentmanagement.graphtools.utils;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
@ -262,7 +264,7 @@ public class HttpRequest {
});
}
URL checkurl = new URL(url);
HttpURLConnection conn = (HttpURLConnection) checkurl.openConnection();
checkConn = conn.getResponseCode();
@ -273,6 +275,26 @@ public class HttpRequest {
return checkConn;
}
public static void downloadFile(String fileurl, String localFile) throws Exception {
URL smpFile = new URL(fileurl);
URLConnection uc = (URLConnection) smpFile.openConnection();
InputStream is = uc.getInputStream();
AnalysisLogger.getLogger().debug("GenericWorker-> Retrieving from " + fileurl + " to :" + localFile);
inputStreamToFile(is, localFile);
is.close();
is=null;
System.gc();
}
public static void inputStreamToFile(InputStream is, String path) throws FileNotFoundException, IOException {
FileOutputStream out = new FileOutputStream(new File(path));
byte buf[] = new byte[1024];
int len = 0;
while ((len = is.read(buf)) > 0)
out.write(buf, 0, len);
out.close();
}
public static void main(String[] args) {
String url = "http://geoserver-dev.d4science-ii.research-infrastructures.eu/geoserver/rest/layergroups/group4402c0cff-27e3-4606-a2f1-993ad37c3dfb.json";

8
src/main/java/org/gcube/dataanalysis/ecoengine/utils/IOHelper.java
View File

@ -6,9 +6,11 @@ import java.util.List;
import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration;
import org.gcube.dataanalysis.ecoengine.datatypes.DatabaseType;
import org.gcube.dataanalysis.ecoengine.datatypes.PrimitiveType;
import org.gcube.dataanalysis.ecoengine.datatypes.ServiceType;
import org.gcube.dataanalysis.ecoengine.datatypes.StatisticalType;
import org.gcube.dataanalysis.ecoengine.datatypes.enumtypes.DatabaseParameters;
import org.gcube.dataanalysis.ecoengine.datatypes.enumtypes.PrimitiveTypes;
import org.gcube.dataanalysis.ecoengine.datatypes.enumtypes.ServiceParameters;
public class IOHelper {
@ -42,10 +44,16 @@ public class IOHelper {
inputs.add(new PrimitiveType(Double.class.getName(), null, PrimitiveTypes.NUMBER, name,description,defaultvalue));
}
public static void addRandomStringInput(List<StatisticalType> inputs,String name,String description, String defaultPrefix) {
inputs.add(new ServiceType(ServiceParameters.RANDOMSTRING, name,description,defaultPrefix));
}
public static void addOutputString(LinkedHashMap<String, String> outputParameters, String name, String value) {
outputParameters.put(name, value);
}
public static String getInputParameter(AlgorithmConfiguration config, String paramName) {
return config.getParam(paramName);
}