package org.gcube.dataanalysis.test removed
git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-access/DatabasesResourcesManager@96727 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
parent
ce0e91da4a
commit
80435cf7e7
|
@ -1,36 +0,0 @@
|
||||||
package org.gcube.dataanalysis.test;
|
|
||||||
|
|
||||||
import org.gcube.common.encryption.StringEncrypter;
|
|
||||||
import org.gcube.common.scope.api.ScopeProvider;
|
|
||||||
import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration;
|
|
||||||
import org.gcube.dataanalysis.ecoengine.interfaces.StandardLocalExternalAlgorithm;
|
|
||||||
|
|
||||||
public class Prova {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param args
|
|
||||||
*/
|
|
||||||
public static void main(String[] args) {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
// AnalysisLogger.setLogger("./cfg/"+AlgorithmConfiguration.defaultLoggerFile);
|
|
||||||
|
|
||||||
// AnalysisLogger.getLogger().debug("ciao");
|
|
||||||
|
|
||||||
|
|
||||||
ScopeProvider.instance.set("/gcube/devsec");
|
|
||||||
|
|
||||||
try {
|
|
||||||
String password = StringEncrypter.getEncrypter().decrypt("UwNMZOK7FlIjGPR+NZCV6w==");
|
|
||||||
|
|
||||||
System.out.println(password);
|
|
||||||
} catch (Exception e) {
|
|
||||||
// TODO Auto-generated catch block
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
StandardLocalExternalAlgorithm sle = null;
|
|
||||||
// System.out.println("CIAO");
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,163 +0,0 @@
|
||||||
//package org.gcube.dataanalysis.test;
|
|
||||||
//
|
|
||||||
//import java.io.IOException;
|
|
||||||
//
|
|
||||||
//import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
//import org.gcube.dataanalysis.databases.utils.DatabaseManagement;
|
|
||||||
//
|
|
||||||
//public class RegressionRandomSampleOnTable {
|
|
||||||
//
|
|
||||||
// /**
|
|
||||||
// * @param args
|
|
||||||
// */
|
|
||||||
// public static void main(String[] args) {
|
|
||||||
// // TODO Auto-generated method stub
|
|
||||||
// AnalysisLogger.getLogger().debug("Executing: " + "Postgres");
|
|
||||||
// testPostgres();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("Executing: " + "Mysql1");
|
|
||||||
//// testMysql1();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("Executing: " + "Mysql2");
|
|
||||||
//// testMysql2();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("Executing: " + "Mysql3");
|
|
||||||
//// testMysql3();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // Postgres database
|
|
||||||
// private static void testPostgres() {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection(
|
|
||||||
// "postgres",
|
|
||||||
// "d4science2",
|
|
||||||
// "org.postgresql.Driver",
|
|
||||||
// "org.hibernate.dialect.PostgreSQLDialect",
|
|
||||||
// "jdbc:postgresql://geoserver-dev.d4science-ii.research-infrastructures.eu:5432/aquamapsdb",
|
|
||||||
// "aquamapsdb");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.randomSampleOnTable("Divisions", "public");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "In RegressionRandomSampleOnTable->EXCEPTION: " + e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // Mysql database
|
|
||||||
// private static void testMysql1() {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection("root", "test", "com.mysql.jdbc.Driver",
|
|
||||||
// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
// // "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
// "jdbc:mysql://146.48.87.169:3306/aquamaps", "hcaf_d");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.randomSampleOnTable("hcaf_d", "aquamaps");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "In RegressionRandomSampleOnTable->EXCEPTION: " + e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // Mysql database
|
|
||||||
// private static void testMysql2() {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection("root", "test", "com.mysql.jdbc.Driver",
|
|
||||||
// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
// "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
//// "jdbc:mysql://146.48.87.169:3306/aquamaps",
|
|
||||||
// "example");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.randomSampleOnTable("example", "col2oct2010");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "In RegressionRandomSampleOnTable->EXCEPTION: " + e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// //Mysql database
|
|
||||||
// private static void testMysql3() {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection("root", "test", "com.mysql.jdbc.Driver",
|
|
||||||
// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
// "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
//// "jdbc:mysql://146.48.87.169:3306/aquamaps",
|
|
||||||
// "common_names");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.randomSampleOnTable("common_names", "col2oct2010");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "In RegressionRandomSampleOnTable->EXCEPTION: " + e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//}
|
|
|
@ -1,91 +0,0 @@
|
||||||
//package org.gcube.dataanalysis.test;
|
|
||||||
//
|
|
||||||
//import java.io.IOException;
|
|
||||||
//
|
|
||||||
//import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
//import org.gcube.dataanalysis.databases.utils.DatabaseManagement;
|
|
||||||
//import org.junit.rules.TestName;
|
|
||||||
//
|
|
||||||
//public class RegressionSmartSampleOnTable {
|
|
||||||
//
|
|
||||||
// // String [] testName = {"Postgres", "Mysql"};
|
|
||||||
//
|
|
||||||
// public static void main(String[] args) {
|
|
||||||
// // TODO Auto-generated method stub
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("Executing: " + "Postgres");
|
|
||||||
// testPostgres();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("Executing: " + "Mysql");
|
|
||||||
//// testMysql();
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // Postgres database
|
|
||||||
// private static void testPostgres() {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection(
|
|
||||||
// "postgres",
|
|
||||||
// "d4science2",
|
|
||||||
// "org.postgresql.Driver",
|
|
||||||
// "org.hibernate.dialect.PostgreSQLDialect",
|
|
||||||
// "jdbc:postgresql://geoserver-dev.d4science-ii.research-infrastructures.eu:5432/aquamapsdb",
|
|
||||||
// "aquamapsdb");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.smartSampleOnTable("Divisions", "public");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "In TestSmartSampleOnTable->EXCEPTION: " + e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // Mysql database
|
|
||||||
// private static void testMysql() {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection("root", "test", "com.mysql.jdbc.Driver",
|
|
||||||
// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
// // "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
// "jdbc:mysql://146.48.87.169:3306/aquamaps", "hcaf_d");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.smartSampleOnTable("hcaf_d", "aquamaps");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "In TestSampleOnTable->EXCEPTION: " + e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//}
|
|
|
@ -1,433 +0,0 @@
|
||||||
//package org.gcube.dataanalysis.test;
|
|
||||||
//import static org.gcube.resources.discovery.icclient.ICFactory.clientFor;
|
|
||||||
//import static org.gcube.resources.discovery.icclient.ICFactory.queryFor;
|
|
||||||
//
|
|
||||||
//import java.io.BufferedReader;
|
|
||||||
//import java.io.IOException;
|
|
||||||
//import java.io.InputStreamReader;
|
|
||||||
//import java.util.List;
|
|
||||||
//import java.util.Scanner;
|
|
||||||
//
|
|
||||||
//import org.gcube.common.encryption.StringEncrypter;
|
|
||||||
//import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
||||||
//import org.gcube.common.scope.api.ScopeProvider;
|
|
||||||
//import org.gcube.dataanalysis.databases.resources.DBResource;
|
|
||||||
//import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration;
|
|
||||||
//import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
||||||
//import org.gcube.resources.discovery.client.queries.impl.XQuery;
|
|
||||||
//import org.hibernate.SessionFactory;
|
|
||||||
//
|
|
||||||
//public class TestApp {
|
|
||||||
//
|
|
||||||
// /**
|
|
||||||
// * @param args
|
|
||||||
// */
|
|
||||||
// public static void main(String[] args) {
|
|
||||||
// // TODO Auto-generated method stub
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// ScopeProvider.instance.set("/gcube/devsec/devVRE");
|
|
||||||
// ScopeProvider.instance.set("/gcube/devsec");
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// XQuery query = queryFor(ServiceEndpoint.class);
|
|
||||||
// query.addCondition("$resource/Profile/Category/text() eq 'Database'");
|
|
||||||
//
|
|
||||||
// DiscoveryClient<DBResource> prova=clientFor(DBResource.class);
|
|
||||||
// List<DBResource> access = prova.submit(query);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("size resource: "+access.size());
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// for(int i=0;i<access.size();i++){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //access.get(i).parse();
|
|
||||||
// System.out.println("{ ID: "+access.get(i).getID()
|
|
||||||
// +" ResourceName: "+access.get(i).getResourceName()+" HostedOn: "+access.get(i).getHostedOn()
|
|
||||||
// +" PlatformName: "+access.get(i).getPlatformName()+" PlatformVersion: "+access.get(i).getPlatformVersion()+" }");
|
|
||||||
//
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
// for (int j=0;j<access.get(i).getAccessPoints().size();j++){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("############################# AccessPointInfo #################################");
|
|
||||||
// System.out.println("Description: "+access.get(i).getAccessPoints().get(j).getDescription()
|
|
||||||
// +"\n"+"Endpoint: "+access.get(i).getAccessPoints().get(j).address()
|
|
||||||
// //+"\n"+"Port Number: "+access.get(i).getAccessPoints().get(j).getPort());
|
|
||||||
// +"\n"+"Port Number: "+access.get(i).getPort());
|
|
||||||
//// );
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("Username: "+access.get(i).getAccessPoints().get(j).getUsername()
|
|
||||||
// +"\n"+"Password: "+access.get(i).getAccessPoints().get(j).getPassword()
|
|
||||||
// +"\n"+"DatabaseName: "+access.get(i).getAccessPoints().get(j).getDatabaseName()
|
|
||||||
// +"\n"+"Driver: "+access.get(i).getAccessPoints().get(j).getDriver()
|
|
||||||
// +"\n"+"Dialect: "+access.get(i).getAccessPoints().get(j).getDialect()
|
|
||||||
// +"\n"+"MaxConnections: "+access.get(i).getAccessPoints().get(j).getMaxConnections()
|
|
||||||
// +"\n"+"Schema: "+access.get(i).getAccessPoints().get(j).getSchema()
|
|
||||||
// +"\n"+"tableSpaceCount: "+access.get(i).getAccessPoints().get(j).getTableSpaceCount()
|
|
||||||
// +"\n"+"tableSpacePrefix: "+access.get(i).getAccessPoints().get(j).getTableSpacePrefix());
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //System.out.println("Dim: "+access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().size());
|
|
||||||
//
|
|
||||||
// if (access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().size()!=0){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("AuxiliaryProperty: "+"'aquamapsWorldTable' "+access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().get("aquamapsWorldTable"));
|
|
||||||
// System.out.println("AuxiliaryProperty: "+"'aquamapsDataStore' "+access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().get("aquamapsDataStore"));
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// System.out.println();
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //System.out.println("ID "+access.get(i).getID()+" User "+access.get(i).getTestData().size());
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// // Fase di Selezione del DB e Normalizzazione
|
|
||||||
//
|
|
||||||
// //access.get(2).normalize("//geoserver-dev.d4science-ii.research-infrastructures.eu:5432/aquamapsdb");
|
|
||||||
//
|
|
||||||
//// access.get(1).normalize("jdbc:postgresql://statistical-manager.d.d4science.research-infrastructures.eu/testdb");
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// // retrieve the decrypted version
|
|
||||||
//// try {
|
|
||||||
//// String password = StringEncrypter.getEncrypter().decrypt("Db/lnp5cAPwrAfjqorqctA==");
|
|
||||||
////
|
|
||||||
//// System.out.println("password Obis: " +password);
|
|
||||||
//// } catch (Exception e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// Scanner sc = new Scanner(System.in);
|
|
||||||
//
|
|
||||||
// System.out.println("Seleziona la risorsa database: inserisci un numero fra 0 e "+Integer.toString((access.size())-1));
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
// String index_resource = sc.next();
|
|
||||||
//
|
|
||||||
// System.out.println("Ho letto: " + index_resource);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// int resourceIndex= Integer.valueOf(index_resource).intValue();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// System.out.println("Inserisci l'Endpoint della risorsa");
|
|
||||||
//// String Endpoint_value = sc.next();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("Seleziona il database: inserisci un numero fra 0 e "+Integer.toString(access.get(resourceIndex).getAccessPoints().size()-1));
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// String db_value = sc.next();
|
|
||||||
//
|
|
||||||
// System.out.println("Ho letto: " + db_value);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// int dbIndex= Integer.valueOf(db_value).intValue();
|
|
||||||
//
|
|
||||||
// //access.get(resourceIndex).normalize(access.get(resourceIndex).getAccessPoints().get(dbIndex).address());
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Fase di Stampa
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// ///***** Da qui ho commentato
|
|
||||||
//
|
|
||||||
//// try {
|
|
||||||
// access.get(resourceIndex).normalize(dbIndex);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println();
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("---------------------------------------------------------------"+" Normalization: "+"-----------------------------------------------------");
|
|
||||||
// System.out.println();
|
|
||||||
// System.out.println();
|
|
||||||
// System.out.println();
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// for(int i=0;i<access.size();i++){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //access.get(i).parse();
|
|
||||||
// System.out.println("{ ID: "+access.get(i).getID()
|
|
||||||
// +" ResourceName: "+access.get(i).getResourceName()+" HostedOn: "+access.get(i).getHostedOn()
|
|
||||||
// +" PlatformName: "+access.get(i).getPlatformName()+" PlatformVersion: "+access.get(i).getPlatformVersion()+" }");
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
// for (int j=0;j<access.get(i).getAccessPoints().size();j++){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("############################# AccessPointInfo #################################");
|
|
||||||
// System.out.println("Description: "+access.get(i).getAccessPoints().get(j).getDescription()
|
|
||||||
// +"\n"+"Endpoint: "+access.get(i).getAccessPoints().get(j).address()
|
|
||||||
// //+"\n"+"Port Number: "+access.get(i).getAccessPoints().get(j).getPort());
|
|
||||||
// +"\n"+"Port Number: "+access.get(i).getPort());
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("Username: "+access.get(i).getAccessPoints().get(j).getUsername()
|
|
||||||
// +"\n"+"Password: "+access.get(i).getAccessPoints().get(j).getPassword()
|
|
||||||
// +"\n"+"DatabaseName: "+access.get(i).getAccessPoints().get(j).getDatabaseName()
|
|
||||||
// +"\n"+"Driver: "+access.get(i).getAccessPoints().get(j).getDriver()
|
|
||||||
// +"\n"+"Dialect: "+access.get(i).getAccessPoints().get(j).getDialect()
|
|
||||||
// +"\n"+"MaxConnections: "+access.get(i).getAccessPoints().get(j).getMaxConnections()
|
|
||||||
// +"\n"+"Schema: "+access.get(i).getAccessPoints().get(j).getSchema()
|
|
||||||
// +"\n"+"tableSpaceCount: "+access.get(i).getAccessPoints().get(j).getTableSpaceCount()
|
|
||||||
// +"\n"+"tableSpacePrefix: "+access.get(i).getAccessPoints().get(j).getTableSpacePrefix());
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //System.out.println("Dim: "+access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().size());
|
|
||||||
//
|
|
||||||
// if (access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().size()!=0){
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("AuxiliaryProperty: "+"'aquamapsWorldTable' "+access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().get("aquamapsWorldTable"));
|
|
||||||
// System.out.println("AuxiliaryProperty: "+"'aquamapsDataStore' "+access.get(i).getAccessPoints().get(j).getAuxiliaryProperties().get("aquamapsDataStore"));
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// System.out.println();
|
|
||||||
// System.out.println();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //System.out.println("ID "+access.get(i).getID()+" User "+access.get(i).getTestData().size());
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("---------------------------------------------------------------"+" Database Query: "+"-----------------------------------------------------");
|
|
||||||
//
|
|
||||||
//// // Sottomissione query
|
|
||||||
////
|
|
||||||
//// System.out.println("Insert the Query");
|
|
||||||
////
|
|
||||||
////
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// InputStreamReader is = new InputStreamReader(System.in);
|
|
||||||
//// BufferedReader br = new BufferedReader(is);
|
|
||||||
////
|
|
||||||
//// String q="";
|
|
||||||
//// try {
|
|
||||||
//// q = br.readLine();
|
|
||||||
//// } catch (IOException e1) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e1.printStackTrace();
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
//// System.out.println("Letta: "+q);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// org.gcube.dataanalysis.databases.utilsold.ConnectionManager df=new org.gcube.dataanalysis.databases.utilsold.ConnectionManager();
|
|
||||||
//
|
|
||||||
//// AlgorithmConfiguration config=df.setconfiguration
|
|
||||||
//// ("./cfg/", access.get(1).getAccessPoints().get(0).getUsername(), access.get(1).getAccessPoints().get(0).getPassword(),
|
|
||||||
//// access.get(1).getAccessPoints().get(0).getDriver(), access.get(1).getAccessPoints().get(0).getDialect(),
|
|
||||||
//// access.get(1).getAccessPoints().get(0).address());
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Codice funzionante
|
|
||||||
//// AlgorithmConfiguration config=df.setconfiguration("./cfg/", "utente", "d4science", "org.postgresql.Driver","org.hibernate.dialect.MySQLDialect",
|
|
||||||
//// "jdbc:postgresql://statistical-manager.d.d4science.research-infrastructures.eu:5432/testdb");
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// AlgorithmConfiguration config;
|
|
||||||
// try {
|
|
||||||
// config = df.setconfiguration("./cfg/", access.get(resourceIndex).getAccessPoints().get(dbIndex).getUsername(),
|
|
||||||
// access.get(resourceIndex).getAccessPoints().get(dbIndex).getPassword(), access.get(resourceIndex).getAccessPoints().get(dbIndex).getDriver(), access.get(resourceIndex).getAccessPoints().get(dbIndex).getDialect(),
|
|
||||||
// access.get(resourceIndex).getAccessPoints().get(dbIndex).address(), access.get(resourceIndex).getAccessPoints().get(dbIndex).getDatabaseName());
|
|
||||||
//
|
|
||||||
// SessionFactory sf=df.createConnection(config);
|
|
||||||
//
|
|
||||||
// boolean val=sf.isClosed();
|
|
||||||
//
|
|
||||||
// if (val!=true){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("la connessione è attiva");
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// if (config!=null){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// SessionFactory sf=df.createConnection(config);
|
|
||||||
////
|
|
||||||
//// boolean val=sf.isClosed();
|
|
||||||
////
|
|
||||||
//// if (val!=true){
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// System.out.println("la connessione è attiva");
|
|
||||||
////
|
|
||||||
//// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// try {
|
|
||||||
////// List<Object> rawnames = df.executeQuery("select * from (select a.field1 as aa, b.field1_id as bb, b.field1 as cc from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
////// "left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id) as cd", sf);
|
|
||||||
////
|
|
||||||
//// /*List<Object> rawnames = df.executeQuery("select * from (select a.field1, b.field1_id, b.field1 from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
//// "left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id) as cd", sf);*/
|
|
||||||
////
|
|
||||||
////// List<Object> rawnames = df.executeQuery("select a.field1 as aa, b.field1_id as bb, b.field1 as cc from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
////// "left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id)", sf);
|
|
||||||
////
|
|
||||||
////
|
|
||||||
////
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// //Query funzionante
|
|
||||||
////
|
|
||||||
////// List<Object> rawnames = df.executeQuery("select a.field1, b.field1_id from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
////// "left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id", sf);
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// //Query non funzionante
|
|
||||||
////// List<Object> rawnames = df.executeQuery("select a.field1, b.field1_id, b.field1 from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
////// "left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id", sf);
|
|
||||||
////
|
|
||||||
//// //Query funzionante con alias
|
|
||||||
////
|
|
||||||
////// List<Object> rawnames = df.executeQuery("select a.field1 as aa, b.field1_id as bb, b.field1 as cc from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
////// "left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id", sf);
|
|
||||||
////
|
|
||||||
//// //Query funzionante
|
|
||||||
////// List<Object> rawnames = df.executeQuery("select a.source_data as sourceA, b.source_data as sourceB, a.target_data_scientific_name as targetA, b.target_data_scientific_name as tagertB " +
|
|
||||||
////// "from bionymoutsimplefaked1csvpreprcsv as a join bionymoutfaked1csvpreprcsv as b on a.source_data=b.source_data limit 10",sf);
|
|
||||||
////
|
|
||||||
//// List<Object> rawnames = df.executeQuery(q,sf);
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// System.out.println("***************************************************************");
|
|
||||||
//// System.out.println();
|
|
||||||
////
|
|
||||||
//// System.out.println("Size: "+rawnames.size());
|
|
||||||
// //
|
|
||||||
//// for (int i = 0; i < rawnames.size(); i++) {
|
|
||||||
// //
|
|
||||||
//// Object[] row = (Object[]) rawnames.get(i);
|
|
||||||
// //
|
|
||||||
//// for (int j = 0; j < row.length; j++) {
|
|
||||||
// //
|
|
||||||
//// System.out.print("\"" + row[j] + "\"; ");
|
|
||||||
// //
|
|
||||||
//// }
|
|
||||||
//// System.out.println();
|
|
||||||
//// //System.out.println("Fine ");
|
|
||||||
// //
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// } catch (Exception e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// //e.printStackTrace();
|
|
||||||
////
|
|
||||||
//// System.out.println("***************************************************************");
|
|
||||||
//// System.out.println();
|
|
||||||
////
|
|
||||||
//// String error=e.getCause().toString();
|
|
||||||
////
|
|
||||||
//// if (error.contains("MySQLSyntaxErrorException"))
|
|
||||||
//// {
|
|
||||||
////
|
|
||||||
//// System.out.println("ERROR "+e.getMessage()+" "+"because an error is present: "+e.getCause().getMessage());
|
|
||||||
//// System.out.println("Suggestion: insert an alias name for the columns");
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
////
|
|
||||||
//// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// }else {
|
|
||||||
//// System.out.println("ERRORE: Non è possibile eseguire la connessione perchè l'indirizzo non è completo: databasename non dsiponibile");
|
|
||||||
//// }8
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//// } catch (IOException e1) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e1.printStackTrace();
|
|
||||||
//// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//}
|
|
|
@ -1,34 +0,0 @@
|
||||||
package org.gcube.dataanalysis.test;
|
|
||||||
|
|
||||||
/** Class that interacts with the IS in order to recover some information about the available databases and the contained data.
|
|
||||||
* Once recovered the interested data he can import these in the database used by the SM.
|
|
||||||
* */
|
|
||||||
|
|
||||||
public class TestDatabasesResourcesManager {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param args
|
|
||||||
*/
|
|
||||||
public static void main(String[] args) {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
|
|
||||||
|
|
||||||
// the user sets the scope
|
|
||||||
|
|
||||||
|
|
||||||
// the user views the available databases in the fixed scope
|
|
||||||
|
|
||||||
// the user selects a database
|
|
||||||
|
|
||||||
// the user wants to view some characteristics of the chosen database such as: the tables, rows' number and the create statement
|
|
||||||
|
|
||||||
// the user wants to recover data from a certain table so he submits a 'select' query on the database
|
|
||||||
|
|
||||||
// ?? the user create a table in the database's SM and import the recovered data
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,114 +0,0 @@
|
||||||
package org.gcube.dataanalysis.test;
|
|
||||||
import java.math.BigInteger;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Scanner;
|
|
||||||
|
|
||||||
import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
import org.gcube.dataaccess.databases.utils.DatabaseManagement;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/** Class that tests the code for the recovery of the tables */
|
|
||||||
public class TestGetTables {
|
|
||||||
|
|
||||||
|
|
||||||
public static void main(String[] args) {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
Scanner sc = new Scanner(System.in);
|
|
||||||
|
|
||||||
System.out.println("Specifica il nome del file di configurazione");
|
|
||||||
|
|
||||||
String configurationfile=sc.next();
|
|
||||||
|
|
||||||
//TODO: decommentare per la corretta esecuzione della classe
|
|
||||||
// try {
|
|
||||||
// DatabaseManagement obj=new DatabaseManagement("./cfg/", configurationfile);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Retrieve the schema for the postgres database
|
|
||||||
//
|
|
||||||
// List <String> schemas=new ArrayList<String>();
|
|
||||||
//
|
|
||||||
// schemas=obj.getSchemas();
|
|
||||||
//
|
|
||||||
// if (schemas!=null){
|
|
||||||
//
|
|
||||||
// //test Print
|
|
||||||
// for (int i=0;i<schemas.size();i++)
|
|
||||||
// {
|
|
||||||
//
|
|
||||||
// System.out.println("Schema's name: "+ schemas.get(i));
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
// else{
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("il database nn ha schemi");
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// List <String> tables=new ArrayList<String>();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Retrieve the table's names of the database
|
|
||||||
// tables=obj.getTables();
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //test print
|
|
||||||
// for (int i=0;i<tables.size();i++)
|
|
||||||
// {
|
|
||||||
//
|
|
||||||
// System.out.println(tables.get(i));
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Retrieve the "Create Table" statement
|
|
||||||
// System.out.println("Specifica il nome della tabella");
|
|
||||||
// String tablename=sc.next();
|
|
||||||
//
|
|
||||||
// String createtable=obj.getCreateTable(tablename);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //View number of rows
|
|
||||||
// try {
|
|
||||||
//
|
|
||||||
// BigInteger rows=obj.getNumberOfRows(tablename);
|
|
||||||
//
|
|
||||||
// System.out.println("il numero di righe è: " + rows);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO: handle exception
|
|
||||||
//
|
|
||||||
// System.out.println("The table does not exist.");
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,145 +0,0 @@
|
||||||
//package org.gcube.dataanalysis.test;
|
|
||||||
//
|
|
||||||
//import java.util.Scanner;
|
|
||||||
//import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
//import org.gcube.dataanalysis.databases.lexer.MySQLLexicalAnalyzer;
|
|
||||||
//import org.gcube.dataanalysis.databases.lexer.PostgresLexicalAnalyzer;
|
|
||||||
//
|
|
||||||
//
|
|
||||||
///** Class that tests the query's parsing by means of a lexical analyzer. It allows to filter a query no read-only compliant. */
|
|
||||||
//public class TestParsing {
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// public static void main(String[] args) {
|
|
||||||
// // TODO Auto-generated method stub
|
|
||||||
//
|
|
||||||
// String query="INSERT INTO ANTIQUES VALUES (21, 01, 'Ottoman', 200.00);";
|
|
||||||
//
|
|
||||||
// // String query =
|
|
||||||
// // "SELECT COUNT(*) FROM EMPLOYEESTATISTICSTABLE WHERE POSITION = 'Staff';";
|
|
||||||
// // String
|
|
||||||
// // query="SELECT COUNT(*) FROM EMPLOYEESTATISTICSTABLE WHERE POSITION = 'Staff';";
|
|
||||||
//
|
|
||||||
// // String query =
|
|
||||||
// // "SELECT EMPLOYEEIDNO FROM EMPLOYEESTATISTICSTABLE WHERE SALARY<40000 OR BENEFITS<10000;";
|
|
||||||
//
|
|
||||||
// // String
|
|
||||||
// // query="SELECT EMPLOYEEIDNO FROM EMPLOYEESTATISTICSTABLE WHERE POSITION='Manager' AND SALARY>60000 OR BENEFITS>12000;";
|
|
||||||
//
|
|
||||||
// // String
|
|
||||||
// // query="SELECT EMPLOYEEIDNO FROM EMPLOYEESTATISTICSTABLE WHERE SALARY>=50000;";
|
|
||||||
//
|
|
||||||
// // String
|
|
||||||
// // query="SELECT EMPLOYEEIDNO FROM EMPLOYEESTATISTICSTABLE WHERE SALARY<=50000;";
|
|
||||||
//
|
|
||||||
// // String
|
|
||||||
// // query="SELECT SUM(SALARY), AVG(SALARY) FROM EMPLOYEESTATISTICSTABLE;";
|
|
||||||
//
|
|
||||||
// // String
|
|
||||||
// // query="SELECT FirstName, LastName, Address, City, State FROM EmployeeAddressTable;";
|
|
||||||
//
|
|
||||||
// // String
|
|
||||||
// // query="SELECT EMPLOYEEIDNO FROM EMPLOYEESTATISTICSTABLE WHERE SALARY<>50000;";
|
|
||||||
//
|
|
||||||
// // String query="INSERT INTO ANTIQUES from select * from hcaf_d;";
|
|
||||||
//
|
|
||||||
// // String query = "COPY lori FROM lavoro";
|
|
||||||
//
|
|
||||||
//// String query = "COPY lori FROM \"lavoro\";";
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// // String query="SELECT TITLE, DIRECTOR "
|
|
||||||
// // +"FROM MOVIE "
|
|
||||||
// // +"WHERE MOVIE_ID IN"
|
|
||||||
// // +"("
|
|
||||||
// // +"("
|
|
||||||
// // +"SELECT MOVIE_ID "
|
|
||||||
// // +"FROM ACTOR "
|
|
||||||
// // +"WHERE NAME=?Tom Cruise? "
|
|
||||||
// // +"UNION "
|
|
||||||
// // +"SELECT "
|
|
||||||
// // +"MOVIE_ID "
|
|
||||||
// // +"FROM ACTOR "
|
|
||||||
// // +"WHERE NAME=?Kelly McGillis? "
|
|
||||||
// // +")"
|
|
||||||
// // +"INTERSECT "
|
|
||||||
// // +"SELECT MOVIE_ID "
|
|
||||||
// // +"FROM KEYWORD "
|
|
||||||
// // +"WHERE KEYWORD=?drama? "
|
|
||||||
// // +");";
|
|
||||||
//
|
|
||||||
// // String query="select * from `drop` where `drop`.id>10;";
|
|
||||||
//
|
|
||||||
// // System.out.println("Inserisci la query");
|
|
||||||
// // Scanner scanIn = new Scanner(System.in);
|
|
||||||
// //
|
|
||||||
// // String query=scanIn.nextLine();
|
|
||||||
// //
|
|
||||||
// // scanIn.close();
|
|
||||||
//
|
|
||||||
// // StringTokenizer string=new StringTokenizer(query, " ()[]{}<;>=,",
|
|
||||||
// // false);
|
|
||||||
// //
|
|
||||||
// // ArrayList<String> tokenslist=new ArrayList<String>();
|
|
||||||
// //
|
|
||||||
// // //StringTokenizer
|
|
||||||
// // AnalysisLogger.getLogger().debug("------------ Tokenizer ----------- ");
|
|
||||||
// //
|
|
||||||
// //
|
|
||||||
// // int count = string.countTokens();
|
|
||||||
// //
|
|
||||||
// // for (int i=0; i< count; i++){
|
|
||||||
// //
|
|
||||||
// // String token=string.nextToken();
|
|
||||||
// //
|
|
||||||
// //
|
|
||||||
// // tokenslist.add(token);
|
|
||||||
// //
|
|
||||||
// // AnalysisLogger.getLogger().debug("TestParsing->: "+ token);
|
|
||||||
// //
|
|
||||||
// // }
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("TestParsing->: Query " + query);
|
|
||||||
// // System.out.println();
|
|
||||||
//
|
|
||||||
// boolean AllowedQuery = false;
|
|
||||||
//
|
|
||||||
// // LexicalAnalyzer lexer=new LexicalAnalyzer();
|
|
||||||
// // AllowedQuery=lexer.analyze(query);
|
|
||||||
//
|
|
||||||
// System.out.println("Specifica il tipo di piattaforma");
|
|
||||||
//
|
|
||||||
// Scanner scanIn = new Scanner(System.in);
|
|
||||||
// String platform = scanIn.nextLine();
|
|
||||||
// scanIn.close();
|
|
||||||
//
|
|
||||||
// if (platform.toLowerCase().contains("postgres")) {
|
|
||||||
//
|
|
||||||
// PostgresLexicalAnalyzer obj = new PostgresLexicalAnalyzer();
|
|
||||||
//
|
|
||||||
// AllowedQuery = obj.analyze(query);
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// if (platform.toLowerCase().contains("mysql")) {
|
|
||||||
//
|
|
||||||
// MySQLLexicalAnalyzer obj = new MySQLLexicalAnalyzer();
|
|
||||||
//
|
|
||||||
// AllowedQuery = obj.analyze(query);
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// if (AllowedQuery == true) {
|
|
||||||
//
|
|
||||||
// AnalysisLogger.getLogger().debug("TestParsing->: filtered Query");
|
|
||||||
//
|
|
||||||
// } else {
|
|
||||||
// AnalysisLogger.getLogger().debug(
|
|
||||||
// "TestParsing->: not filtered query");
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//}
|
|
|
@ -1,284 +0,0 @@
|
||||||
package org.gcube.dataanalysis.test;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration;
|
|
||||||
import org.gcube.dataanalysis.ecoengine.utils.DatabaseUtils;
|
|
||||||
import org.hibernate.Query;
|
|
||||||
import org.hibernate.Session;
|
|
||||||
import org.hibernate.SessionFactory;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public class TestPostgres {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param args
|
|
||||||
*/
|
|
||||||
|
|
||||||
@SuppressWarnings({"unchecked"})
|
|
||||||
public static List<Object> executeHQLQuery(String query, SessionFactory DBSessionFactory, boolean useSQL) throws Exception{
|
|
||||||
|
|
||||||
List<Object> obj = null;
|
|
||||||
Session ss = null;
|
|
||||||
try {
|
|
||||||
ss = DBSessionFactory.getCurrentSession();
|
|
||||||
|
|
||||||
ss.beginTransaction();
|
|
||||||
|
|
||||||
Query qr = null;
|
|
||||||
|
|
||||||
if (useSQL)
|
|
||||||
qr = ss.createSQLQuery(query);
|
|
||||||
else
|
|
||||||
qr = ss.createQuery(query);
|
|
||||||
|
|
||||||
List<Object> result = qr.list();
|
|
||||||
|
|
||||||
ss.getTransaction().commit();
|
|
||||||
|
|
||||||
/*
|
|
||||||
if (result == null)
|
|
||||||
System.out.println("Hibernate doesn't return a valid object when org.gcube.contentmanagement.lexicalmatcher retrieve UserState Object");
|
|
||||||
|
|
||||||
if (result != null && result.size() == 0)
|
|
||||||
System.out.println(String.format("found nothing in database"));
|
|
||||||
*/
|
|
||||||
if (result != null && result.size() != 0) {
|
|
||||||
obj = result;
|
|
||||||
}
|
|
||||||
|
|
||||||
} catch (Exception e) {
|
|
||||||
|
|
||||||
// System.out.println(String.format("Error while executing query: %1$s %2$s", query, e.getMessage()));
|
|
||||||
// e.printStackTrace();
|
|
||||||
System.out.println(String.format("Error while executing query: %1$s %2$s", query, e.getMessage()));
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
|
|
||||||
return obj;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void main(String[] args) throws Exception{
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
|
|
||||||
/*AlgorithmConfiguration config = new AlgorithmConfiguration();
|
|
||||||
config.setConfigPath("./cfg/");
|
|
||||||
config.setParam("DatabaseUserName", "utente");
|
|
||||||
config.setParam("DatabasePassword", "d4science");
|
|
||||||
config.setParam("DatabaseDriver","org.postgresql.Driver");
|
|
||||||
//config.setParam("DatabaseDialect", "org.hibernate.dialect.PostgresPlusDialect");
|
|
||||||
config.setParam(
|
|
||||||
"DatabaseURL",
|
|
||||||
"jdbc:postgresql://statistical-manager.d.d4science.research-infrastructures.eu/testdb");
|
|
||||||
|
|
||||||
SessionFactory dbconnection = DatabaseUtils.initDBSession(config);
|
|
||||||
List<Object> rawnames = DatabaseFactory
|
|
||||||
.executeSQLQuery(
|
|
||||||
"select a.source_data as sourceA, b.source_data as sourceB, a.target_data_scientific_name as targetA, b.target_data_scientific_name as tagertB " +
|
|
||||||
"from bionymoutsimplefaked1csvpreprcsv as a join bionymoutfaked1csvpreprcsv as b on a.source_data=b.source_data limit 10",
|
|
||||||
dbconnection);
|
|
||||||
|
|
||||||
|
|
||||||
List<Object> rawnames = DatabaseFactory
|
|
||||||
.executeSQLQuery(
|
|
||||||
"select a.source_data as sourceA, a.target_data_scientific_name as targetA, b.source_data sourceB " +
|
|
||||||
"from bion_id_a1f27126_df23_4980_8e2b_4afc8aaa404f as a " +
|
|
||||||
"left join bion_id_ab251ee0_7cc6_49b2_8956_330f4716650f as b " +
|
|
||||||
"on a.source_data=b.source_data",
|
|
||||||
dbconnection);
|
|
||||||
|
|
||||||
|
|
||||||
//List<Object> rawnames = DatabaseFactory.executeHQLQuery(query, DBSessionFactory, useSQL);
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
System.out.println("***************************************************************");
|
|
||||||
System.out.println();
|
|
||||||
|
|
||||||
for (int i = 0; i < rawnames.size(); i++) {
|
|
||||||
|
|
||||||
Object[] row = (ObEntityManagerject[]) rawnames.get(i);
|
|
||||||
|
|
||||||
for (int j = 0; j < row.length; j++) {
|
|
||||||
|
|
||||||
System.out.print("\"" + row[j] + "\"; ");
|
|
||||||
|
|
||||||
}
|
|
||||||
System.out.println();
|
|
||||||
//System.out.println("Fine ");
|
|
||||||
|
|
||||||
}*/
|
|
||||||
|
|
||||||
|
|
||||||
AlgorithmConfiguration config = new AlgorithmConfiguration();
|
|
||||||
config.setConfigPath("./cfg/");
|
|
||||||
config.setParam("DatabaseUserName", "root");
|
|
||||||
config.setParam("DatabasePassword", "test");
|
|
||||||
config.setParam("DatabaseDriver","com.mysql.jdbc.Driver");
|
|
||||||
config.setParam("DatabaseDialect", "org.hibernate.dialect.MySQLDialect");
|
|
||||||
config.setParam(
|
|
||||||
"DatabaseURL",
|
|
||||||
"jdbc:mysql://146.48.87.169/timeseries");
|
|
||||||
|
|
||||||
SessionFactory dbconnection = DatabaseUtils.initDBSession(config);
|
|
||||||
|
|
||||||
|
|
||||||
/*List<Object> rawnames = DatabaseFactory
|
|
||||||
.executeSQLQuery(
|
|
||||||
"select a.source_data as sourceA, b.source_data as sourceB, a.target_data_scientific_name as targetA, b.target_data_scientific_name as tagertB " +
|
|
||||||
"from bionymoutsimplefaked1csvpreprcsv as a join bionymoutfaked1csvpreprcsv as b on a.source_data=b.source_data limit 10",
|
|
||||||
dbconnection);*/
|
|
||||||
|
|
||||||
//try{
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// dbconnection.getCurrentSession().;
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// ss.getCause()
|
|
||||||
|
|
||||||
// }
|
|
||||||
/*catch(JDBCExceptionReporter e)
|
|
||||||
{
|
|
||||||
Throwable t = e.getCause();
|
|
||||||
SQLException ex = (SQLException) t.getCause();
|
|
||||||
while(ex != null){
|
|
||||||
while(t != null) {
|
|
||||||
t = t.getCause();
|
|
||||||
}
|
|
||||||
// Logger logger=new Logger();
|
|
||||||
// logger.warn("SQLException="+ex.getLocalizedMessage());
|
|
||||||
|
|
||||||
System.out.println("sono qui");
|
|
||||||
|
|
||||||
ex = ex.getNextException();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
System.out.println("***************************************************************");
|
|
||||||
System.out.println();
|
|
||||||
|
|
||||||
//List<Object> rawnames =((javax.persistence.Query) query).getResultList();
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
try{
|
|
||||||
|
|
||||||
/*List<Object> rawnames = executeHQLQuery(
|
|
||||||
"select * from (select a.field1, b.field1_id as bb, b.field1 from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
"left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id) as cd",*/
|
|
||||||
// "select * "+
|
|
||||||
// "from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a, cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b limit 10",
|
|
||||||
// dbconnection, true);
|
|
||||||
|
|
||||||
|
|
||||||
List<Object> rawnames = executeHQLQuery(
|
|
||||||
"select a.field1, b.field1_id from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a "+
|
|
||||||
"left join cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b on a.field3_id=b.field1_id",dbconnection, true);
|
|
||||||
// "select * "+
|
|
||||||
// "from a7f768710_c7b0_11df_b2bc_e0f36cf4c8cd as a, cur_00d4e2d0_ecbd_11df_87fa_de008e0850ff as b limit 10",
|
|
||||||
// dbconnection, true);
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
System.out.println("Size: "+rawnames.size());
|
|
||||||
|
|
||||||
for (int i = 0; i < rawnames.size(); i++) {
|
|
||||||
|
|
||||||
Object[] row = (Object[]) rawnames.get(i);
|
|
||||||
|
|
||||||
for (int j = 0; j < row.length; j++) {
|
|
||||||
|
|
||||||
System.out.print("\"" + row[j] + "\"; ");
|
|
||||||
|
|
||||||
}
|
|
||||||
System.out.println();
|
|
||||||
//System.out.println("Fine ");
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}catch(Exception e){
|
|
||||||
e.printStackTrace();
|
|
||||||
System.out.println("message: "+e.getMessage());
|
|
||||||
//System.out.println(e.getLocalizedMessage());
|
|
||||||
|
|
||||||
StackTraceElement [] elem=e.getStackTrace();
|
|
||||||
|
|
||||||
|
|
||||||
System.out.println("localized: "+e.getCause().toString());
|
|
||||||
String error=e.getCause().toString();
|
|
||||||
if (error.contains("MySQLSyntaxErrorException"))
|
|
||||||
{
|
|
||||||
|
|
||||||
System.out.println("ERROR "+e.getMessage()+" "+"because an error is present: "+e.getCause().getMessage());
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// System.out.println("cause: "+e.getCause().getMessage());
|
|
||||||
|
|
||||||
// for (int i=0;i<elem.length;i++){
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// System.out.println("elem: "+ elem[i]);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//System.out.println("JDBC Error: "+JDBCExceptionReporter.DEFAULT_EXCEPTION_MSG);
|
|
||||||
//System.out.println("JDBC Error: "+JDBCExceptionReporter.DEFAULT_WARNING_MSG);
|
|
||||||
//System.out.println("JDBC Error: "+JDBCExceptionReporter.log.getName());
|
|
||||||
//System.out.println("JDBC Error: "+JDBCExceptionReporter.log.ROOT_LOGGER_NAME);
|
|
||||||
//org.slf4j.Logger logger = LoggerFactory.getLogger("log4j.logger.org.hibernate");
|
|
||||||
|
|
||||||
|
|
||||||
// Session s=dbconnection.openSession();
|
|
||||||
// s.close()
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// System.out.println(dbconnection.getCache().getClass());
|
|
||||||
|
|
||||||
//SQLException ex= new SQLException(JDBCExceptionReporter.log.getName());
|
|
||||||
|
|
||||||
//SQLException ex= new SQLException
|
|
||||||
|
|
||||||
//System.out.println("message: "+ex.getLocalizedMessage());
|
|
||||||
|
|
||||||
// System.out.println(ex.getCause();
|
|
||||||
|
|
||||||
// JDBCExceptionReporter.;
|
|
||||||
|
|
||||||
//System.out.println("Eccezione:" +e.getMessage());
|
|
||||||
//e.printStackTrace();
|
|
||||||
//e.getLocalizedMessage();
|
|
||||||
|
|
||||||
|
|
||||||
/*Connection a=dbconnection.getCurrentSession().disconnect();
|
|
||||||
|
|
||||||
|
|
||||||
try {
|
|
||||||
System.out.println(a.getWarnings().getSQLState());
|
|
||||||
} catch (SQLException e1) {
|
|
||||||
// TODO Auto-generated catch block
|
|
||||||
|
|
||||||
System.out.println("message: "+e1.getCause().getStackTrace().length);
|
|
||||||
//e1.printStackTrace();
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
|
@ -1,40 +0,0 @@
|
||||||
package org.gcube.dataanalysis.test;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
import org.gcube.dataaccess.databases.accessold.AddressesDiscoverer;
|
|
||||||
|
|
||||||
|
|
||||||
public class TestRetrieveEndpoint {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param args
|
|
||||||
*/
|
|
||||||
public static void main(String[] args) {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
AddressesDiscoverer obj=new AddressesDiscoverer();
|
|
||||||
List <String> addresses=new ArrayList<String>();
|
|
||||||
|
|
||||||
obj.setScope("/gcube/devsec");
|
|
||||||
|
|
||||||
addresses=obj.retrieveAddress("Database");
|
|
||||||
|
|
||||||
//Stampa
|
|
||||||
for (int i=0; i<addresses.size();i++){
|
|
||||||
|
|
||||||
System.out.println(addresses.get(i));
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,88 +0,0 @@
|
||||||
//package org.gcube.dataanalysis.test;
|
|
||||||
//
|
|
||||||
//import java.io.IOException;
|
|
||||||
//
|
|
||||||
//import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
//import org.gcube.dataanalysis.databases.utils.DatabaseManagement;
|
|
||||||
//
|
|
||||||
//public class TestSampleOnTable {
|
|
||||||
//
|
|
||||||
// public static void main(String[] args) {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Postgres Database
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection(
|
|
||||||
// "postgres",
|
|
||||||
// "d4science2",
|
|
||||||
// "org.postgresql.Driver",
|
|
||||||
// "org.hibernate.dialect.PostgreSQLDialect",
|
|
||||||
// "jdbc:postgresql://geoserver-dev.d4science-ii.research-infrastructures.eu:5432/aquamapsdb",
|
|
||||||
// "aquamapsdb");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.sampleOnTable("Divisions", "public");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger
|
|
||||||
// .getLogger()
|
|
||||||
// .debug("In TestSampleOnTable->EXCEPTION: "+ e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SmartSampleOnTable operation
|
|
||||||
//
|
|
||||||
// // mgt.smartSampleOnTable(tableName);
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //MYSQL Database
|
|
||||||
//
|
|
||||||
//// try {
|
|
||||||
//// mgt.createConnection(
|
|
||||||
//// "root",
|
|
||||||
//// "test",
|
|
||||||
//// "com.mysql.jdbc.Driver",
|
|
||||||
//// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
////// "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
//// "jdbc:mysql://146.48.87.169:3306/aquamaps",
|
|
||||||
//// "hcaf_d");
|
|
||||||
//// } catch (IOException e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
//// // SampleOnTable operation
|
|
||||||
////
|
|
||||||
//// try {
|
|
||||||
//// // for database postgres, if a table is not in lower case format, it
|
|
||||||
//// // is necessary to include the table name in quotes ""
|
|
||||||
//// mgt.sampleOnTable("hcaf_d", "aquamaps");
|
|
||||||
//// } catch (Exception e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
////
|
|
||||||
//// AnalysisLogger
|
|
||||||
//// .getLogger()
|
|
||||||
//// .debug("In TestSampleOnTable->EXCEPTION: "+ e);
|
|
||||||
//// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//}
|
|
|
@ -1,109 +0,0 @@
|
||||||
//package org.gcube.dataanalysis.test;
|
|
||||||
//
|
|
||||||
//import java.io.IOException;
|
|
||||||
//
|
|
||||||
//import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
||||||
//import org.gcube.dataanalysis.databases.utils.DatabaseManagement;
|
|
||||||
//
|
|
||||||
//public class TestSmartSampleOnTable {
|
|
||||||
//
|
|
||||||
// public static void main(String[] args) {
|
|
||||||
//
|
|
||||||
// // connection to database
|
|
||||||
// DatabaseManagement mgt = new DatabaseManagement("");
|
|
||||||
//
|
|
||||||
//// // Postgres Database
|
|
||||||
//// try {
|
|
||||||
//// mgt.createConnection(
|
|
||||||
//// "postgres",
|
|
||||||
//// "d4science2",
|
|
||||||
//// "org.postgresql.Driver",
|
|
||||||
//// "org.hibernate.dialect.PostgreSQLDialect",
|
|
||||||
//// "jdbc:postgresql://geoserver-dev.d4science-ii.research-infrastructures.eu:5432/aquamapsdb",
|
|
||||||
//// "aquamapsdb");
|
|
||||||
//// } catch (IOException e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
//// // SampleOnTable operation
|
|
||||||
////
|
|
||||||
//// try {
|
|
||||||
//// // for database postgres, if a table is not in lower case format, it
|
|
||||||
//// // is necessary to include the table name in quotes ""
|
|
||||||
//// mgt.smartSampleOnTable("Divisions", "public");
|
|
||||||
//// } catch (Exception e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
////
|
|
||||||
//// AnalysisLogger.getLogger().debug(
|
|
||||||
//// "In TestSmartSampleOnTable->EXCEPTION: " + e);
|
|
||||||
//// }
|
|
||||||
//
|
|
||||||
//
|
|
||||||
//
|
|
||||||
// //Mysql database
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// mgt.createConnection(
|
|
||||||
// "root",
|
|
||||||
// "test",
|
|
||||||
// "com.mysql.jdbc.Driver",
|
|
||||||
// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
//// "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
// "jdbc:mysql://146.48.87.169:3306/aquamaps",
|
|
||||||
// "hcaf_d");
|
|
||||||
// } catch (IOException e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// // SampleOnTable operation
|
|
||||||
//
|
|
||||||
// try {
|
|
||||||
// // for database postgres, if a table is not in lower case format, it
|
|
||||||
// // is necessary to include the table name in quotes ""
|
|
||||||
// mgt.smartSampleOnTable("hcaf_d", "aquamaps");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e.printStackTrace();
|
|
||||||
//
|
|
||||||
// AnalysisLogger
|
|
||||||
// .getLogger()
|
|
||||||
// .debug("In TestSampleOnTable->EXCEPTION: "+ e);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// //Mysql database
|
|
||||||
//
|
|
||||||
//// try {
|
|
||||||
//// mgt.createConnection(
|
|
||||||
//// "root",
|
|
||||||
//// "test",
|
|
||||||
//// "com.mysql.jdbc.Driver",
|
|
||||||
//// "org.hibernate.dialect.MySQLDialect",
|
|
||||||
////// "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
//// "jdbc:mysql://146.48.87.169:3306/col2oct2010",
|
|
||||||
//// "common_names");
|
|
||||||
//// } catch (IOException e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
//// }
|
|
||||||
////
|
|
||||||
//// // SampleOnTable operation
|
|
||||||
////
|
|
||||||
//// try {
|
|
||||||
//// // for database postgres, if a table is not in lower case format, it
|
|
||||||
//// // is necessary to include the table name in quotes ""
|
|
||||||
//// mgt.smartSampleOnTable("common_names", "col2oct2010");
|
|
||||||
//// } catch (Exception e) {
|
|
||||||
//// // TODO Auto-generated catch block
|
|
||||||
//// e.printStackTrace();
|
|
||||||
////
|
|
||||||
//// AnalysisLogger
|
|
||||||
//// .getLogger()
|
|
||||||
//// .debug("In TestSampleOnTable->EXCEPTION: "+ e);
|
|
||||||
//// }
|
|
||||||
//
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
//}
|
|
Loading…
Reference in New Issue