reset PayloadContentSize after relogin, because the new credential may be different with the old one (#399)

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/AbstractPayload.java

@@ -240,11 +240,13 @@ protected byte[] encodeDefaultBytes() {
 
     protected boolean isUseDefaultEncode() { return false; }
 
+
     /**
      * Reset the cached payload content size to force recalculation
      * Subclasses should override this method to reset their own cached sizes
      * and call this method on their child objects
      */
+    @Override
     public void resetPayloadContentSize() {
         this.payLoadContentSize = INVALID_PAYLOAD_CONTENT_SIZE;
     }

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/ObPayload.java

@@ -97,4 +97,5 @@ public interface ObPayload extends ObUnisVersion {
      */
     long getPayloadContentSize();
 
+    void resetPayloadContentSize();
 }

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

@@ -168,4 +168,14 @@ public long getPayloadContentSize() {
         return this.payLoadContentSize;
     }
 
+    @Override
+    public void resetPayloadContentSize() {
+        super.resetPayloadContentSize();
+        for (ObHbaseCell cell : cells) {
+            if (cell != null) {
+                cell.resetPayloadContentSize();
+            }
+        }
+    }
+
 }

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

@@ -155,6 +155,16 @@ public long getPayloadContentSize() {
         return payLoadContentSize;
     }
 
+    @Override
+    public void resetPayloadContentSize() {
+        super.resetPayloadContentSize();
+        for (ObHbaseCfRows cfRows : cfRows) {
+            if (cfRows != null) {
+                cfRows.resetPayloadContentSize();
+            }
+        }
+    }
+
     public void setTimeout(long timeout) {
         this.timeout = timeout;
     }

src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java

@@ -461,6 +461,7 @@ private ObPayload executeWithReconnect(ObTableConnection connection, final ObPay
                             connection.getObTable().getIp(), connection.getObTable().getPort(),
                             connection.getTenantId(), retryTimes);
                     connection.reConnectAndLogin(msg);
+                    request.resetPayloadContentSize();
                     needReconnect = false;
                 }
                 payload = realClient.invokeSync(connection, request, obTableExecuteTimeout);