Refactor table routing process

src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java

@@ -105,6 +105,10 @@ public static boolean isHBaseBatchSupport() {
                || OB_VERSION >= OB_VERSION_4_3_5_0;
     }
 
+    public static boolean isSchemaVersionSupport() {
+        return OB_VERSION >= OB_VERSION_4_3_5_2;
+    }
+
     public static boolean isDistributedExecSupport() {
         return OB_VERSION >= OB_VERSION_4_3_5_2;
     }

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

@@ -195,6 +195,8 @@ private void login() throws Exception {
                 // no need to retry when the username or password is wrong.
                 if (e instanceof ObTableAuthException) {
                     throw new ObTableLoginException(errMessage, e);
+                } else if (e instanceof FeatureNotSupportedException) {
+                    throw e;
                 }
             }
         }
@@ -230,6 +232,7 @@ public void checkStatus() throws Exception {
             reconnect("Check connection is null");
         }
         if (connection.getChannel() == null || !connection.getChannel().isActive()) {
+            LOGGER.warn("[latency monitor] need to reconnect server: {}:{}", obTable.getIp(), obTable.getPort());
             reconnect("Check connection failed for address: " + connection.getUrl());
         }
         if (!connection.getChannel().isWritable()) {

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

@@ -84,7 +84,7 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
             return null;
         } else if (!response.isSuccess()) {
             String errMessage = TraceUtil.formatTraceMessage(conn, request,
-                "get an error response: " + response.getMessage());
+                "get an error response: " + response.getMessage() + ", transportCode: " + response.getTransportCode());
             logger.warn(errMessage);
             response.releaseByteBuf();
             ExceptionUtil.throwObTableTransportException(errMessage, response.getTransportCode());
@@ -125,30 +125,30 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
             if (!conn.getObTable().isEnableRerouting() && response.getHeader().isRoutingWrong()) {
                 String errMessage = TraceUtil.formatTraceMessage(conn, request,
                     "routed to the wrong server: [error code:" + resultCode.getRcode() + "]"
-                            + response.getMessage());
+                            + resultCode.getErrMsg());
                 logger.debug(errMessage);
-                if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
-                    throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
-                } else if (needFetchPartial(resultCode.getRcode())) {
+                if (needFetchMeta(resultCode.getRcode(), resultCode.getPcode())) {
+                    throw new ObTableNeedFetchMetaException(errMessage, resultCode.getRcode());
+                } else if (needFetchPartitionLocation(resultCode.getRcode())) {
                     throw new ObTableRoutingWrongException(errMessage, resultCode.getRcode());
                 } else {
                     // Encountered an unexpected RoutingWrong error code, 
                     // possibly due to the client error code version being behind the observer's version.  
                     // Attempting a full refresh here
                     // and delegating to the upper-level call to determine whether to throw the exception to the user based on the retry result.
                     logger.warn("get unexpected error code: {}", errMessage);
-                    throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
+                    throw new ObTableNeedFetchMetaException(errMessage, resultCode.getRcode());
                 }
             }
             if (resultCode.getRcode() != 0
                 && response.getHeader().getPcode() != Pcodes.OB_TABLE_API_MOVE) {
                 String errMessage = TraceUtil.formatTraceMessage(conn, request,
                     "routed to the wrong server:  [error code:" + resultCode.getRcode() + "]"
-                            + response.getMessage());
+                            + resultCode.getErrMsg());
                 logger.debug(errMessage);
-                if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
-                    throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
-                } else if (needFetchPartial(resultCode.getRcode())) {
+                if (needFetchMeta(resultCode.getRcode(), resultCode.getPcode())) {
+                    throw new ObTableNeedFetchMetaException(errMessage, resultCode.getRcode());
+                } else if (needFetchPartitionLocation(resultCode.getRcode())) {
                     throw new ObTableRoutingWrongException(errMessage, resultCode.getRcode());
                 } else {
                     logger.warn(errMessage);
@@ -192,7 +192,7 @@ protected InvokeFuture createInvokeFuture(Connection conn, RemotingCommand reque
     }
 
     // schema changed
-    private boolean needFetchAll(int errorCode, int pcode) {
+    private boolean needFetchMeta(int errorCode, int pcode) {
         return errorCode == ResultCodes.OB_SCHEMA_ERROR.errorCode
                || errorCode == ResultCodes.OB_TABLE_NOT_EXIST.errorCode
                || errorCode == ResultCodes.OB_TABLET_NOT_EXIST.errorCode
@@ -202,10 +202,11 @@ private boolean needFetchAll(int errorCode, int pcode) {
                || errorCode == ResultCodes.OB_SCHEMA_EAGAIN.errorCode
                || errorCode == ResultCodes.OB_ERR_WAIT_REMOTE_SCHEMA_REFRESH.errorCode
                || errorCode == ResultCodes.OB_GTS_NOT_READY.errorCode
+               || errorCode == ResultCodes.OB_ERR_OPERATION_ON_RECYCLE_OBJECT.errorCode
                || (pcode == Pcodes.OB_TABLE_API_LS_EXECUTE && errorCode == ResultCodes.OB_NOT_MASTER.errorCode);
     }
 
-    private boolean needFetchPartial(int errorCode) {
+    private boolean needFetchPartitionLocation(int errorCode) {
         return errorCode == ResultCodes.OB_LOCATION_LEADER_NOT_EXIST.errorCode
                || errorCode == ResultCodes.OB_NOT_MASTER.errorCode
                || errorCode == ResultCodes.OB_RS_NOT_MASTER.errorCode

src/main/java/com/alipay/oceanbase/rpc/checkandmutate/CheckAndInsUp.java

@@ -109,7 +109,7 @@ public MutationResult execute() throws Exception {
         ObTableOperation operation = ObTableOperation.getInstance(ObTableOperationType.INSERT_OR_UPDATE,
                 insUp.getRowKey().getValues(), insUp.getColumns(), insUp.getValues());
 
-        return new MutationResult(((ObTableClient)client).mutationWithFilter(query, rowKey, ranges, operation,
+        return new MutationResult(((ObTableClient)client).mutationWithFilter(query, rowKey, operation,
                 false, true, checkExists, rollbackWhenCheckFailed));
     }
 }

src/main/java/com/alipay/oceanbase/rpc/exception/ObTableEntryRefreshException.java

@@ -18,7 +18,7 @@
 package com.alipay.oceanbase.rpc.exception;
 
 public class ObTableEntryRefreshException extends ObTableException {
-    
+
     private boolean connectInactive = false;
 
     /*
@@ -54,7 +54,7 @@ public ObTableEntryRefreshException(String message) {
     public ObTableEntryRefreshException(String message, Throwable cause) {
         super(message, cause);
     }
-    
+
     public ObTableEntryRefreshException(String message, Throwable cause, boolean connectInactive) {
         super(message, cause);
         this.connectInactive = connectInactive;
@@ -63,6 +63,7 @@ public ObTableEntryRefreshException(String message, Throwable cause, boolean con
     public boolean isConnectInactive() {
         return connectInactive;
     }
+
     /*
      * Ob table entry refresh exception.
      */

src/main/java/com/alipay/oceanbase/rpc/exception/ObTableException.java

@@ -17,10 +17,12 @@
 
 package com.alipay.oceanbase.rpc.exception;
 
+import com.alipay.oceanbase.rpc.protocol.payload.ResultCodes;
+
 public class ObTableException extends RuntimeException {
 
-    private int     errorCode;
-    private boolean needRefreshTableEntry;
+    private int     errorCode             = -1;
+    private boolean needRefreshTableEntry = false;
 
     /*
      * Ob table exception.
@@ -82,4 +84,10 @@ public boolean isNeedRefreshTableEntry() {
         return needRefreshTableEntry;
     }
 
+    public boolean isNeedRetryServerError() {
+        return errorCode == ResultCodes.OB_TRY_LOCK_ROW_CONFLICT.errorCode
+               || errorCode == ResultCodes.OB_TRANSACTION_SET_VIOLATION.errorCode
+               || errorCode == ResultCodes.OB_SCHEMA_EAGAIN.errorCode;
+    }
+
 }

src/main/java/com/alipay/oceanbase/rpc/exception/ObTableNeedFetchAllException.java → src/main/java/com/alipay/oceanbase/rpc/exception/ObTableNeedFetchMetaException.java

@@ -17,45 +17,47 @@
 
 package com.alipay.oceanbase.rpc.exception;
 
-public class ObTableNeedFetchAllException extends ObTableException {
+import com.alipay.oceanbase.rpc.protocol.payload.ResultCodes;
+
+public class ObTableNeedFetchMetaException extends ObTableException {
     /*
      * Ob table routing wrong exception.
      */
-    public ObTableNeedFetchAllException() {
+    public ObTableNeedFetchMetaException() {
     }
 
     /*
      * Ob table routing wrong exception with error code.
      */
-    public ObTableNeedFetchAllException(int errorCode) {
+    public ObTableNeedFetchMetaException(int errorCode) {
         super(errorCode);
     }
 
     /*
      * Ob table routing wrong exception with message and error code.
      */
-    public ObTableNeedFetchAllException(String message, int errorCode) {
+    public ObTableNeedFetchMetaException(String message, int errorCode) {
         super(message, errorCode);
     }
 
     /*
      * Ob table routing wrong exception with message.
      */
-    public ObTableNeedFetchAllException(String message) {
+    public ObTableNeedFetchMetaException(String message) {
         super(message);
     }
 
     /*
      * Ob table routing wrong exception with message and cause.
      */
-    public ObTableNeedFetchAllException(String message, Throwable cause) {
+    public ObTableNeedFetchMetaException(String message, Throwable cause) {
         super(message, cause);
     }
 
     /*
      * Ob table routing wrong exception with cause.
      */
-    public ObTableNeedFetchAllException(Throwable cause) {
+    public ObTableNeedFetchMetaException(Throwable cause) {
         super(cause);
     }
 
@@ -65,4 +67,13 @@ public ObTableNeedFetchAllException(Throwable cause) {
     public boolean isNeedRefreshTableEntry() {
         return true;
     }
+
+    public boolean isNeedRefreshMetaAndLocation() {
+        return getErrorCode() == ResultCodes.OB_LS_NOT_EXIST.errorCode // need to refresh the whole tablets in this ls
+               || getErrorCode() == ResultCodes.OB_SNAPSHOT_DISCARDED.errorCode // fetch a wrong ls tablets, need to refetch locations
+               || getErrorCode() == ResultCodes.OB_TABLET_NOT_EXIST.errorCode
+               || getErrorCode() == ResultCodes.OB_ERR_OPERATION_ON_RECYCLE_OBJECT.errorCode // table has been drop and recreated
+               || getErrorCode() == ResultCodes.OB_MAPPING_BETWEEN_TABLET_AND_LS_NOT_EXIST.errorCode
+               || getErrorCode() == ResultCodes.OB_SCHEMA_ERROR.errorCode; // drop table
+    }
 }

src/main/java/com/alipay/oceanbase/rpc/exception/ObTableSchemaVersionMismatchException.java

@@ -0,0 +1,61 @@
+/*-
+ * #%L
+ * com.oceanbase:obkv-table-client
+ * %%
+ * Copyright (C) 2021 - 2025 OceanBase
+ * %%
+ * OBKV Table Client Framework is licensed under Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ *          http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
+ * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
+ * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ * #L%
+ */
+
+package com.alipay.oceanbase.rpc.exception;
+
+public class ObTableSchemaVersionMismatchException extends ObTableException {
+    /*
+     * Ob table schema version mismatch exception.
+     */
+    public ObTableSchemaVersionMismatchException() {
+    }
+
+    /*
+     * Ob table schema version mismatch exception with error code.
+     */
+    public ObTableSchemaVersionMismatchException(int errorCode) {
+        super(errorCode);
+    }
+
+    /*
+     * Ob table schema version mismatch exception with message and error code.
+     */
+    public ObTableSchemaVersionMismatchException(String message, int errorCode) {
+        super(message, errorCode);
+    }
+
+    /*
+     * Ob table schema version mismatch exception with message.
+     */
+    public ObTableSchemaVersionMismatchException(String message) {
+        super(message);
+    }
+
+    /*
+     * Ob table schema version mismatch exception with message and cause.
+     */
+    public ObTableSchemaVersionMismatchException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    /*
+     * Ob table schema version mismatch exception with case.
+     */
+    public ObTableSchemaVersionMismatchException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/alipay/oceanbase/rpc/exception/ObTableTryLockTimeoutException.java

@@ -0,0 +1,61 @@
+/*-
+ * #%L
+ * com.oceanbase:obkv-table-client
+ * %%
+ * Copyright (C) 2021 - 2025 OceanBase
+ * %%
+ * OBKV Table Client Framework is licensed under Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ *          http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
+ * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
+ * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ * #L%
+ */
+
+package com.alipay.oceanbase.rpc.exception;
+
+public class ObTableTryLockTimeoutException extends ObTableException {
+    /*
+     * Ob table try lock timeout exception.
+     */
+    public ObTableTryLockTimeoutException() {
+    }
+
+    /*
+     * Ob table try lock timeout exception.
+     */
+    public ObTableTryLockTimeoutException(int errorCode) {
+        super(errorCode);
+    }
+
+    /*
+     * Ob table try lock timeout exception.
+     */
+    public ObTableTryLockTimeoutException(String message, int errorCode) {
+        super(message, errorCode);
+    }
+
+    /*
+     * Ob table try lock timeout exception.
+     */
+    public ObTableTryLockTimeoutException(String message) {
+        super(message);
+    }
+
+    /*
+     * Ob table try lock timeout exception.
+     */
+    public ObTableTryLockTimeoutException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    /*
+     * Ob table try lock timeout exception.
+     */
+    public ObTableTryLockTimeoutException(Throwable cause) {
+        super(cause);
+    }
+}