Add support for wildcard_query function

common/src/main/java/org/opensearch/sql/common/utils/StringUtils.java

@@ -108,6 +108,48 @@ public static String format(final String format, Object... args) {
     return String.format(Locale.ROOT, format, args);
   }
 
+  /**
+   * Converts sql wildcard character % and _ to * and ?.
+   * @param text string to be converted
+   * @return converted string
+   */
+  public static String convertSqlWildcardToLucene(String text) {
+    final char DEFAULT_ESCAPE = '\\';
+    StringBuilder convertedString = new StringBuilder(text.length());
+    boolean escaped = false;
+
+    for (char currentChar : text.toCharArray()) {
+      switch (currentChar) {
+        case DEFAULT_ESCAPE:
+          escaped = true;
+          convertedString.append(currentChar);
+          break;
+        case '%':
+          if (escaped) {
+            convertedString.deleteCharAt(convertedString.length() - 1);
+            convertedString.append("%");
+          } else {
+            convertedString.append("*");
+          }
+          escaped = false;
+          break;
+        case '_':
+          if (escaped) {
+            convertedString.deleteCharAt(convertedString.length() - 1);
+            convertedString.append("_");
+          } else {
+            convertedString.append('?');
+          }
+          escaped = false;
+          break;
+        default:
+          convertedString.append(currentChar);
+          escaped = false;
+      }
+    }
+    return convertedString.toString();
+  }
+
   private static boolean isQuoted(String text, String mark) {
     return !Strings.isNullOrEmpty(text) && text.startsWith(mark) && text.endsWith(mark);
   }

integ-test/src/test/java/org/opensearch/sql/sql/WildcardQueryIT.java

@@ -35,6 +35,19 @@ public void test_wildcard_query_asterisk_function() throws IOException {
     verifyDataRows(result2, rows(expected));
   }
 
+  @Test
+  public void test_LIKE() throws IOException {
+    String expected = "test wildcard";
+
+    String query1 = "SELECT Body, Body LIKE 't*' FROM " + TEST_INDEX_WILDCARD + " LIMIT 1";
+    JSONObject result1 = executeJdbcRequest(query1);
+    verifyDataRows(result1, rows(expected));
+
+    query1 = "SELECT Body FROM " + TEST_INDEX_WILDCARD + " WHERE Body LIKE 't*' LIMIT 1";
+    result1 = executeJdbcRequest(query1);
+    verifyDataRows(result1, rows(expected));
+  }
+
   @Test
   public void test_wildcard_query_question_mark_function() throws IOException {
     String expected = "test wildcard";

opensearch/src/main/java/org/opensearch/sql/opensearch/storage/script/filter/FilterQueryBuilder.java

@@ -24,6 +24,7 @@
 import org.opensearch.sql.expression.FunctionExpression;
 import org.opensearch.sql.expression.function.BuiltinFunctionName;
 import org.opensearch.sql.expression.function.FunctionName;
+import org.opensearch.sql.opensearch.storage.script.filter.lucene.LikeQuery;
 import org.opensearch.sql.opensearch.storage.script.filter.lucene.LuceneQuery;
 import org.opensearch.sql.opensearch.storage.script.filter.lucene.RangeQuery;
 import org.opensearch.sql.opensearch.storage.script.filter.lucene.RangeQuery.Comparison;
@@ -57,7 +58,7 @@ public class FilterQueryBuilder extends ExpressionNodeVisitor<QueryBuilder, Obje
           .put(BuiltinFunctionName.GREATER.getName(), new RangeQuery(Comparison.GT))
           .put(BuiltinFunctionName.LTE.getName(), new RangeQuery(Comparison.LTE))
           .put(BuiltinFunctionName.GTE.getName(), new RangeQuery(Comparison.GTE))
-          .put(BuiltinFunctionName.LIKE.getName(), new WildcardQuery())
+          .put(BuiltinFunctionName.LIKE.getName(), new LikeQuery())
           .put(BuiltinFunctionName.MATCH.getName(), new MatchQuery())
           .put(BuiltinFunctionName.MATCH_PHRASE.getName(), new MatchPhraseQuery())
           .put(BuiltinFunctionName.MATCHPHRASE.getName(), new MatchPhraseQuery())

opensearch/src/main/java/org/opensearch/sql/opensearch/storage/script/filter/lucene/LikeQuery.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.opensearch.sql.opensearch.storage.script.filter.lucene;
+
+import org.opensearch.index.query.QueryBuilder;
+import org.opensearch.index.query.QueryBuilders;
+import org.opensearch.index.query.WildcardQueryBuilder;
+import org.opensearch.sql.common.utils.StringUtils;
+import org.opensearch.sql.data.model.ExprValue;
+import org.opensearch.sql.expression.Expression;
+import org.opensearch.sql.expression.FunctionExpression;
+import org.opensearch.sql.expression.ReferenceExpression;
+
+public class LikeQuery extends LuceneQuery {
+  @Override
+  public QueryBuilder build(FunctionExpression func) {
+    ReferenceExpression ref = (ReferenceExpression) func.getArguments().get(0);
+    Expression expr = func.getArguments().get(1);
+    ExprValue literalValue = expr.valueOf();
+
+    return createBuilder(ref.toString(), literalValue.stringValue());
+  }
+
+  protected WildcardQueryBuilder createBuilder(String field, String query) {
+    String matchText = StringUtils.convertSqlWildcardToLucene(query);
+    return QueryBuilders.wildcardQuery(field, matchText);
+  }
+}

opensearch/src/main/java/org/opensearch/sql/opensearch/storage/script/filter/lucene/relevance/WildcardQuery.java

@@ -8,6 +8,7 @@
 
 import org.opensearch.index.query.QueryBuilders;
 import org.opensearch.index.query.WildcardQueryBuilder;
+import org.opensearch.sql.common.utils.StringUtils;
 
 /**
  * Lucene query that builds wildcard query.
@@ -21,57 +22,14 @@ public WildcardQuery() {
     super(FunctionParameterRepository.WildcardQueryBuildActions);
   }
 
-  private static final char DEFAULT_ESCAPE = '\\';
-
-  /**
-   * Converts sql wildcard character % and _ to * and ?.
-   * @param text string to be converted
-   * @return converted string
-   */
-  public String convertSqlWildcardToLucene(String text) {
-    StringBuilder convertedString = new StringBuilder(text.length());
-    boolean escaped = false;
-
-    for (char currentChar : text.toCharArray()) {
-      switch (currentChar) {
-        case DEFAULT_ESCAPE:
-          escaped = true;
-          convertedString.append(currentChar);
-          break;
-        case '%':
-          if (escaped) {
-            convertedString.deleteCharAt(convertedString.length() - 1);
-            convertedString.append("%");
-          } else {
-            convertedString.append("*");
-          }
-          escaped = false;
-          break;
-        case '_':
-          if (escaped) {
-            convertedString.deleteCharAt(convertedString.length() - 1);
-            convertedString.append("_");
-          } else {
-            convertedString.append('?');
-          }
-          escaped = false;
-          break;
-        default:
-          convertedString.append(currentChar);
-          escaped = false;
-      }
-    }
-    return convertedString.toString();
-  }
-
   @Override
   protected String getQueryName() {
     return WildcardQueryBuilder.NAME;
   }
 
   @Override
   protected WildcardQueryBuilder createBuilder(String field, String query) {
-    String matchText = convertSqlWildcardToLucene(query);
+    String matchText = StringUtils.convertSqlWildcardToLucene(query);
     return QueryBuilders.wildcardQuery(field, matchText);
   }
 }

opensearch/src/test/java/org/opensearch/sql/opensearch/storage/script/filter/lucene/WildcardQueryTest.java

@@ -18,6 +18,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 import org.opensearch.sql.common.antlr.SyntaxCheckException;
+import org.opensearch.sql.common.utils.StringUtils;
 import org.opensearch.sql.data.model.ExprValue;
 import org.opensearch.sql.data.type.ExprType;
 import org.opensearch.sql.exception.SemanticCheckException;
@@ -77,19 +78,19 @@ public void test_SemanticCheckException_when_invalid_parameter() {
 
   @Test
   public void test_escaping_sql_wildcards() {
-    assertEquals("%", wildcardQueryQuery.convertSqlWildcardToLucene("\\%"));
-    assertEquals("\\*", wildcardQueryQuery.convertSqlWildcardToLucene("\\*"));
-    assertEquals("_", wildcardQueryQuery.convertSqlWildcardToLucene("\\_"));
-    assertEquals("\\?", wildcardQueryQuery.convertSqlWildcardToLucene("\\?"));
-    assertEquals("%*", wildcardQueryQuery.convertSqlWildcardToLucene("\\%%"));
-    assertEquals("*%", wildcardQueryQuery.convertSqlWildcardToLucene("%\\%"));
-    assertEquals("%*%", wildcardQueryQuery.convertSqlWildcardToLucene("\\%%\\%"));
-    assertEquals("*%*", wildcardQueryQuery.convertSqlWildcardToLucene("%\\%%"));
-    assertEquals("_?", wildcardQueryQuery.convertSqlWildcardToLucene("\\__"));
-    assertEquals("?_", wildcardQueryQuery.convertSqlWildcardToLucene("_\\_"));
-    assertEquals("_?_", wildcardQueryQuery.convertSqlWildcardToLucene("\\__\\_"));
-    assertEquals("?_?", wildcardQueryQuery.convertSqlWildcardToLucene("_\\__"));
-    assertEquals("%\\*_\\?", wildcardQueryQuery.convertSqlWildcardToLucene("\\%\\*\\_\\?"));
+    assertEquals("%", StringUtils.convertSqlWildcardToLucene("\\%"));
+    assertEquals("\\*", StringUtils.convertSqlWildcardToLucene("\\*"));
+    assertEquals("_", StringUtils.convertSqlWildcardToLucene("\\_"));
+    assertEquals("\\?", StringUtils.convertSqlWildcardToLucene("\\?"));
+    assertEquals("%*", StringUtils.convertSqlWildcardToLucene("\\%%"));
+    assertEquals("*%", StringUtils.convertSqlWildcardToLucene("%\\%"));
+    assertEquals("%*%", StringUtils.convertSqlWildcardToLucene("\\%%\\%"));
+    assertEquals("*%*", StringUtils.convertSqlWildcardToLucene("%\\%%"));
+    assertEquals("_?", StringUtils.convertSqlWildcardToLucene("\\__"));
+    assertEquals("?_", StringUtils.convertSqlWildcardToLucene("_\\_"));
+    assertEquals("_?_", StringUtils.convertSqlWildcardToLucene("\\__\\_"));
+    assertEquals("?_?", StringUtils.convertSqlWildcardToLucene("_\\__"));
+    assertEquals("%\\*_\\?", StringUtils.convertSqlWildcardToLucene("\\%\\*\\_\\?"));
   }
 
   private class WildcardQueryExpression extends FunctionExpression {