[Feature][Transform-V2][SqlTransform] Support Not Like Expression

seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/NotLikeFilterIT.java

@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.seatunnel.e2e.transform;
+
+import org.apache.seatunnel.e2e.common.container.TestContainer;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.TestTemplate;
+import org.testcontainers.containers.Container;
+
+import java.io.IOException;
+
+public class NotLikeFilterIT extends TestSuiteBase {
+
+    @TestTemplate
+    public void testSQLTransform(TestContainer container) throws IOException, InterruptedException {
+        Container.ExecResult sqlNotLikeFilter =
+                container.executeJob("/sql_transform/not_like_filter.conf");
+        Assertions.assertEquals(0, sqlNotLikeFilter.getExitCode());
+    }
+}

seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/not_like_filter.conf

@@ -0,0 +1,73 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+######
+###### This config file is a demonstration of streaming processing in seatunnel config
+######
+env {
+  execution.parallelism = 1
+  job.mode = "BATCH"
+  checkpoint.interval = 10000
+}
+
+source {
+  FakeSource {
+    result_table_name = "fake"
+    schema = {
+      fields {
+        id = "int"
+        name = "string"
+        age = "int"
+        email = "string"
+      }
+    }
+    rows = [
+      {fields = [1, "Joy Ding", 20, null], kind = INSERT}
+      {fields = [2, "May Ding", 22, "[email protected]"], kind = INSERT}
+      {fields = [3, "Kin Dom", 21, "[email protected]"], kind = INSERT}
+    ]
+  }
+}
+
+transform {
+  Sql {
+    source_table_name = "fake"
+    result_table_name = "fake1"
+    query = "select id,name,age from fake where  name not like '%Din_'"
+  }
+}
+
+sink {
+  Console {
+    source_table_name = "fake1"
+  }
+  Assert {
+    source_table_name = "fake1"
+    rules = {
+      field_rules = [
+        {
+          field_name = "name"
+          field_type = "string"
+          field_value = [
+            {equals_to = "Kin Dom"}
+          ]
+        }
+      ]
+    }
+  }
+
+
+}

seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFilter.java

@@ -173,7 +173,7 @@ private boolean likeExpr(LikeExpression likeExpression, Object[] inputFields) {
         Pattern pattern = Pattern.compile(regex);
         Matcher matcher = pattern.matcher(leftVal.toString());
 
-        return matcher.matches();
+        return matcher.matches() ^ likeExpression.isNot();
     }
 
     private Pair<Object, Object> executeComparisonOperator(