#347

Author: mgramin

src/main/kotlin/com/github/mgramin/sqlboot/sql/select/impl/SimpleSelectQuery.kt

@@ -64,11 +64,20 @@ class SimpleSelectQuery(private val templateGenerator: TemplateGenerator) : Sele
     override fun execute(variables: Map<String, Any>) = throw RuntimeException("Not allow here")
 
 
-    private class SelectStatementParser(sql: String) {
+    private class SelectStatementParser {
 
-        val parser = SELECTParser(CommonTokenStream(SELECTLexer(ANTLRInputStream(sql))))
-        val selectVisitorCustom = SelectVisitorCustom()
-        val visit = selectVisitorCustom.visit(parser.select_statement())
+        constructor(sql: String) {
+            val selectLexer = SELECTLexer(ANTLRInputStream(sql))
+            selectLexer.removeErrorListeners()
+
+            this.parser = SELECTParser(CommonTokenStream(selectLexer))
+            this.selectVisitorCustom = SelectVisitorCustom()
+            this.visit = selectVisitorCustom.visit(parser.select_statement())
+        }
+
+        val parser: SELECTParser
+        val selectVisitorCustom: SelectVisitorCustom
+        val visit: Any
 
         fun comment() = selectVisitorCustom.queryComment
 

src/main/kotlin/com/github/mgramin/sqlboot/sql/select/impl/parser/SELECT.g4

@@ -65,7 +65,6 @@ select_statement
    : query_comment
      (with)*
      select select_row( COMMA select_row )*
-     from (schema_name+ DOT)? table_name
        .*?
    ;
 

src/main/kotlin/com/github/mgramin/sqlboot/sql/select/wrappers/JdbcSelectQuery.kt

@@ -67,7 +67,7 @@ class JdbcSelectQuery(
 
     override fun execute(variables: Map<String, Any>): Flux<Map<String, Any>> {
         val sqlText = JinjaTemplateGenerator(origin.query()).generate(variables)
-        logger.info(sqlText)
+        logger.info("\n$sqlText")
 
         return Mono.fromCallable {
             logger.info(Thread.currentThread().toString())