diff --git a/backend-node/src/services/dataflowService.ts b/backend-node/src/services/dataflowService.ts index a7e45747..3c167e48 100644 --- a/backend-node/src/services/dataflowService.ts +++ b/backend-node/src/services/dataflowService.ts @@ -56,63 +56,27 @@ export class DataflowService { ); } - // 트랜잭션으로 관계 생성과 단순 키값 연결 처리 - const result = await prisma.$transaction(async (tx) => { - // 1. 새 관계 생성 - const relationship = await tx.table_relationships.create({ - data: { - relationship_name: data.relationshipName, - from_table_name: data.fromTableName, - from_column_name: data.fromColumnName, - to_table_name: data.toTableName, - to_column_name: data.toColumnName, - relationship_type: data.relationshipType, - connection_type: data.connectionType, - company_code: data.companyCode, - settings: data.settings, - created_by: data.createdBy, - updated_by: data.createdBy, - }, - }); - - // 2. 단순 키값 연결인 경우 data_relationship_bridge에도 기본 레코드 생성 - if (data.connectionType === "simple-key") { - logger.info( - `단순 키값 연결이므로 data_relationship_bridge에 기본 연결 레코드 생성 - 관계ID: ${relationship.relationship_id}` - ); - - await tx.data_relationship_bridge.create({ - data: { - relationship_id: relationship.relationship_id, - from_table_name: data.fromTableName, - from_column_name: data.fromColumnName, - to_table_name: data.toTableName, - to_column_name: data.toColumnName, - connection_type: data.connectionType, - company_code: data.companyCode, - bridge_data: { - autoCreated: true, - createdAt: new Date().toISOString(), - notes: "단순 키값 연결 - 테이블과 컬럼 관계만 정의", - connectionInfo: `${data.fromTableName}.${data.fromColumnName} ↔ ${data.toTableName}.${data.toColumnName}`, - settings: data.settings, - }, - created_by: data.createdBy, - }, - }); - - logger.info( - `단순 키값 연결 기본 레코드 생성 완료 - 관계ID: ${relationship.relationship_id}` - ); - } - - return relationship; + // 새 관계 생성 (중계 테이블은 별도로 생성하지 않음) + const relationship = await prisma.table_relationships.create({ + data: { + relationship_name: data.relationshipName, + from_table_name: data.fromTableName, + from_column_name: data.fromColumnName, + to_table_name: data.toTableName, + to_column_name: data.toColumnName, + relationship_type: data.relationshipType, + connection_type: data.connectionType, + company_code: data.companyCode, + settings: data.settings, + created_by: data.createdBy, + updated_by: data.createdBy, + }, }); logger.info( - `DataflowService: 테이블 관계 생성 완료 - ID: ${result.relationship_id}` + `DataflowService: 테이블 관계 생성 완료 - ID: ${relationship.relationship_id}` ); - return result; + return relationship; } catch (error) { logger.error("DataflowService: 테이블 관계 생성 실패", error); throw error; diff --git a/frontend/components/dataflow/ConnectionSetupModal.tsx b/frontend/components/dataflow/ConnectionSetupModal.tsx index 79c4553b..b23f7f4f 100644 --- a/frontend/components/dataflow/ConnectionSetupModal.tsx +++ b/frontend/components/dataflow/ConnectionSetupModal.tsx @@ -248,12 +248,6 @@ export const ConnectionSetupModal: React.FC = ({ className="text-sm" /> -
-
🔄 통합 중계 테이블 사용
-
- 모든 데이터 연결은 data_relationship_bridge 테이블에서 통합 관리됩니다. -
-
);