Align obkv-hbase enable/disable exception handling with HBase

fix syntax errors

Align obkv-hbase enable/disable exception handling with HBase

Author: Zhou-jw

src/main/java/com/alipay/oceanbase/hbase/util/OHTableAccessControlExecutor.java

@@ -2,7 +2,9 @@
 
 import com.alibaba.fastjson.JSON;
 import com.alipay.oceanbase.hbase.execute.AbstractObTableMetaExecutor;
+import com.alipay.oceanbase.rpc.protocol.payload.ResultCodes;
 import com.alipay.oceanbase.rpc.ObTableClient;
+import com.alipay.oceanbase.rpc.exception.ObTableException;
 import com.alipay.oceanbase.rpc.meta.ObTableMetaRequest;
 import com.alipay.oceanbase.rpc.meta.ObTableMetaResponse;
 import com.alipay.oceanbase.rpc.meta.ObTableRpcMetaType;
@@ -40,7 +42,21 @@ public Void enableTable(String tableName) throws IOException, TableNotFoundExcep
         requestData.put("table_name", tableName);
         String jsonData = JSON.toJSONString(requestData);
         request.setData(jsonData);
-        return execute(tableClient, request);
+        try {
+            return execute(tableClient, request);
+        } catch (IOException e) {
+            Throwable cause = e.getCause();
+            if (cause instanceof ObTableException) {
+                ObTableException obEx = (ObTableException) cause;
+                int errCode = obEx.getErrorCode();
+                if(ResultCodes.OB_KV_TABLE_NOT_ENABLED.errorCode == errCode) {
+                    throw new TableNotEnabledException("Table is not enabled: " + tableName + obEx);
+                } else if (ResultCodes.OB_TABLEGROUP_NOT_EXIST.errorCode == errCode) {
+                    throw new TableNotFoundException("Table not found: " + tableName + obEx);
+                }
+            }
+            throw e;
+        }
     }
 
     public Void disableTable(String tableName) throws IOException, TableNotFoundException, TableNotDisabledException {
@@ -50,6 +66,20 @@ public Void disableTable(String tableName) throws IOException, TableNotFoundExce
         requestData.put("table_name", tableName);
         String jsonData = JSON.toJSONString(requestData);
         request.setData(jsonData);
-        return execute(tableClient, request);
+        try {
+            return execute(tableClient, request);
+        } catch (IOException e) {
+            Throwable cause = e.getCause();
+            if (cause instanceof ObTableException) {
+                ObTableException obEx = (ObTableException) cause;
+                int errCode = obEx.getErrorCode();
+                if(ResultCodes.OB_KV_TABLE_NOT_DISABLED.errorCode == errCode) {
+                    throw new TableNotDisabledException("Table is not disabled: " + tableName + obEx);
+                } else if (ResultCodes.OB_TABLEGROUP_NOT_EXIST.errorCode == errCode) {
+                    throw new TableNotFoundException("Table not found: " + tableName + obEx);
+                }
+            }
+            throw e;
+        }
     }
 }

src/test/java/com/alipay/oceanbase/hbase/OHTableAdminInterfaceTest.java

@@ -355,7 +355,7 @@ public void testAdminEnDisableTable() throws Exception {
         // enable an enabled table
         thrown = assertThrows(IOException.class,
                 () -> {
-                    admin.disableTable(TableName.valueOf("n1", "test");
+                    admin.disableTable(TableName.valueOf("n1", "test"));
                 });
         assertTrue(thrown.getCause() instanceof ObTableException);
         Assert.assertEquals(ResultCodes.OB_KV_TABLE_NOT_ENABLED.errorCode, ((ObTableException) thrown.getCause()).getErrorCode());