Skip to content

Commit 413fa74

Browse files
authored
[Hotfix][Jdbc] Fix dameng catalog query table sql (apache#6141)
1 parent 543d2c5 commit 413fa74

File tree

1 file changed

+2
-2
lines changed
  • seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm

1 file changed

+2
-2
lines changed

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,8 @@ public class DamengCatalog extends AbstractJdbcCatalog {
6161
+ "ON COLUMNS.OWNER = COMMENTS.SCHEMA_NAME "
6262
+ "AND COLUMNS.TABLE_NAME = COMMENTS.TABLE_NAME "
6363
+ "AND COLUMNS.COLUMN_NAME = COMMENTS.COLUMN_NAME "
64-
+ "WHERE COLUMNS.OWNER = ? "
65-
+ "AND COLUMNS.TABLE_NAME = ? "
64+
+ "WHERE COLUMNS.OWNER = '%s' "
65+
+ "AND COLUMNS.TABLE_NAME = '%s' "
6666
+ "ORDER BY COLUMNS.COLUMN_ID ASC";
6767

6868
public DamengCatalog(

0 commit comments

Comments
 (0)