Skip to content

Commit 3ca7dfc

Browse files
committed
es 6.4.2 support
1 parent 7cd4da9 commit 3ca7dfc

File tree

3 files changed

+4
-6
lines changed

3 files changed

+4
-6
lines changed

.travis.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ before_install:
1717
# update to java 8
1818
- sudo update-java-alternatives -s java-8-oracle
1919
- export JAVA_HOME=/usr/lib/jvm/java-8-oracle
20-
- wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-6.4.1.deb && sudo dpkg -i --force-confnew elasticsearch-6.4.1.deb
20+
- wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-6.4.2.deb && sudo dpkg -i --force-confnew elasticsearch-6.4.2.deb
2121
- sudo cp ./src/test/resources/elasticsearch.yml /etc/elasticsearch/elasticsearch.yml
2222
- sudo cat /etc/elasticsearch/elasticsearch.yml
2323
- sudo java -version

pom.xml

Lines changed: 2 additions & 2 deletions
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.4.1.1</version>
6+
<version>6.4.2.0</version>
77
<packaging>jar</packaging>
88
<description>Query elasticsearch using SQL</description>
99
<name>elasticsearch-sql</name>
@@ -45,7 +45,7 @@
4545
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
4646
<runSuite>**/MainTestSuite.class</runSuite>
4747
<elasticsearch.plugin.name>sql</elasticsearch.plugin.name>
48-
<elasticsearch.version>6.4.1</elasticsearch.version>
48+
<elasticsearch.version>6.4.2</elasticsearch.version>
4949
<elasticsearch.plugin.classname>org.elasticsearch.plugin.nlpcn.SqlPlug</elasticsearch.plugin.classname>
5050
</properties>
5151

src/main/java/org/nlpcn/es4sql/parse/CaseWhenParser.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@
44
import com.alibaba.druid.sql.ast.expr.SQLCaseExpr;
55
import com.alibaba.druid.sql.ast.expr.SQLNullExpr;
66
import com.google.common.base.Joiner;
7-
import org.elasticsearch.common.inject.internal.Join;
8-
import org.nlpcn.es4sql.SQLFunctions;
97
import org.nlpcn.es4sql.Util;
108
import org.nlpcn.es4sql.domain.Condition;
119
import org.nlpcn.es4sql.domain.Condition.OPEAR;
@@ -75,7 +73,7 @@ private void explainWhere(List<String> codes, Where where) throws SqlParseExcept
7573
Condition condition = (Condition) where;
7674

7775
if (condition.getValue() instanceof ScriptFilter) {
78-
codes.add("(" + ((ScriptFilter) condition.getValue()).getScript() + ")");
76+
codes.add(String.format("Function.identity().compose((o)->{%s}).apply(null)", ((ScriptFilter) condition.getValue()).getScript()));
7977
} else if (condition.getOpear() == OPEAR.BETWEEN) {
8078
Object[] objs = (Object[]) condition.getValue();
8179
codes.add("(" + "doc['" + condition.getName() + "'].value >= " + objs[0] + " && doc['"

0 commit comments

Comments
 (0)