git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineGeoSpatialExtension@75208 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
parent
57f39dcd64
commit
138f029cf5
|
|
@ -10,17 +10,16 @@ import org.gcube.dataanalysis.ecoengine.utils.DatabaseUtils;
|
|||
import org.gcube.dataanalysis.ecoengine.utils.Tuple;
|
||||
import org.gcube.dataanalysis.geo.retrieval.GeoIntersector;
|
||||
import org.gcube.dataanalysis.geo.utils.CSquareCodesConverter;
|
||||
import org.gcube.dataanalysis.geo.utils.EnvDataExplorer;
|
||||
import org.hibernate.SessionFactory;
|
||||
|
||||
/**
|
||||
* transforms a raster map into a table
|
||||
*
|
||||
* @author coro
|
||||
*
|
||||
*
|
||||
*/
|
||||
public class RasterTable {
|
||||
|
||||
private double resolution;
|
||||
private double valuesMatrix[][];
|
||||
double x1;
|
||||
double x2;
|
||||
|
|
@ -28,74 +27,98 @@ public class RasterTable {
|
|||
double y2;
|
||||
double z;
|
||||
double xResolution;
|
||||
double yResolution;
|
||||
|
||||
double yResolution;
|
||||
|
||||
private AlgorithmConfiguration configuration;
|
||||
private String tablename = ""+UUID.randomUUID();
|
||||
private String tablename = "rstr" + ("" + UUID.randomUUID()).replace("-", "");
|
||||
static String createTableStatement = "CREATE TABLE %1$s (csquarecode character varying, x real, y real, z real, probability real)";
|
||||
static String columnsnames = "csquarecode, x , y , z , probability";
|
||||
|
||||
|
||||
public String getTablename() {
|
||||
return tablename;
|
||||
}
|
||||
|
||||
|
||||
public void setTablename(String tablename) {
|
||||
this.tablename = tablename;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
public RasterTable(double x1, double x2, double y1, double y2, double z, double xResolution, double yResolution, double[][] values, AlgorithmConfiguration configuration){
|
||||
this.valuesMatrix=values;
|
||||
this.configuration=configuration;
|
||||
this.x1=x1;
|
||||
this.x2=x2;
|
||||
this.y1=y1;
|
||||
this.y2=y2;
|
||||
this.z=z;
|
||||
this.xResolution=xResolution;
|
||||
this.yResolution=yResolution;
|
||||
public RasterTable(double x1, double x2, double y1, double y2, double z, double xResolution, double yResolution, double[][] values, AlgorithmConfiguration configuration) {
|
||||
this.valuesMatrix = values;
|
||||
this.configuration = configuration;
|
||||
this.x1 = x1;
|
||||
this.x2 = x2;
|
||||
this.y1 = y1;
|
||||
this.y2 = y2;
|
||||
this.z = z;
|
||||
this.xResolution = xResolution;
|
||||
this.yResolution = yResolution;
|
||||
}
|
||||
|
||||
|
||||
public void dumpGeoTable(){
|
||||
|
||||
//open the connection to the db
|
||||
SessionFactory dbconnection = DatabaseUtils.initDBSession(configuration);
|
||||
try{
|
||||
//create a table
|
||||
DatabaseFactory.executeSQLUpdate(String.format(createTableStatement, tablename), dbconnection);
|
||||
List<Tuple<Double>> coordinates = GeoIntersector.generateCoordinateTriplets(x1, x2, y1, y2, z, xResolution, yResolution);
|
||||
List<Double> values = GeoIntersector.associateValueToCoordinates(coordinates, valuesMatrix);
|
||||
//for each element in the matrix, build the corresponding csquare code
|
||||
int triplets = coordinates.size();
|
||||
StringBuffer sb = new StringBuffer();
|
||||
for (int i=0;i<triplets;i++){
|
||||
//save the string in a buffer
|
||||
Tuple<Double> cset = coordinates.get(i);
|
||||
double x = cset.getElements().get(0);
|
||||
double y = cset.getElements().get(1);
|
||||
String csquare = CSquareCodesConverter.convertAtResolution(x, y, xResolution);
|
||||
double value = values.get(i);
|
||||
sb.append("("+csquare+","+x+","+y+","+z+","+value+")");
|
||||
if (i<triplets-1)
|
||||
sb.append(",");
|
||||
}
|
||||
//save all the strings on the table
|
||||
DatabaseUtils.insertFromBuffer(tablename, columnsnames, sb);
|
||||
|
||||
}catch(Exception e){
|
||||
public void dumpGeoTable() {
|
||||
|
||||
// open the connection to the db
|
||||
SessionFactory dbconnection = DatabaseUtils.initDBSession(configuration);
|
||||
try {
|
||||
AnalysisLogger.getLogger().debug("Database Initialized");
|
||||
// create a table
|
||||
DatabaseFactory.executeSQLUpdate(String.format(createTableStatement, tablename), dbconnection);
|
||||
AnalysisLogger.getLogger().debug("Table " + tablename + " created");
|
||||
List<Tuple<Double>> coordinates = GeoIntersector.generateCoordinateTriplets(x1, x2, y1, y2, z, xResolution, yResolution);
|
||||
int triplets = coordinates.size();
|
||||
AnalysisLogger.getLogger().debug("Generated " + triplets + " coordinates triples");
|
||||
List<Double> values = GeoIntersector.associateValueToCoordinates(coordinates, valuesMatrix);
|
||||
AnalysisLogger.getLogger().debug("Association to values completed - fulfilling buffer");
|
||||
// for each element in the matrix, build the corresponding csquare code
|
||||
StringBuffer sb = new StringBuffer();
|
||||
for (int i = 0; i < triplets; i++) {
|
||||
// save the string in a buffer
|
||||
Tuple<Double> cset = coordinates.get(i);
|
||||
double x = cset.getElements().get(0);
|
||||
double y = cset.getElements().get(1);
|
||||
String csquare = CSquareCodesConverter.convertAtResolution(x, y, xResolution);
|
||||
Double value = values.get(i);
|
||||
if (value.isNaN())
|
||||
value = 0d;
|
||||
|
||||
sb.append("('" + csquare + "'," + x + "," + y + "," + z + ",'" + value + "')");
|
||||
|
||||
if (i % 5000 == 0) {
|
||||
AnalysisLogger.getLogger().debug("Partial Inserting Buffer of " + sb.length() + " Values");
|
||||
String insertStatement = DatabaseUtils.insertFromBuffer(tablename, columnsnames, sb);
|
||||
DatabaseFactory.executeSQLUpdate(insertStatement, dbconnection);
|
||||
AnalysisLogger.getLogger().debug("Partial Insertion completed with Success!");
|
||||
sb = new StringBuffer();
|
||||
} else if (i < triplets - 1)
|
||||
sb.append(",");
|
||||
}
|
||||
|
||||
AnalysisLogger.getLogger().debug("Inserting Buffer of " + sb.length() + " Values");
|
||||
// save all the strings on the table
|
||||
if (sb.length() > 0) {
|
||||
String insertStatement = DatabaseUtils.insertFromBuffer(tablename, columnsnames, sb);
|
||||
DatabaseFactory.executeSQLUpdate(insertStatement, dbconnection);
|
||||
AnalysisLogger.getLogger().debug("Insertion completed with Success!");
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
AnalysisLogger.getLogger().debug("Error in dumping table: "+e.getLocalizedMessage());
|
||||
AnalysisLogger.getLogger().debug("Error in dumping table: " + e.getLocalizedMessage());
|
||||
} finally {
|
||||
// close the connection
|
||||
DatabaseUtils.closeDBConnection(dbconnection);
|
||||
AnalysisLogger.getLogger().debug("Raster Geo Table DB closed!");
|
||||
}
|
||||
finally{
|
||||
//close the connection
|
||||
}
|
||||
|
||||
public void deleteTable() {
|
||||
SessionFactory dbconnection = null;
|
||||
try {
|
||||
dbconnection = DatabaseUtils.initDBSession(configuration);
|
||||
DatabaseFactory.executeSQLUpdate(DatabaseUtils.dropTableStatement(tablename), dbconnection);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
DatabaseUtils.closeDBConnection(dbconnection);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue