do fetch by error code

Author: maochongxin

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

@@ -140,10 +140,18 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
                 }
             }
             if (resultCode.getRcode() != 0) {
-                ExceptionUtil.throwObTableException(conn.getObTable().getIp(), conn.getObTable()
-                    .getPort(), response.getHeader().getTraceId1(), response.getHeader()
-                    .getTraceId0(), resultCode.getRcode(), resultCode.getErrMsg());
-                return null;
+                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);
+                } else if (needFetchPartial(resultCode.getRcode())) {
+                    throw new ObTableRoutingWrongException(errMessage);
+                } else {
+                    ExceptionUtil.throwObTableException(conn.getObTable().getIp(), conn.getObTable()
+                            .getPort(), response.getHeader().getTraceId1(), response.getHeader()
+                            .getTraceId0(), resultCode.getRcode(), resultCode.getErrMsg());
+                }
             }
 
             // decode payload itself
@@ -178,6 +186,7 @@ protected InvokeFuture createInvokeFuture(Connection conn, RemotingCommand reque
                                               InvokeCallback invokeCallback) {
         return new ObClientFuture(request.getId());
     }
+    
 
     // schema changed
     private boolean needFetchAll(int errorCode, int pcode) {