add ObBinlogRowImageType for QueryAndMutateRequest to skip the space of encode

Author: JackShi148

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

@@ -0,0 +1,37 @@
+package com.alipay.oceanbase.rpc.protocol.payload.impl.execute;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public enum ObBinlogRowImageType {
+    MINIMAL(0), NOBLOB(1), FULL(2);
+    private int value;
+    private static Map<Integer, ObBinlogRowImageType> map             = new HashMap<Integer, ObBinlogRowImageType>();
+    ObBinlogRowImageType(int value) { this.value = value; }
+    static {
+        for (ObBinlogRowImageType type : ObBinlogRowImageType.values()) {
+            map.put(type.value, type);
+        }
+    }
+
+    /*
+     * Value of.
+     */
+    public static ObBinlogRowImageType valueOf(int value) {
+        return map.get(value);
+    }
+
+    /*
+     * Get value.
+     */
+    public int getValue() {
+        return value;
+    }
+
+    /*
+     * Get byte value.
+     */
+    public byte getByteValue() {
+        return (byte) value;
+    }
+}

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

@@ -21,6 +21,6 @@ public void setFlagServerCanRetry(boolean serverCanRetry) {
     }
 
     public boolean getFlagServerCanRetry() {
-        return (this.flags & FLAG_SERVER_CAN_RETRY) == 1;
+        return (this.flags & FLAG_SERVER_CAN_RETRY) != 0;
     }
 }

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

@@ -19,6 +19,7 @@
 
 import com.alipay.oceanbase.rpc.ObGlobal;
 import com.alipay.oceanbase.rpc.protocol.payload.Pcodes;
+import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.ObBinlogRowImageType;
 import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.ObTableAbstractOperationRequest;
 import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.ObTableEntityType;
 import com.alipay.oceanbase.rpc.util.Serialization;
@@ -32,11 +33,14 @@
      table_id_,
      partition_id_,
      entity_type_,
-     query_and_mutate_);
+     query_and_mutate_,
+     binlog_row_image_type_,
+     option_flag_);
  *
  */
 public class ObTableQueryAndMutateRequest extends ObTableAbstractOperationRequest {
 
+    private ObBinlogRowImageType type = ObBinlogRowImageType.FULL; // no use for now
     private ObTableQueryAndMutate tableQueryAndMutate;
 
     /*
@@ -68,8 +72,8 @@ public byte[] encode() {
 
         // encode ObBinlogRowImageType::FULL (2)
         idx += len;
-        len = Serialization.getNeedBytes(2);
-        System.arraycopy(Serialization.encodeVi32(2), 0, bytes, idx, len);
+        len = Serialization.getNeedBytes(type.getValue());
+        System.arraycopy(Serialization.encodeVi32(type.getValue()), 0, bytes, idx, len);
 
         idx += len;
         System.arraycopy(Serialization.encodeI8(option_flag.getByteValue()), 0, bytes, idx, 1);
@@ -107,7 +111,7 @@ public long getPayloadContentSize() {
         if (ObGlobal.obVsnMajor() >= 4)
             return Serialization.getNeedBytes(credential) + Serialization.getNeedBytes(tableName)
                    + Serialization.getNeedBytes(tableId) + 8 + 1
-                   + tableQueryAndMutate.getPayloadSize() + 1;
+                   + tableQueryAndMutate.getPayloadSize() + Serialization.getNeedBytes(type.getValue()) + 1;
         else
             return Serialization.getNeedBytes(credential) + Serialization.getNeedBytes(tableName)
                    + Serialization.getNeedBytes(tableId) + Serialization.getNeedBytes(partitionId)