From b68e55070e0382689d8d654240aabe7b3f91c864 Mon Sep 17 00:00:00 2001
From: davidfrigolet <dfrigolet@gmail.com>
Date: Wed, 15 Apr 2026 15:49:34 +0100
Subject: [PATCH] fix: SqlLockDialectHelper for H2

---
 .../sql/dialectHelpers/SqlLockDialectHelper.java     | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/flamingock-sql-util/src/main/java/io/flamingock/internal/common/sql/dialectHelpers/SqlLockDialectHelper.java b/flamingock-sql-util/src/main/java/io/flamingock/internal/common/sql/dialectHelpers/SqlLockDialectHelper.java
index 1cca74f..222ebc2 100644
--- a/flamingock-sql-util/src/main/java/io/flamingock/internal/common/sql/dialectHelpers/SqlLockDialectHelper.java
+++ b/flamingock-sql-util/src/main/java/io/flamingock/internal/common/sql/dialectHelpers/SqlLockDialectHelper.java
@@ -51,7 +51,6 @@ public String getCreateTableSqlString(String tableName) {
             case MYSQL:
             case MARIADB:
             case SQLITE:
-            case H2:
                 return String.format(
                         "CREATE TABLE IF NOT EXISTS %s (" +
                                 "`key` VARCHAR(255) PRIMARY KEY," +
@@ -59,6 +58,14 @@ public String getCreateTableSqlString(String tableName) {
                                 "owner VARCHAR(255)," +
                                 "expires_at TIMESTAMP" +
                                 ")", tableName);
+            case H2:
+                return String.format(
+                        "CREATE TABLE IF NOT EXISTS %s (" +
+                                "\"key\" VARCHAR(255) PRIMARY KEY," +
+                                "status VARCHAR(32)," +
+                                "owner VARCHAR(255)," +
+                                "expires_at TIMESTAMP" +
+                                ")", tableName);
             case SQLSERVER:
                 return String.format(
                         "IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='%s' AND xtype='U') " +
@@ -240,6 +247,7 @@ public String getDeleteLockSqlString(String tableName) {
         switch (sqlDialect) {
             case POSTGRESQL:
             case ORACLE:
+            case H2:
                 return String.format("DELETE FROM %s WHERE \"key\" = ?", tableName);
             case INFORMIX:
             case DB2:
@@ -248,7 +256,7 @@ public String getDeleteLockSqlString(String tableName) {
                 return String.format("DELETE FROM %s WHERE lock_key = ?", tableName);
             case SQLSERVER:
                 return String.format("DELETE FROM %s WHERE [key] = ?", tableName);
-            default: // MYSQL, MARIADB, SQLITE, H2
+            default: // MYSQL, MARIADB, SQLITE
                 return String.format("DELETE FROM %s WHERE `key` = ?", tableName);
         }
     }