중계테이블 생성 로직 삭제
This commit is contained in:
@@ -56,63 +56,27 @@ export class DataflowService {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
// 트랜잭션으로 관계 생성과 단순 키값 연결 처리
|
// 새 관계 생성 (중계 테이블은 별도로 생성하지 않음)
|
||||||
const result = await prisma.$transaction(async (tx) => {
|
const relationship = await prisma.table_relationships.create({
|
||||||
// 1. 새 관계 생성
|
data: {
|
||||||
const relationship = await tx.table_relationships.create({
|
relationship_name: data.relationshipName,
|
||||||
data: {
|
from_table_name: data.fromTableName,
|
||||||
relationship_name: data.relationshipName,
|
from_column_name: data.fromColumnName,
|
||||||
from_table_name: data.fromTableName,
|
to_table_name: data.toTableName,
|
||||||
from_column_name: data.fromColumnName,
|
to_column_name: data.toColumnName,
|
||||||
to_table_name: data.toTableName,
|
relationship_type: data.relationshipType,
|
||||||
to_column_name: data.toColumnName,
|
connection_type: data.connectionType,
|
||||||
relationship_type: data.relationshipType,
|
company_code: data.companyCode,
|
||||||
connection_type: data.connectionType,
|
settings: data.settings,
|
||||||
company_code: data.companyCode,
|
created_by: data.createdBy,
|
||||||
settings: data.settings,
|
updated_by: data.createdBy,
|
||||||
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;
|
|
||||||
});
|
});
|
||||||
|
|
||||||
logger.info(
|
logger.info(
|
||||||
`DataflowService: 테이블 관계 생성 완료 - ID: ${result.relationship_id}`
|
`DataflowService: 테이블 관계 생성 완료 - ID: ${relationship.relationship_id}`
|
||||||
);
|
);
|
||||||
return result;
|
return relationship;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
logger.error("DataflowService: 테이블 관계 생성 실패", error);
|
logger.error("DataflowService: 테이블 관계 생성 실패", error);
|
||||||
throw error;
|
throw error;
|
||||||
|
|||||||
@@ -248,12 +248,6 @@ export const ConnectionSetupModal: React.FC<ConnectionSetupModalProps> = ({
|
|||||||
className="text-sm"
|
className="text-sm"
|
||||||
/>
|
/>
|
||||||
</div>
|
</div>
|
||||||
<div className="rounded-lg bg-blue-50 p-3 text-xs text-blue-700">
|
|
||||||
<div className="mb-1 font-medium">🔄 통합 중계 테이블 사용</div>
|
|
||||||
<div>
|
|
||||||
모든 데이터 연결은 <code>data_relationship_bridge</code> 테이블에서 통합 관리됩니다.
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
|
|||||||
Reference in New Issue
Block a user