Client 2 1 0 (#94)

* add native hbase test (#90)

* merge native hbase test

Author: stuBirdFly

obkv-table-client-1.2.114-SNAPSHOT-jar-with-dependencies.jar

@@ -105,10 +105,17 @@
                 </exclusion>
             </exclusions>
         </dependency>
+<!--        <dependency>-->
+<!--            <groupId>com.oceanbase</groupId>-->
+<!--            <artifactId>obkv-table-client</artifactId>-->
+<!--            <version>${table.client.version}</version>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>com.oceanbase</groupId>
             <artifactId>obkv-table-client</artifactId>
-            <version>${table.client.version}</version>
+            <version>1.2.114-SNAPSHOT</version>
+            <scope>system</scope>
+            <systemPath>${project.basedir}/obkv-table-client-1.2.114-SNAPSHOT-jar-with-dependencies.jar</systemPath>
         </dependency>
         <dependency>
             <groupId>org.apache.hbase</groupId>

pom.xml

@@ -1445,25 +1445,30 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
                                            boolean includeStart, byte[] stop, boolean includeStop,
                                            boolean isReversed) {
         ObNewRange obNewRange = new ObNewRange();
-
+        ObBorderFlag obBorderFlag = new ObBorderFlag();
         if (Arrays.equals(start, HConstants.EMPTY_BYTE_ARRAY)) {
             obNewRange.setStartKey(ObRowKey.getInstance(ObObj.getMin(), ObObj.getMin(),
                 ObObj.getMin()));
         } else if (includeStart) {
             obNewRange.setStartKey(ObRowKey.getInstance(start, ObObj.getMin(), ObObj.getMin()));
+            obBorderFlag.setInclusiveStart();
         } else {
             obNewRange.setStartKey(ObRowKey.getInstance(start, ObObj.getMax(), ObObj.getMax()));
+            obBorderFlag.unsetInclusiveStart();
         }
 
         if (Arrays.equals(stop, HConstants.EMPTY_BYTE_ARRAY)) {
             obNewRange.setEndKey(ObRowKey.getInstance(ObObj.getMax(), ObObj.getMax(),
                 ObObj.getMax()));
         } else if (includeStop) {
             obNewRange.setEndKey(ObRowKey.getInstance(stop, ObObj.getMax(), ObObj.getMax()));
+            obBorderFlag.setInclusiveEnd();
         } else {
             obNewRange.setEndKey(ObRowKey.getInstance(stop, ObObj.getMin(), ObObj.getMin()));
+            obBorderFlag.unsetInclusiveEnd();
         }
         ObTableQuery obTableQuery = new ObTableQuery();
+        obNewRange.setBorderFlag(obBorderFlag);
         if (isReversed) {
             obTableQuery.setScanOrder(ObScanOrder.Reverse);
         }

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

@@ -50,8 +50,6 @@ public class ClientStreamScanner extends AbstractClientScanner {
 
     private boolean                         closed       = false;
 
-    private boolean                         streamNext   = true;
-
     private boolean                         isTableGroup = false;
 
     public ClientStreamScanner(ObTableClientQueryStreamResult streamResult, String tableName,
@@ -145,7 +143,12 @@ public Result[] next(int nbRows) throws IOException {
 
     @Override
     public boolean renewLease() {
-        throw new FeatureNotSupportedException("not supported yet'");
+        try {
+            streamResult.renewLease();
+            return true;
+        } catch (Exception e) {
+            return false;
+        }
     }
 
     private void checkStatus() throws IllegalStateException {