opt for lsop decode err

Author: GroundWu

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableRemoting.java

@@ -173,7 +173,7 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
                 payload.decode(buf);
             } catch (Exception e) {
                 String errMessage = TraceUtil.formatTraceMessage(conn, response,
-                        "decode meet exception, cause: " + e.getMessage());
+                        "payload decode meet exception");
                 throw new RuntimeException(errMessage, e);
             }
             return payload;

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableResult.java

@@ -132,4 +132,10 @@ public String getErrMsg() {
     public void setMsg(byte[] msg) {
         this.msg = msg;
     }
+
+    @Override
+    public String toString() {
+        return String.format("ObTableResult[errno=%d, sqlState=%s, msg=%s]",
+                errno, new String(sqlState), getErrMsg());
+    }
 }

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableSingleOpEntity.java

@@ -193,7 +193,7 @@ public Object decode(ByteBuf buf) {
         } catch (Exception e) {
             String errMsg = String.format("ObTableSingleOpEntity decode exception: rowkeyBitLen=%d, rowkeyLen=%d, propertiesBitLen=%d, propertiesLen=%d"
                     , rowKeyBitLen, rowkeyLen, propertiesBitLen, propLen);
-            throw new IllegalArgumentException(errMsg + ", cause: " + e.getMessage(), e);
+            throw new IllegalArgumentException(errMsg, e);
         }
 
         return this;

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableSingleOpResult.java

@@ -80,21 +80,27 @@ public byte[] encode() {
      */
     @Override
     public Object decode(ByteBuf buf) {
-        // 0. decode version
-        super.decode(buf);
-
-        // 1. decode ObTableResult
-        this.header.decode(buf);
-
-        // 2. decode types
-        this.operationType = ObTableOperationType.valueOf(Serialization.decodeI8(buf.readByte()));
-
-        // 3. decode Entity
-        this.entity.setAggPropertiesNames(propertiesColumnNames);
-        this.entity.decode(buf);
-
-        // 4. decode affected rows
-        this.affectedRows = Serialization.decodeVi64(buf);
+        try {
+            // 0. decode version
+            super.decode(buf);
+
+            // 1. decode ObTableResult
+            this.header.decode(buf);
+
+            // 2. decode types
+            this.operationType = ObTableOperationType.valueOf(Serialization.decodeI8(buf.readByte()));
+
+            // 3. decode Entity
+            this.entity.setAggPropertiesNames(propertiesColumnNames);
+            this.entity.decode(buf);
+
+            // 4. decode affected rows
+            this.affectedRows = Serialization.decodeVi64(buf);
+        } catch (Exception e) {
+            String errMsg = String.format("ObTableSingleOpResult decode exception: header=%s, operationType=%d",
+                    this.header.toString(), this.operationType);
+            throw new IllegalArgumentException(errMsg + ", cause: " + e.getMessage(), e);
+        }
 
         return this;
     }