fix (sql compatibility): use sys_context to query tenant name on orac…

…le mode (#58)
oceanbase · Mar 12, 2024 · 27b0dab · 27b0dab
1 parent b1eaac1
commit 27b0dab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...oceanbase/src/main/java/com/oceanbase/connector/flink/dialect/OceanBaseOracleDialect.java b/...oceanbase/src/main/java/com/oceanbase/connector/flink/dialect/OceanBaseOracleDialect.java
@@ -86,6 +86,6 @@ public String getSysDatabase() {
 
  @Override
  public String getQueryTenantNameStatement() {
- return "SELECT TENANT_NAME FROM SYS.DBA_OB_TENANTS";
+ return "SELECT SYS_CONTEXT('USERENV', 'CON_NAME') FROM DUAL";
  }
 }