add ob verison check when do fts query

Author: GroundWu

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

@@ -86,6 +86,10 @@ public static boolean isLsOpSupport() {
                || OB_VERSION >= OB_VERSION_4_3_4_0;
     }
 
+    public static boolean isFtsQuerySupport() {
+        return OB_VERSION >= OB_VERSION_4_3_5_1;
+    }
+
     public static boolean isReturnOneResultSupport() {
         return OB_VERSION >= OB_VERSION_4_2_3_0 && OB_VERSION < OB_VERSION_4_3_0_0
                || OB_VERSION >= OB_VERSION_4_3_4_0;
@@ -96,6 +100,8 @@ public static boolean isReturnOneResultSupport() {
     public static final long OB_VERSION_4_3_0_0 = calcVersion(4, (short) 3, (byte) 0, (byte) 0);
 
     public static final long OB_VERSION_4_3_4_0 = calcVersion(4, (short) 3, (byte) 4, (byte) 0);
+    // todo @weifeng : change ob version to 4_3_5_1
+    public static final long OB_VERSION_4_3_5_1 = calcVersion(4, (short) 3, (byte) 5, (byte) 0);
 
     public static long       OB_VERSION         = calcVersion(0, (short) 0, (byte) 0, (byte) 0);
 }

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

@@ -17,7 +17,9 @@
 
 package com.alipay.oceanbase.rpc.table;
 
+import com.alipay.oceanbase.rpc.ObGlobal;
 import com.alipay.oceanbase.rpc.ObTableClient;
+import com.alipay.oceanbase.rpc.exception.FeatureNotSupportedException;
 import com.alipay.oceanbase.rpc.exception.ObTableException;
 import com.alipay.oceanbase.rpc.location.model.partition.ObPair;
 import com.alipay.oceanbase.rpc.mutation.Row;
@@ -129,6 +131,15 @@ public void checkArgumentBeforeExec() throws Exception {
             throw new ObTableException("offset can not be use without limit");
         } else if (tableName == null || tableName.isEmpty()) {
             throw new IllegalArgumentException("table name is null");
+        } else if (tableQuery.isFTSQuery()) {
+            if (!ObGlobal.isFtsQuerySupport()) {
+                throw new FeatureNotSupportedException("full text query is not supported in "+ObGlobal.OB_VERSION);
+            }
+            if (tableQuery.getIndexName() == null || tableQuery.getIndexName().isEmpty()
+                    || tableQuery.getIndexName().equalsIgnoreCase("primary")) {
+                throw new IllegalArgumentException(
+                        "use fulltext search but specified index name is not fulltext index");
+            }
         }
     }
 
@@ -159,15 +170,6 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
         // fill a whole range if no range is added explicitly.
         if (tableQuery.getKeyRanges().isEmpty()) {
             tableQuery.addKeyRange(ObNewRange.getWholeRange());
-        } else if (tableQuery.isFTSQuery()) {
-            // Currently, fulltext query only support scan all partitions
-            tableQuery.getKeyRanges().clear();
-            tableQuery.addKeyRange(ObNewRange.getWholeRange());
-            if (tableQuery.getIndexName() == null || tableQuery.getIndexName().isEmpty()
-                    || tableQuery.getIndexName().equalsIgnoreCase("primary")) {
-                throw new IllegalArgumentException(
-                        "use fulltext search but specified index name is not fulltext index");
-            }
         }
 
         // init partitionObTables