fix isKeyInRange when encounter MinObObj or MaxObObj

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableRemoting.java

@@ -123,7 +123,7 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
             boolean isNeedRefreshMeta = false;
             ObRpcResultCode resultCode = new ObRpcResultCode();
             resultCode.decode(buf);
-            logger.debug("require_rerouting_: {}, need_refresh_kv_meta_: {}"
+            logger.debug("require_rerouting: {}, need_refresh_kv_meta: {}"
                     , response.getHeader().isRoutingWrong(), response.getHeader().isNeedRefreshKvMeta());
             if (response.getHeader().getPcode() != Pcodes.OB_TABLE_API_MOVE) {
                 if (resultCode.getRcode() != 0) {

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

@@ -108,17 +108,31 @@ private byte[] parseStartKeyToBytes(List<ObObj> key) {
     }
 
     private boolean isKeyInRange(ObNewRange range, List<ObObj> key) {
-        byte[] startKeyBytes = parseStartKeyToBytes(range.getStartKey().getObjs());
-        byte[] endKeyBytes = parseStartKeyToBytes(range.getEndKey().getObjs());
-        byte[] keyBytes = parseStartKeyToBytes(key);
+        if (range.getStartKey().getObj(0).isMinObj() && range.getEndKey().getObj(0).isMaxObj()) {
+            return true;
+        } else if (range.getStartKey().getObj(0).isMinObj()) {
+            byte[] keyBytes = parseStartKeyToBytes(key);
+            byte[] endKeyBytes = parseStartKeyToBytes(range.getEndKey().getObjs());
+            int endComparison = compareByteArrays(endKeyBytes, keyBytes);
+            return endComparison > 0;
+        } else if (range.getEndKey().getObj(0).isMaxObj()) {
+            byte[] keyBytes = parseStartKeyToBytes(key);
+            byte[] startKeyBytes = parseStartKeyToBytes(range.getStartKey().getObjs());
+            int startComparison = compareByteArrays(startKeyBytes, keyBytes);
+            return startComparison <= 0;
+        } else {
+            byte[] startKeyBytes = parseStartKeyToBytes(range.getStartKey().getObjs());
+            byte[] endKeyBytes = parseStartKeyToBytes(range.getEndKey().getObjs());
+            byte[] keyBytes = parseStartKeyToBytes(key);
 
-        int startComparison = compareByteArrays(startKeyBytes, keyBytes);
-        int endComparison = compareByteArrays(endKeyBytes, keyBytes);
+            int startComparison = compareByteArrays(startKeyBytes, keyBytes);
+            int endComparison = compareByteArrays(endKeyBytes, keyBytes);
 
-        boolean withinStart = startComparison <= 0;
-        boolean withinEnd = endComparison > 0;
+            boolean withinStart = startComparison <= 0;
+            boolean withinEnd = endComparison > 0;
 
-        return withinStart && withinEnd;
+            return withinStart && withinEnd;
+        }
     }