(seatunnel) branch dev updated: [Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)

[gaojun2048]

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

gaojun2048 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 6f8d0a5040 [Feature][JDBC、CDC] Support Short and Byte Type in spliter 
(#6027)
6f8d0a5040 is described below

commit 6f8d0a50408a02405bc2ff5fa0070798958c86fd
Author: ic4y <83933160+i...@users.noreply.github.com>
AuthorDate: Fri Jan 19 10:05:49 2024 +0800

    [Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)
---
 .../org/apache/seatunnel/connectors/cdc/base/utils/ObjectUtils.java | 6 ++++++
 .../seatunnel/connectors/seatunnel/jdbc/utils/ObjectUtils.java      | 6 ++++++
 2 files changed, 12 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/ObjectUtils.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/ObjectUtils.java
index 0f703f02c1..75a747493a 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/ObjectUtils.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/ObjectUtils.java
@@ -55,6 +55,12 @@ public class ObjectUtils {
         }
         if (minuend instanceof Integer) {
             return BigDecimal.valueOf((int) 
minuend).subtract(BigDecimal.valueOf((int) subtrahend));
+        } else if (minuend instanceof Short) {
+            return BigDecimal.valueOf((short) minuend)
+                    .subtract(BigDecimal.valueOf((short) subtrahend));
+        } else if (minuend instanceof Byte) {
+            return BigDecimal.valueOf((byte) minuend)
+                    .subtract(BigDecimal.valueOf((byte) subtrahend));
         } else if (minuend instanceof Long) {
             return BigDecimal.valueOf((long) minuend)
                     .subtract(BigDecimal.valueOf((long) subtrahend));
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/ObjectUtils.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/ObjectUtils.java
index d5f9260879..f178a83ea2 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/ObjectUtils.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/ObjectUtils.java
@@ -57,6 +57,12 @@ public class ObjectUtils {
         }
         if (minuend instanceof Integer) {
             return BigDecimal.valueOf((int) 
minuend).subtract(BigDecimal.valueOf((int) subtrahend));
+        } else if (minuend instanceof Short) {
+            return BigDecimal.valueOf((short) minuend)
+                    .subtract(BigDecimal.valueOf((short) subtrahend));
+        } else if (minuend instanceof Byte) {
+            return BigDecimal.valueOf((byte) minuend)
+                    .subtract(BigDecimal.valueOf((byte) subtrahend));
         } else if (minuend instanceof Long) {
             return BigDecimal.valueOf((long) minuend)
                     .subtract(BigDecimal.valueOf((long) subtrahend));