From 3c9e9fc2464b247981b9fbf9a26bc826c32f3014 Mon Sep 17 00:00:00 2001
From: JackShi148 <jackshi896@gmail.com>
Date: Fri, 13 Jun 2025 17:53:47 +0800
Subject: [PATCH] fix namespace not exsit

---
 .../alipay/oceanbase/hbase/util/OHAdmin.java  | 27 ++++++++++++++++---
 1 file changed, 23 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/alipay/oceanbase/hbase/util/OHAdmin.java b/src/main/java/com/alipay/oceanbase/hbase/util/OHAdmin.java
index 99f43267..5cb7d92c 100644
--- a/src/main/java/com/alipay/oceanbase/hbase/util/OHAdmin.java
+++ b/src/main/java/com/alipay/oceanbase/hbase/util/OHAdmin.java
@@ -3,8 +3,10 @@
 import com.alipay.oceanbase.rpc.ObTableClient;
 import com.alipay.oceanbase.rpc.bolt.transport.TransportCodes;
 import com.alipay.oceanbase.hbase.exception.FeatureNotSupportedException;
+import com.alipay.oceanbase.rpc.exception.ObTableException;
 import com.alipay.oceanbase.rpc.exception.ObTableTransportException;
 import com.alipay.oceanbase.rpc.meta.ObTableRpcMetaType;
+import com.alipay.oceanbase.rpc.protocol.payload.ResultCodes;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.hbase.*;
 import org.apache.hadoop.hbase.client.*;
@@ -63,10 +65,27 @@ public Connection getConnection() {
 
     @Override
     public boolean tableExists(TableName tableName) throws IOException {
-        OHConnectionConfiguration connectionConf = new OHConnectionConfiguration(conf);
-        ObTableClient tableClient = ObTableClientManager.getOrCreateObTableClientByTableName(tableName, connectionConf);
-        OHTableExistsExecutor executor = new OHTableExistsExecutor(tableClient);
-        return executor.tableExists(tableName.getNameAsString());
+        try {
+            OHConnectionConfiguration connectionConf = new OHConnectionConfiguration(conf);
+            ObTableClient tableClient = ObTableClientManager.getOrCreateObTableClientByTableName(tableName, connectionConf);
+            OHTableExistsExecutor executor = new OHTableExistsExecutor(tableClient);
+            return executor.tableExists(tableName.getNameAsString());
+        } catch (Exception e) {
+            // try to get the original cause
+            Throwable cause = e.getCause();
+            while(cause != null && cause.getCause() != null) {
+                cause = cause.getCause();
+            }
+            if (cause instanceof ObTableException) {
+                int errCode = ((ObTableException) cause).getErrorCode();
+                // if the original cause is database_not_exist, means namespace in tableName does not exist
+                // for HBase, namespace not exist will not throw exceptions but will return false
+                if (errCode == ResultCodes.OB_ERR_BAD_DATABASE.errorCode) {
+                    return false;
+                }
+            }
+            throw e;
+        }
     }
 
     @Override