adapt fulltext query

Author: GroundWu

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

@@ -68,9 +68,10 @@ public class ObTableQuery extends AbstractPayload {
     protected long                maxResultSize             = -1;
     protected ObHTableFilter      hTableFilter;
 
-    protected static final byte[] HTABLE_DUMMY_BYTES = new byte[] { 0x01, 0x00 };
-    protected boolean             isHbaseQuery              = false;
-    protected List<String>        scanRangeColumns          = new LinkedList<String>();
+    private static final byte[] HTABLE_DUMMY_BYTES = new byte[] { 0x01, 0x00 };
+    private boolean             isHbaseQuery              = false;
+    private boolean             isFTSQuery                = true;
+    private List<String>        scanRangeColumns          = new LinkedList<String>();
 
     protected List<ObTableAggregationSingle>    aggregations       = new LinkedList<>();
 
@@ -561,18 +562,21 @@ public void setObKVParams(ObKVParams obKVParams) {
     }
 
     public void setSearchText(String searchText) {
-        if (isHbaseQuery) {
+        if (this.isHbaseQuery) {
             throw new FeatureNotSupportedException("Hbase query not support full text search currently");
         }
-        if (obKVParams == null) {
+        if (this.obKVParams == null) {
             obKVParams = new ObKVParams();
         }
         ObFTSParams ftsParams = (ObFTSParams)obKVParams.getObParams(ObKVParamsBase.paramType.FTS);
         ftsParams.setSearchText(searchText);
-        obKVParams.setObParamsBase(ftsParams);
+        this.obKVParams.setObParamsBase(ftsParams);
+        this.isFTSQuery = true;
     }
 
     public ObKVParams getObKVParams() {
         return obKVParams;
     }
+
+    public boolean isFTSQuery() { return isFTSQuery; }
 }

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

@@ -159,6 +159,10 @@ 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());
         }
 
         // init partitionObTables

src/test/java/com/alipay/oceanbase/rpc/ObTableFullTextIndexTest.java

@@ -27,7 +27,7 @@ public class ObTableFullTextIndexTest {
     ObTableClient client;
     String tableName = "tbl1";
     String ttlTableName = "ttl_tbl1";
-    String createTableSQL = "CREATE TABLE IF NOT EXISTS tbl1(id INT, c2 INT, txt text, PRIMARY KEY (id), FULLTEXT INDEX full_idx1_tbl1(txt));";
+    String createTableSQL = "CREATE TABLE IF NOT EXISTS tbl1(id INT, c2 INT, txt text, PRIMARY KEY (id), FULLTEXT INDEX full_idx1_tbl1(txt)) partition by key(id) partitions 3;";
     String createTTLTableSQL = "CREATE TABLE IF NOT EXISTS ttl_tbl1(id INT, c2 INT, txt text, expired_ts timestamp(6), PRIMARY KEY (id), FULLTEXT INDEX full_idx1_tbl1(txt)) TTL(expired_ts + INTERVAL 10 SECOND);;";
     String truncateTableSQL = "truncate table tbl1;";
     String truncateTTLTableSQL = "truncate table ttl_tbl1;";
@@ -326,11 +326,13 @@ public void testTTLInsert() throws Exception {
     }
 
     @Test
-    public void testFtsQuery() throws Exception {
+    public void testFTSQuery() throws Exception {
         try {
+            client.addRowKeyElement(tableName, new String[] {"id"});
+
             //sync query
             QueryResultSet resultSet = client.query(tableName)
-                    .setSearchText("native")
+                    .setSearchText("oceanbase")
                     .indexName("full_idx1_tbl1")
                     .execute();
             while(resultSet.next()) {