[31402][rdb-async]rdb async not support time type

Author: simenliuxing

core/src/main/java/com/dtstack/flink/sql/util/DateUtil.java

@@ -59,6 +59,7 @@ public class DateUtil {
 
     private static final Pattern DATETIME = Pattern.compile("^\\d{4}-(?:0[0-9]|1[0-2])-[0-9]{2}T\\d{2}:\\d{2}:\\d{2}(\\.\\d{3,9})?Z$");
     private static final Pattern DATE = Pattern.compile("^\\d{4}-(?:0[0-9]|1[0-2])-[0-9]{2}$");
+    private static final Pattern TIME = Pattern.compile("^\\d{2}:\\d{2}:\\d{2}(\\.\\d{3,9})?Z$");
     private static final int MILLIS_PER_SECOND = 1000;
 
 
@@ -832,4 +833,18 @@ public static java.sql.Date getDateFromStr(String dateStr) {
         return null == date ? null : new java.sql.Date(date.getTime());
     }
 
+    public static java.sql.Time getTimeFromStr(String dateStr) {
+        if (TIME.matcher(dateStr).matches()) {
+            dateStr = dateStr.substring(0,dateStr.length()-1);
+            Instant instant = LocalTime.parse(dateStr).atDate(LocalDate.now()).toInstant(ZoneOffset.UTC);
+            return new java.sql.Time(instant.toEpochMilli());
+        } else if (DATETIME.matcher(dateStr).matches()) {
+            Instant instant = Instant.from(ISO_INSTANT.parse(dateStr));
+            return new java.sql.Time(instant.toEpochMilli());
+        }
+        Date date = stringToDate(dateStr);
+        return null == date ? null : new java.sql.Time(date.getTime());
+    }
+
+
 }

core/src/main/java/com/dtstack/flink/sql/util/MathUtil.java

@@ -22,6 +22,7 @@
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.sql.Date;
+import java.sql.Time;
 import java.sql.Timestamp;
 
 /**
@@ -234,7 +235,19 @@ public static Date getDate(Object obj) {
         throw new RuntimeException("not support type of " + obj.getClass() + " convert to Date.");
     }
 
-
+    public static Time getTime(Object obj) {
+        if (obj == null) {
+            return null;
+        }
+        if (obj instanceof String) {
+            return DateUtil.getTimeFromStr((String) obj);
+        } else if (obj instanceof Timestamp) {
+            return new Time(((Timestamp) obj).getTime());
+        } else if (obj instanceof Time) {
+            return (Time) obj;
+        }
+        throw new RuntimeException("not support type of " + obj.getClass() + " convert to Time.");
+    }
 
     public static Timestamp getTimestamp(Object obj) {
         if (obj == null) {

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/util/SwitchUtil.java

@@ -78,6 +78,8 @@ public static Object getTarget(Object obj, String targetType) {
             case "timestamp":
             case "datetime":
                 return MathUtil.getTimestamp(obj);
+            case "time":
+                return MathUtil.getTime(obj);
             default:
         }
         return obj;