Skip to content

Commit bbc412d

Browse files
committed
fix NLPchina#714 SQL parse error when where condition contains 'join' keyword
1 parent 6a14820 commit bbc412d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
<modelVersion>4.0.0</modelVersion>
44
<groupId>org.nlpcn</groupId>
55
<artifactId>elasticsearch-sql</artifactId>
6-
<version>6.3.1.0</version>
6+
<version>6.3.1.1</version>
77
<packaging>jar</packaging>
88
<description>Query elasticsearch using SQL</description>
99
<name>elasticsearch-sql</name>

src/main/java/org/nlpcn/es4sql/query/ESActionFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ private static SQLStatementParser createSqlStatementParser(String sql) {
126126

127127
private static boolean isJoin(SQLQueryExpr sqlExpr,String sql) {
128128
MySqlSelectQueryBlock query = (MySqlSelectQueryBlock) sqlExpr.getSubQuery().getQuery();
129-
return query.getFrom() instanceof SQLJoinTableSource && sql.toLowerCase().contains("join");
129+
return query.getFrom() instanceof SQLJoinTableSource && ((SQLJoinTableSource) query.getFrom()).getJoinType() != SQLJoinTableSource.JoinType.COMMA && sql.toLowerCase().contains("join");
130130
}
131131

132132
private static SQLExpr toSqlExpr(String sql) {

0 commit comments

Comments
 (0)