Merge pull request #12 from openworm/development

Release 0.3.4

Author: tarelli

.gitignore

@@ -4,6 +4,5 @@ src/main/java/META-INF/MANIFEST.MF
 /.externalToolBuilders/
 /.settings/
 .classpath
-bin/
 geppettoTmp/
-/bin/
+/bin

pom.xml

@@ -5,7 +5,7 @@
 	<groupId>org.geppetto</groupId>
 	<artifactId>datasources</artifactId>
 	<name>Geppetto Data Sources bundle</name>
-	<version>0.3.3</version>
+	<version>0.3.4</version>
 	<packaging>bundle</packaging>
 	<properties>
 		<spring.version>3.1.3.RELEASE</spring.version>

src/main/java/org/geppetto/datasources/ExecuteQueryVisitor.java

@@ -58,6 +58,7 @@
 import org.geppetto.model.util.GeppettoModelTraversal;
 import org.geppetto.model.util.GeppettoVisitingException;
 import org.geppetto.model.variables.Variable;
+import com.google.gson.JsonSyntaxException;
 
 /**
  * @author matteocantarelli
@@ -183,12 +184,14 @@ public Object caseSimpleQuery(SimpleQuery query)
 	{
 		if(!count || (count && query.isRunForCount()))
 		{
+			String processedQueryString = "";
+			String url = "";
 			try
 			{
 				if(QueryChecker.check(query, getVariable()))
 				{
 					ADataSourceService dataSourceService = getDataSourceService(query);
-					String url = getDataSource(query).getUrl();
+					url = getDataSource(query).getUrl();
 					String queryString = null;
 					if(count)
 					{
@@ -208,7 +211,7 @@ public Object caseSimpleQuery(SimpleQuery query)
 						properties.putAll(processingOutputMap);
 					}
 
-					String processedQueryString = VelocityUtils.processTemplate(dataSourceService.getTemplate(), properties);
+					processedQueryString = VelocityUtils.processTemplate(dataSourceService.getTemplate(), properties);
 
 					String response = null;
 					switch(dataSourceService.getConnectionType())
@@ -226,6 +229,7 @@ public Object caseSimpleQuery(SimpleQuery query)
 			}
 			catch(GeppettoDataSourceException e)
 			{
+				System.out.println("Query request: " + url + "?" + processedQueryString);
 				return new GeppettoVisitingException(e);
 			}
 			catch(GeppettoInitializationException e)
@@ -242,18 +246,23 @@ public Object caseSimpleQuery(SimpleQuery query)
 	 */
 	private void processResponse(String response, ADataSourceService dataSourceService) throws GeppettoDataSourceException
 	{
-		if(count)
-		{
-			Map<String, Object> responseMap = JSONUtility.getAsMap(response);
-			results = dataSourceService.getQueryResponseProcessor().processResponse(responseMap);
-			// TODO How to get the count if it is actually specified?
-		}
-		else
-		{
-			Map<String, Object> responseMap = JSONUtility.getAsMap(response);
-			results = dataSourceService.getQueryResponseProcessor().processResponse(responseMap);
+		try{
+			if(count)
+			{
+				Map<String, Object> responseMap = JSONUtility.getAsMap(response);
+				results = dataSourceService.getQueryResponseProcessor().processResponse(responseMap);
+				// TODO How to get the count if it is actually specified?
+			}
+			else
+			{
+				Map<String, Object> responseMap = JSONUtility.getAsMap(response);
+				results = dataSourceService.getQueryResponseProcessor().processResponse(responseMap);
+			}
+		}catch (JsonSyntaxException e){
+			System.out.println("JsonSyntaxException handling: " + response);
+			System.out.println(e);
+			throw new GeppettoDataSourceException(e);
 		}
-
 	}
 
 	/**

src/main/java/org/geppetto/datasources/neo4j/Neo4jResponseProcessor.java

@@ -27,21 +27,28 @@ public class Neo4jResponseProcessor implements IQueryResponseProcessor
 	public QueryResults processResponse(Map<String, Object> response)
 	{
 		QueryResults results = DatasourcesFactory.eINSTANCE.createQueryResults();
-		List<String> headers = (List<String>) ((List) ((Map<String, Object>) ((List) response.get("results")).get(0)).get("columns"));
+		if(((List) response.get("results")).size() > 0)
+		{
+			List<String> headers = (List<String>) ((List) ((Map<String, Object>) ((List) response.get("results")).get(0)).get("columns"));
 
-		results.getHeader().addAll(headers);
+			results.getHeader().addAll(headers);
 
-		results.getResults().clear();
-		List<Map<String, Object>> data = (List<Map<String, Object>>) ((List) ((Map<String, Object>) ((List) response.get("results")).get(0)).get("data"));
-		for(Map<String, Object> rowObject : data)
-		{
-			QueryResult resultRow = DatasourcesFactory.eINSTANCE.createQueryResult();
-			List<Object> row = (List<Object>) rowObject.get("row");
-			for(Object value : row)
+			results.getResults().clear();
+			List<Map<String, Object>> data = (List<Map<String, Object>>) ((List) ((Map<String, Object>) ((List) response.get("results")).get(0)).get("data"));
+			for(Map<String, Object> rowObject : data)
 			{
-				resultRow.getValues().add(value);
+				QueryResult resultRow = DatasourcesFactory.eINSTANCE.createQueryResult();
+				List<Object> row = (List<Object>) rowObject.get("row");
+				for(Object value : row)
+				{
+					resultRow.getValues().add(value);
+				}
+				results.getResults().add(resultRow);
 			}
-			results.getResults().add(resultRow);
+		}
+		else
+		{
+			// TODO: report reponse to log
 		}
 		return results;
 	}

src/main/resources/templates/neo4j/queryTemplate.vm

@@ -3,10 +3,9 @@
     {  
       "statement":"$QUERY",
       "resultDataContents":[  
-        "row",
-        "graph"
+        "row"
       ],
-      "includeStats":true
+      "includeStats":false
     }
   ]
 }