commit 5d73e6b5042a021df05a2ac0e091441df22a4612
author JB Onofré <jbonofre@apache.org> Wed Apr 17 23:37:56 2024 +0200
committer GitHub <noreply@github.com> Wed Apr 17 15:37:56 2024 -0600
tree 46a4d0d141f623749bf741bd450f842e04b462d2
parent c45c9f63aba2b02b16bf6f4f9f39ed305a0a61b6

Core: Fix namespace SQL statement using ESCAPE character that works with MySQL/PostgreSQL (#10167) (#10169)

Co-authored-by: Chauncy <xuchuanqiu@gmail.com>

core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java

diff --git a/core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java b/core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java
index 8f918b4..ffa606a 100644
--- a/core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java
+++ b/core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java
@@ -335,7 +335,7 @@
           + TABLE_NAMESPACE
           + " = ? OR "
           + TABLE_NAMESPACE
-          + " LIKE ? ESCAPE '\\')"
+          + " LIKE ? ESCAPE '!')"
           + " LIMIT 1";
   static final String LIST_NAMESPACES_SQL =
       "SELECT DISTINCT "
@@ -426,7 +426,7 @@
           + NAMESPACE_NAME
           + " = ? OR "
           + NAMESPACE_NAME
-          + " LIKE ? ESCAPE '\\' "
+          + " LIKE ? ESCAPE '!' "
           + " ) ";
   static final String INSERT_NAMESPACE_PROPERTIES_SQL =
       "INSERT INTO "
@@ -783,7 +783,7 @@
     // when namespace has sub-namespace then additionally checking it with LIKE statement.
     // catalog.db can exists as: catalog.db.ns1 or catalog.db.ns1.ns2
     String namespaceStartsWith =
-        namespaceEquals.replace("\\", "\\\\").replace("_", "\\_").replace("%", "\\%") + ".%";
+        namespaceEquals.replace("!", "!!").replace("_", "!_").replace("%", "!%") + ".%";
     if (exists(connections, GET_NAMESPACE_SQL, catalogName, namespaceEquals, namespaceStartsWith)) {
       return true;
     }