From 5545fa9f1bcc45dcff5ff20f3c75a3cac3a8b3a7 Mon Sep 17 00:00:00 2001
From: Yi Wang <connorwang@live.com>
Date: Thu, 24 Jul 2025 11:22:01 +0800
Subject: [PATCH] Fix createSchema to properly handle ignoreIfExists parameter

---
 src/main/java/org/apache/paimon/trino/TrinoMetadata.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/apache/paimon/trino/TrinoMetadata.java b/src/main/java/org/apache/paimon/trino/TrinoMetadata.java
index 8fac45c..7773999 100644
--- a/src/main/java/org/apache/paimon/trino/TrinoMetadata.java
+++ b/src/main/java/org/apache/paimon/trino/TrinoMetadata.java
@@ -305,7 +305,7 @@ public void createSchema(
 
         try {
             catalog.initSession(session);
-            catalog.createDatabase(schemaName, true);
+            catalog.createDatabase(schemaName, false);
         } catch (Catalog.DatabaseAlreadyExistException e) {
             throw new RuntimeException(format("database already existed: '%s'", schemaName));
         }