Fix issue 13

Author: shulkaolka

src/main/java/io/elastic/jdbc/QueryColumnNamesProvider.java

@@ -44,6 +44,18 @@ public JsonObject getMetaModel(JsonObject configuration) {
   public JsonObject getColumns(JsonObject configuration) {
     JsonObjectBuilder properties = Json.createObjectBuilder();
     String sqlQuery = configuration.getString("sqlQuery");
+    Pattern patternPoint = Pattern.compile("\\B@\\S+");
+    Matcher matcherPoint = patternPoint.matcher(sqlQuery);
+    if (matcherPoint.find()) {
+      do {
+        if (matcherPoint.group().contains(".")){
+          throw new RuntimeException(
+              "The variable name of the prepared statement '"
+              + matcherPoint.group()
+              + "' should not contain '.' symbol");
+        }
+      } while (matcherPoint.find());
+    }
     Pattern pattern = Pattern.compile(Utils.VARS_REGEXP);
     Matcher matcher = pattern.matcher(sqlQuery);
     Boolean isEmpty = true;

src/test/groovy/io/elastic/jdbc/QueryColumnNamesProviderSpec.groovy

@@ -6,14 +6,15 @@ import javax.json.Json
 import javax.json.JsonObject
 import javax.json.JsonObjectBuilder
 
-@Ignore
 class QueryColumnNamesProviderSpec extends Specification {
 
   JsonObjectBuilder configuration = Json.createObjectBuilder()
   String sqlQuery
+  String wrongSqlQuery
 
   def setup() {
     sqlQuery = "SELECT * FROM films WHERE watched = @watched:boolean AND created = @created:date"
+    wrongSqlQuery = "SELECT * FROM films WHERE watched = @watched.name:boolean"
   }
 
   def "get metadata model, given json object"() {
@@ -25,4 +26,14 @@ class QueryColumnNamesProviderSpec extends Specification {
     expect:
     meta.toString() == "{\"out\":{\"type\":\"object\",\"properties\":{\"watched\":{\"title\":\"watched\",\"type\":\"boolean\"},\"created\":{\"title\":\"created\",\"type\":\"date\"}}},\"in\":{\"type\":\"object\",\"properties\":{\"watched\":{\"title\":\"watched\",\"type\":\"boolean\"},\"created\":{\"title\":\"created\",\"type\":\"date\"}}}}"
   }
+
+  def "get metadata model, wrong sqlQuery"() {
+    configuration.add("sqlQuery", wrongSqlQuery)
+    given :
+    QueryColumnNamesProvider provider = new QueryColumnNamesProvider()
+    when:
+    provider.getMetaModel(configuration.build())
+    then:
+    thrown RuntimeException
+  }
 }