0000765: Added catalog to information_schema.columns query

JumpMind · Sep 26, 2022 · 88a1553 · 88a1553
1 parent 7b50983
commit 88a1553
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mysql/MySqlDdlReader.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mysql/MySqlDdlReader.java
@@ -149,9 +149,11 @@ protected Column readColumn(DatabaseMetaDataWrapper metaData, Map<String, Object
             JdbcSqlTemplate sqlTemplate = (JdbcSqlTemplate) platform.getSqlTemplateDirty();
             String sql = "SELECT extra, generation_expression\n"
                     + "FROM information_schema.columns\n"
-                    + "WHERE table_name = ?\n"
+                    + "WHERE table_schema = ?\n"
+                    + "AND table_name = ?\n"
                     + "AND column_name = ?";
             List<String> l = new ArrayList<String>();
+            l.add((String) values.get("TABLE_CAT"));
             l.add((String) values.get("TABLE_NAME"));
             l.add(column.getName());
             Row result = sqlTemplate.queryForRow(sql, l.toArray());