From f83d0c7b74ca9668bab64481dbace20b729c77c2 Mon Sep 17 00:00:00 2001 From: Amogh Shetkar Date: Fri, 18 Jul 2025 09:56:42 +0000 Subject: [PATCH] Use lowercase tablename for the SELECT query to correctly fetch its columns --- .../database/postgresql/yugabytedb/YugabyteDBDatabase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBDatabase.java b/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBDatabase.java index ce1cc3d..663871e 100644 --- a/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBDatabase.java +++ b/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBDatabase.java @@ -37,7 +37,8 @@ public class YugabyteDBDatabase extends PostgreSQLDatabase { public static final String LOCK_TABLE_NAME = "YB_FLYWAY_LOCK_TABLE"; - private static final String LOCK_TABLE_SCHEMA_SQL = "SELECT table_name, column_name FROM information_schema.columns WHERE table_name = '" + LOCK_TABLE_NAME + "'"; + // Using table name in lower case, see https://github.com/flyway/flyway-community-db-support/issues/97 + private static final String LOCK_TABLE_SCHEMA_SQL = "SELECT table_name, column_name FROM information_schema.columns WHERE table_name = '" + LOCK_TABLE_NAME.toLowerCase() + "'"; private static final String DROP_LOCK_TABLE_IF_EXISTS_DDL = "DROP TABLE IF EXISTS " + LOCK_TABLE_NAME; /** * This table is used to enforce locking through SELECT ... FOR UPDATE on a