set isReadOnly for hbase get

JackShi148 · JackShi148 · commit 919c270aee9e · 2025-01-02T19:19:47.000+08:00
diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableTabletOp.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableTabletOp.java
@@ -155,8 +155,12 @@ public void setSingleOperations(List<ObTableSingleOp> singleOperations) {
             }
         }
 
-        if (isSameType() && singleOperations.get(0).getSingleOpType() == ObTableOperationType.GET) {
-            setIsReadOnly(true);
+        if (isSameType()) {
+            boolean isHbaseOps = singleOperations.get(0).getQuery().isHbaseQuery();
+            if ((isHbaseOps && singleOperations.get(0).getSingleOpType() == ObTableOperationType.SCAN)
+                || (!isHbaseOps && singleOperations.get(0).getSingleOpType() == ObTableOperationType.GET)) {
+                setIsReadOnly(true);
+            }
         }
         this.singleOperations = singleOperations;
     }

Original file line number	Diff line number	Diff line change
`@@ -155,8 +155,12 @@ public void setSingleOperations(List<ObTableSingleOp> singleOperations) {`
`155`	`155`	`}`
`156`	`156`	`}`
`157`	`157`
`158`		`- if (isSameType() && singleOperations.get(0).getSingleOpType() == ObTableOperationType.GET) {`
`159`		`- setIsReadOnly(true);`
	`158`	`+ if (isSameType()) {`
	`159`	`+ boolean isHbaseOps = singleOperations.get(0).getQuery().isHbaseQuery();`
	`160`	`+ if ((isHbaseOps && singleOperations.get(0).getSingleOpType() == ObTableOperationType.SCAN)`
	`161`	`+ \|\| (!isHbaseOps && singleOperations.get(0).getSingleOpType() == ObTableOperationType.GET)) {`
	`162`	`+ setIsReadOnly(true);`
	`163`	`+ }`
`160`	`164`	`}`
`161`	`165`	`this.singleOperations = singleOperations;`
`162`	`166`	`}`