(paimon-trino) branch main updated: Implement schemaExists in TrinoMetadata

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/paimon-trino.git


The following commit(s) were added to refs/heads/main by this push:
     new 0796b9b  Implement schemaExists in TrinoMetadata
0796b9b is described below

commit 0796b9b63d54b4e3c6d92054eb6df0ec31e72422
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Mon Apr 22 19:48:27 2024 +0800

    Implement schemaExists in TrinoMetadata
---
 .../src/main/java/org/apache/paimon/trino/TrinoMetadata.java        | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoMetadata.java 
b/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoMetadata.java
index 1e310f4..0d8510e 100644
--- 
a/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoMetadata.java
+++ 
b/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoMetadata.java
@@ -85,6 +85,12 @@ public class TrinoMetadata implements ConnectorMetadata {
         return catalog;
     }
 
+    @Override
+    public boolean schemaExists(ConnectorSession session, String schemaName) {
+        catalog.initSession(session);
+        return catalog.databaseExists(schemaName);
+    }
+
     @Override
     public List<String> listSchemaNames(ConnectorSession session) {
         catalog.initSession(session);