feat: support user_specific_T flag for ObTableQueryAndMutate and ObTableSingleOp (#289)

Author: maochongxin

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

@@ -21,6 +21,7 @@ public class ObTableQueryAndMutateFlag {
     private static final int FLAG_IS_CHECK_AND_EXECUTE          = 1 << 0;
     private static final int FLAG_IS_CHECK_NOT_EXISTS           = 1 << 1;
     private static final int FLAG_IS_ROLLBACK_WHEN_CHECK_FAILED = 1 << 2;
+    private static final int FLAG_IS_USER_SPECIFIED_T           = 1 << 3;
     private long             flags                              = 0;
 
     public void setIsCheckAndExecute(boolean isCheckAndExecute) {
@@ -46,6 +47,14 @@ public void setIsRollbackWhenCheckFailed(boolean isRollbackWhenCheckFailed) {
             flags &= ~FLAG_IS_ROLLBACK_WHEN_CHECK_FAILED;
         }
     }
+    
+    public void setIsUserSpecifiedT(boolean isUserSpecifiedT) {
+        if (isUserSpecifiedT) {
+            flags |= FLAG_IS_USER_SPECIFIED_T;
+        } else {
+            flags &= ~FLAG_IS_USER_SPECIFIED_T;
+        }
+    }
 
     public long getValue() {
         return flags;
@@ -62,4 +71,8 @@ public boolean isCheckAndExecute() {
     public boolean isRollbackWhenCheckFailed() {
         return (flags & FLAG_IS_ROLLBACK_WHEN_CHECK_FAILED) != 0;
     }
+    
+    public boolean isUserSpecifiedT() {
+        return (flags & FLAG_IS_USER_SPECIFIED_T) != 0;
+    }
 }

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

@@ -20,6 +20,7 @@
 public class ObTableSingleOpFlag {
     private static final int FLAG_IS_CHECK_NOT_EXISTS = 1 << 0;
     private static final int FLAG_IS_ROLLBACK_WHEN_CHECK_FAILED = 1 << 1;
+    private static final int FLAG_IS_USER_SPECIFIED_T = 1 << 2;
     private long             flags                    = 0;
 
     public void setIsCheckNotExists(boolean isCheckNotExists) {
@@ -37,6 +38,14 @@ public void setIsRollbackWhenCheckFailed(boolean isRollbackWhenCheckFailed) {
             flags &= ~FLAG_IS_ROLLBACK_WHEN_CHECK_FAILED;
         }
     }
+    
+    public void setIsUserSpecifiedT(boolean isUserSpecifiedT) {
+        if (isUserSpecifiedT) {
+            flags |= FLAG_IS_USER_SPECIFIED_T;
+        } else {
+            flags &= ~FLAG_IS_USER_SPECIFIED_T;
+        }
+    }
 
     public long getValue() {
         return flags;
@@ -49,7 +58,10 @@ public boolean isCheckNotExists() {
     public boolean isRollbackWhenCheckFailed() {
         return (flags & FLAG_IS_ROLLBACK_WHEN_CHECK_FAILED) != 0;
     }
-
+    public boolean isUserSpecifiedT() {
+        return (flags & FLAG_IS_USER_SPECIFIED_T) != 0;
+    }
+    
     void setValue(long value) {
         flags = value;
     }