fix compatibility problem

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/mutation/BatchOperation.java

@@ -89,12 +89,26 @@ public BatchOperation setTable(String tableName) {
      * add queries
      */
     public BatchOperation addOperation(TableQuery... queries) {
-        if (isSameType && lastType != ObTableOperationType.INVALID
-            && lastType != ObTableOperationType.GET) {
-            isSameType = false;
+        boolean isHBaseQuery = false;
+        for (TableQuery query : queries) {
+            if (query.getObTableQuery().isHbaseQuery()) {
+                isHBaseQuery = true;
+            }
+            break;
+        }
+        if (isHBaseQuery) {
+            if (isSameType && lastType != ObTableOperationType.INVALID
+                && lastType != ObTableOperationType.SCAN) {
+                isSameType = false;
+            }
+            lastType = ObTableOperationType.SCAN;
+        } else {
+            if (isSameType && lastType != ObTableOperationType.INVALID
+                && lastType != ObTableOperationType.GET) {
+                isSameType = false;
+            }
+            lastType = ObTableOperationType.GET;
         }
-
-        lastType = ObTableOperationType.GET;
         this.operations.addAll(Arrays.asList(queries));
         return this;
     }

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

@@ -34,15 +34,15 @@ public enum ObTableOperationType {
 
     private int                                       value;
     private static Map<Integer, ObTableOperationType> map             = new HashMap<Integer, ObTableOperationType>();
-    private static final List<Boolean>                needEncodeQuery = Arrays.asList(true, // GET
+    private static final List<Boolean>                needEncodeQuery = Arrays.asList(false, // GET
                                                                           false, // INSERT
                                                                           false, // DEL
                                                                           false, // UPDATE
                                                                           false, // INSERT_OR_UPDATE
                                                                           false, // REPLACE
                                                                           false, // INCREMENT
                                                                           false, // APPEND
-                                                                          false, // SCAN
+                                                                          true, // SCAN
                                                                           false, // TTL
                                                                           true, // CHECK_AND_INSERT_UP
                                                                           false, // PUT

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

@@ -163,7 +163,11 @@ public void addEntity(ObTableSingleOpEntity entity) {
     public List<ObObj> getRowkeyObjs() {
         List<ObObj> rowkeyObjs;
         if (singleOpType == ObTableOperationType.SCAN) {
-            throw new IllegalArgumentException("can not get rowkey from scan operation");
+            if (query.isHbaseQuery()) {
+                rowkeyObjs = entities.get(0).getRowkey();
+            } else {
+                throw new IllegalArgumentException("can not get rowkey from scan operation");
+            }
         } else if (singleOpType == ObTableOperationType.CHECK_AND_INSERT_UP) {
             rowkeyObjs = getScanRange().get(0).getStartKey().getObjs();
         } else {

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

@@ -206,8 +206,10 @@ public void addOperation(TableQuery query) throws Exception {
                 obTableQuery.isHbaseQuery(), obTableQuery.gethTableFilter(),
                 obTableQuery.getObKVParams(), obTableQuery.getFilterString());
             singleOp.setQuery(singleOpQuery);
+            singleOp.setSingleOpType(ObTableOperationType.SCAN);
+        } else {
+            singleOp.setSingleOpType(ObTableOperationType.GET);
         }
-        singleOp.setSingleOpType(ObTableOperationType.GET);
         singleOp.addEntity(entity);
         addOperation(singleOp);
     }