Wired up parsing to ODBC engine.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a5ad4420 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a5ad4420 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a5ad4420 Branch: refs/heads/ignite-3716 Commit: a5ad44206d3ae7f683bbb93924b2e5496e1b08e5 Parents: d087c78 Author: vozerov-gridgain <[email protected]> Authored: Tue Aug 23 12:43:38 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Aug 23 12:43:38 2016 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/odbc/OdbcRequestHandler.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a5ad4420/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java index 8f2d092..dd47a8e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java @@ -22,6 +22,7 @@ import org.apache.ignite.cache.query.QueryCursor; import org.apache.ignite.cache.query.SqlFieldsQuery; import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.processors.cache.QueryCursorImpl; +import org.apache.ignite.internal.processors.odbc.escape.OdbcParser; import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; import org.apache.ignite.internal.processors.query.GridQueryTypeDescriptor; import org.apache.ignite.internal.util.GridSpinBusyLock; @@ -160,7 +161,9 @@ public class OdbcRequestHandler { long qryId = QRY_ID_GEN.getAndIncrement(); try { - SqlFieldsQuery qry = new SqlFieldsQuery(req.sqlQuery()); + String sql = OdbcParser.parse(req.sqlQuery()); + + SqlFieldsQuery qry = new SqlFieldsQuery(sql); qry.setArgs(req.arguments());
