(seatunnel) branch dev updated: [Improve][Transform-V2] Remove unnecessary unquoting method and streamline date parsing (#9478)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0341475825 [Improve][Transform-V2] Remove unnecessary unquoting method 
and streamline date parsing (#9478)
0341475825 is described below

commit 034147582538a561e81bce8d12e8eb8280d3a841
Author: corgy-w <73771213+corg...@users.noreply.github.com>
AuthorDate: Wed Jun 25 10:34:55 2025 +0800

    [Improve][Transform-V2] Remove unnecessary unquoting method and streamline 
date parsing (#9478)
---
 .../org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java  | 2 +-
 .../seatunnel/transform/sql/zeta/functions/DateTimeFunction.java  | 8 --------
 2 files changed, 1 insertion(+), 9 deletions(-)

diff --git 
a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java
 
b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java
index 20ba4b7e1b..9dca1ad8bc 100644
--- 
a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java
+++ 
b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java
@@ -268,7 +268,7 @@ public class ZetaSQLFunction {
             }
         }
         if (expression instanceof StringValue) {
-            return ((StringValue) expression).getValue();
+            return ((StringValue) expression).getNotExcapedValue();
         }
         if (expression instanceof Column) {
             Column columnExp = (Column) expression;
diff --git 
a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/DateTimeFunction.java
 
b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/DateTimeFunction.java
index 8ef8a80365..262fb2129c 100644
--- 
a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/DateTimeFunction.java
+++ 
b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/DateTimeFunction.java
@@ -634,7 +634,6 @@ public class DateTimeFunction {
             return null;
         }
         String format = (String) args.get(1);
-        format = getUnquotedValue(format);
         if (format.contains("yy") && format.contains("mm")) {
             DateTimeFormatter df = DateTimeFormatter.ofPattern(format);
             return LocalDateTime.parse(str, df);
@@ -716,11 +715,4 @@ public class DateTimeFunction {
         LocalDateTime datetime = 
Instant.ofEpochSecond(unixTime).atZone(zoneId).toLocalDateTime();
         return df.format(datetime);
     }
-
-    private static String getUnquotedValue(String format) {
-        if (format.contains("''")) {
-            return format.replace("''", "'");
-        }
-        return format;
-    }
 }