From 0e31028f60d4c10acc003fd446ad45c394d54b6e Mon Sep 17 00:00:00 2001 From: hailin0 Date: Fri, 5 Jan 2024 16:34:29 +0800 Subject: [PATCH] [Hotfix][Jdbc] Fix dameng catalog query table sql --- .../connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java index 219067b68fa..d0114f60770 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java @@ -61,8 +61,8 @@ public class DamengCatalog extends AbstractJdbcCatalog { + "ON COLUMNS.OWNER = COMMENTS.SCHEMA_NAME " + "AND COLUMNS.TABLE_NAME = COMMENTS.TABLE_NAME " + "AND COLUMNS.COLUMN_NAME = COMMENTS.COLUMN_NAME " - + "WHERE COLUMNS.OWNER = ? " - + "AND COLUMNS.TABLE_NAME = ? " + + "WHERE COLUMNS.OWNER = '%s' " + + "AND COLUMNS.TABLE_NAME = '%s' " + "ORDER BY COLUMNS.COLUMN_ID ASC"; public DamengCatalog(