[fix][dingo-sdk] Fix decimal key prefix encoding and decoding issue.

Author: nokiaMS

java/dingo-sdk/src/main/java/io/dingodb/sdk/common/serial/schema/DecimalSchema.java

@@ -139,12 +139,16 @@ public void encodeKeyV2(Buf buf, String data) {
                 buf.ensureRemainder(1);
                 buf.write(NOTNULL);
 
-                int size = internalEncodeKeyV2(buf, data);
+                byte[] decimalBin = s2bin(data);
+                int size = internalEncodeKey(buf, decimalBin);
+
                 buf.ensureRemainder(4);
                 buf.reverseWriteInt(size);
             }
         } else {
-            int size = internalEncodeKeyV2(buf, data);
+            byte[] decimalBin = s2bin(data);
+            int size = internalEncodeKey(buf, decimalBin);
+
             buf.ensureRemainder(4);
             buf.reverseWriteInt(size);
         }
@@ -161,6 +165,11 @@ private int internalEncodeKeyV2(Buf buf, String data) {
         return len;
     }
 
+    private byte[] s2bin(String data) {
+        MyDecimal myDecimal = new MyDecimal(data, (int)this.precision, (int)this.scale);
+        return myDecimal.toBin();
+    }
+
     private int internalEncodeKey(Buf buf, byte[] data) {
         int groupNum = data.length / 8;
         int size = (groupNum + 1) * 9;
@@ -213,14 +222,24 @@ public void encodeKeyForUpdateV2(Buf buf, String data) {
                 buf.reverseWriteInt0();
             } else {
                 buf.write(NOTNULL);
-                buf.reverseWriteInt(internalEncodeKeyV2(buf, data));
+
+                byte[] decimalBin = s2bin(data);
+                int size = internalEncodeKey(buf, decimalBin);
+
+                buf.ensureRemainder(4);
+                buf.reverseWriteInt(size);
             }
         } else {
             if (data == null) {
                 throw new RuntimeException("Data is not allow as null.");
             }
             buf.write(NOTNULL);
-            buf.reverseWriteInt(internalEncodeKeyV2(buf, data));
+
+            byte[] decimalBin = s2bin(data);
+            int size = internalEncodeKey(buf, decimalBin);
+
+            buf.ensureRemainder(4);
+            buf.reverseWriteInt(size);
         }
     }
 
@@ -273,7 +292,8 @@ public String decodeKeyV2(Buf buf) {
             }
         }
 
-        return internalReadDecimal(buf);
+        byte[] decBin = internalReadKeyPrefixBytes(buf);
+        return new MyDecimal(decBin, (int)this.precision, (int)this.scale).decimalToString();
     }
 
     //This interface is both used by v1 and v2. We use same way to decode key prefix.
@@ -282,15 +302,12 @@ public String decodeKeyV2(Buf buf) {
     public String decodeKeyPrefix(Buf buf) {
         if (allowNull) {
             if (buf.read() == NULL) {
-                buf.reverseSkipInt();
                 return null;
             }
         }
 
-        //Forward skip codec version field.
-        //buf.reverseSkipInt();
-
-        return internalReadDecimal(buf);
+        byte[] decBin = internalReadKeyPrefixBytes(buf);
+        return new MyDecimal(decBin, (int)this.precision, (int)this.scale).decimalToString();
     }
 
     private byte[] internalReadKeyPrefixBytes(Buf buf) {
@@ -379,14 +396,12 @@ public void encodeKeyPrefix(Buf buf, String data) {
                 buf.ensureRemainder(1);
                 buf.write(NOTNULL);
 
-                int size = internalEncodeKeyV2(buf, data);
-                buf.ensureRemainder(4);
-                buf.reverseWriteInt(size);
+                byte[] decimalBin = s2bin(data);
+                internalEncodeKey(buf, decimalBin);
             }
         } else {
-            int size = internalEncodeKeyV2(buf, data);
-            buf.ensureRemainder(4);
-            buf.reverseWriteInt(size);
+            byte[] decimalBin = s2bin(data);
+            internalEncodeKey(buf, decimalBin);
         }
     }