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 3ffa47d2ea68..862785fc3eb8 100644 --- a/core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java +++ b/core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java @@ -135,7 +135,7 @@ final class JdbcUtil { + CATALOG_NAME + " = ? AND " + TABLE_NAMESPACE - + " LIKE ? LIMIT 1"; + + " = ? LIMIT 1"; static final String LIST_NAMESPACES_SQL = "SELECT DISTINCT " + TABLE_NAMESPACE @@ -205,7 +205,7 @@ final class JdbcUtil { + CATALOG_NAME + " = ? AND " + NAMESPACE_NAME - + " LIKE ? LIMIT 1"; + + " = ? LIMIT 1"; static final String INSERT_NAMESPACE_PROPERTIES_SQL = "INSERT INTO " + NAMESPACE_PROPERTIES_TABLE_NAME diff --git a/core/src/test/java/org/apache/iceberg/jdbc/TestJdbcCatalog.java b/core/src/test/java/org/apache/iceberg/jdbc/TestJdbcCatalog.java index 59a701cb54d9..f71d928b273d 100644 --- a/core/src/test/java/org/apache/iceberg/jdbc/TestJdbcCatalog.java +++ b/core/src/test/java/org/apache/iceberg/jdbc/TestJdbcCatalog.java @@ -576,6 +576,13 @@ public void testNamespaceExists() { assertThat(catalog.namespaceExists(Namespace.of("db", "db2", "not_exist"))) .as("Should false to namespace doesn't exist") .isFalse(); + + Lists.newArrayList(TableIdentifier.of("ns", "t1"), TableIdentifier.of("ns_1", "t1")) + .forEach(t -> catalog.createTable(t, SCHEMA, PartitionSpec.unpartitioned())); + catalog.dropTable(TableIdentifier.of("ns", "t1")); + catalog.dropNamespace(Namespace.of("ns")); + assertThat(catalog.namespaceExists(Namespace.of("ns"))).isFalse(); + assertThat(catalog.namespaceExists(Namespace.of("ns_1"))).isTrue(); } @Test