From c639590744fc7bb99bcf1b2620a207ac2e4cf637 Mon Sep 17 00:00:00 2001
From: Jane <272005125@qq.com>
Date: Tue, 26 Dec 2023 09:28:45 +0800
Subject: [PATCH] update

---
 .../data/metadata/service/impl/MetadataSourceServiceImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/studio/modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/service/impl/MetadataSourceServiceImpl.java b/studio/modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/service/impl/MetadataSourceServiceImpl.java
index a955192..2f8c7ff 100644
--- a/studio/modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/service/impl/MetadataSourceServiceImpl.java
+++ b/studio/modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/service/impl/MetadataSourceServiceImpl.java
@@ -400,7 +400,7 @@ public class MetadataSourceServiceImpl extends BaseServiceImpl<MetadataSourceDao
 			DbQuery dbQuery = this.getDbQuery(datasourceId);
 			Connection connection = dbQuery.getConnection();
 			Statement statement = connection.createStatement();
-			String sql = "SELECT TABLE_NAME,COLUMN_NAME,CONSTRAINT_NAME,REFERENCED_TABLE_NAME,REFERENCED_COLUMN_NAME FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE WHERE TABLE_SCHEMA = '" + dataSource.getSourceName() + "' AND REFERENCED_TABLE_NAME IS NOT NULL";
+			String sql = "SELECT TABLE_NAME,COLUMN_NAME,CONSTRAINT_NAME,REFERENCED_TABLE_NAME,REFERENCED_COLUMN_NAME FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE WHERE TABLE_SCHEMA = '" + dataSource.getDbSchema().getDbName() + "' AND REFERENCED_TABLE_NAME IS NOT NULL";
 			if(StrUtil.isNotEmpty(tableId)){
 				MetadataTableEntity metadataTableEntity = metadataTableService.getMetadataTableById(tableId);
 				sql += " AND table_name = '" + metadataTableEntity.getTableName() + "'";