add error code for rerouting-exception

Author: maochongxin

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

@@ -127,26 +127,26 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
                     "routed to the wrong server: " + response.getMessage());
                 logger.warn(errMessage);
                 if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
-                    throw new ObTableNeedFetchAllException(errMessage);
+                    throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
                 } else if (needFetchPartial(resultCode.getRcode())) {
-                    throw new ObTableRoutingWrongException(errMessage);
+                    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: {}", response.getMessage());
-                    throw new ObTableNeedFetchAllException(errMessage);
+                    throw new ObTableNeedFetchAllException(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: " + response.getMessage());
                 logger.warn(errMessage);
                 if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
-                    throw new ObTableNeedFetchAllException(errMessage);
+                    throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
                 } else if (needFetchPartial(resultCode.getRcode())) {
-                    throw new ObTableRoutingWrongException(errMessage);
+                    throw new ObTableRoutingWrongException(errMessage, resultCode.getRcode());
                 } else {
                     ExceptionUtil.throwObTableException(conn.getObTable().getIp(), conn
                         .getObTable().getPort(), response.getHeader().getTraceId1(), response

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

@@ -509,8 +509,7 @@ private boolean shouldRetry(Throwable throwable) {
     private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableOperation>>>> entry, int maxRetries) throws Exception {
         int retryCount = 0;
         boolean success = false;
-
-        // 初始分区  
+        
         Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableOperation>>>> currentPartitions = new HashMap<>();
         currentPartitions.put(entry.getKey(), entry.getValue());
 

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

@@ -624,8 +624,7 @@ private void executeWithRetries(
 
         int retryCount = 0;
         boolean success = false;
-
-        // 初始分区  
+        
         Map<Long, Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSingleOp>>>>> currentPartitions = new HashMap<>();
         currentPartitions.put(entry.getKey(), entry.getValue());