From 0257254036ee80fe905c0680fbd33cf127f00713 Mon Sep 17 00:00:00 2001 From: kjs Date: Mon, 22 Sep 2025 18:24:00 +0900 Subject: [PATCH 1/4] Fix: Restore multilangController.ts with all required exports - Revert to dev branch version to fix TypeScript compilation errors - Main branch version was missing required export functions - Routes depend on these exported functions for proper API functionality --- .../src/controllers/multilangController.ts | 921 +++++++++++++----- 1 file changed, 654 insertions(+), 267 deletions(-) diff --git a/backend-node/src/controllers/multilangController.ts b/backend-node/src/controllers/multilangController.ts index 25cfb1b3..14155f86 100644 --- a/backend-node/src/controllers/multilangController.ts +++ b/backend-node/src/controllers/multilangController.ts @@ -1,202 +1,496 @@ -import { Response } from "express"; -import { AuthenticatedRequest } from "../types/auth"; +import { Request, Response } from "express"; import { logger } from "../utils/logger"; -import prisma from "../config/database"; - -// 메모리 캐시 (개발 환경용, 운영에서는 Redis 사용 권장) -const translationCache = new Map(); -const CACHE_TTL = 5 * 60 * 1000; // 5분 - -interface CacheEntry { - data: any; - timestamp: number; -} +import { AuthenticatedRequest } from "../types/auth"; +import { MultiLangService } from "../services/multilangService"; +import { + CreateLanguageRequest, + UpdateLanguageRequest, + CreateLangKeyRequest, + UpdateLangKeyRequest, + SaveLangTextsRequest, + GetUserTextParams, + BatchTranslationRequest, + ApiResponse, +} from "../types/multilang"; /** - * GET /api/multilang/batch - * 다국어 텍스트 배치 조회 API - 여러 키를 한번에 조회 + * GET /api/multilang/languages + * 언어 목록 조회 API */ -export const getBatchTranslations = async ( +export const getLanguages = async ( req: AuthenticatedRequest, res: Response ): Promise => { try { - const { companyCode, menuCode, userLang } = req.query; - const { langKeys } = req.body; // 배열로 여러 키 전달 + logger.info("언어 목록 조회 요청", { user: req.user }); - logger.info("다국어 텍스트 배치 조회 요청", { - companyCode, - menuCode, - userLang, - keyCount: langKeys?.length || 0, + const multiLangService = new MultiLangService(); + const languages = await multiLangService.getLanguages(); + + const response: ApiResponse = { + success: true, + message: "언어 목록 조회 성공", + data: languages, + }; + + res.status(200).json(response); + } catch (error) { + logger.error("언어 목록 조회 실패:", error); + res.status(500).json({ + success: false, + message: "언어 목록 조회 중 오류가 발생했습니다.", + error: { + code: "LANGUAGE_LIST_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * POST /api/multilang/languages + * 언어 생성 API + */ +export const createLanguage = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const languageData: CreateLanguageRequest = req.body; + logger.info("언어 생성 요청", { languageData, user: req.user }); + + // 필수 입력값 검증 + if ( + !languageData.langCode || + !languageData.langName || + !languageData.langNative + ) { + res.status(400).json({ + success: false, + message: "언어 코드, 언어명, 원어명은 필수입니다.", + error: { + code: "MISSING_REQUIRED_FIELDS", + details: "langCode, langName, langNative are required", + }, + }); + return; + } + + const multiLangService = new MultiLangService(); + const createdLanguage = await multiLangService.createLanguage({ + ...languageData, + createdBy: req.user?.userId || "system", + updatedBy: req.user?.userId || "system", + }); + + const response: ApiResponse = { + success: true, + message: "언어가 성공적으로 생성되었습니다.", + data: createdLanguage, + }; + + res.status(201).json(response); + } catch (error) { + logger.error("언어 생성 실패:", error); + res.status(500).json({ + success: false, + message: "언어 생성 중 오류가 발생했습니다.", + error: { + code: "LANGUAGE_CREATE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * PUT /api/multilang/languages/:langCode + * 언어 수정 API + */ +export const updateLanguage = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { langCode } = req.params; + const languageData: UpdateLanguageRequest = req.body; + + logger.info("언어 수정 요청", { langCode, languageData, user: req.user }); + + const multiLangService = new MultiLangService(); + const updatedLanguage = await multiLangService.updateLanguage(langCode, { + ...languageData, + updatedBy: req.user?.userId || "system", + }); + + const response: ApiResponse = { + success: true, + message: "언어가 성공적으로 수정되었습니다.", + data: updatedLanguage, + }; + + res.status(200).json(response); + } catch (error) { + logger.error("언어 수정 실패:", error); + res.status(500).json({ + success: false, + message: "언어 수정 중 오류가 발생했습니다.", + error: { + code: "LANGUAGE_UPDATE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * PUT /api/multilang/languages/:langCode/toggle + * 언어 상태 토글 API + */ +export const toggleLanguage = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { langCode } = req.params; + logger.info("언어 상태 토글 요청", { langCode, user: req.user }); + + const multiLangService = new MultiLangService(); + const result = await multiLangService.toggleLanguage(langCode); + + const response: ApiResponse = { + success: true, + message: `언어가 ${result}되었습니다.`, + data: result, + }; + + res.status(200).json(response); + } catch (error) { + logger.error("언어 상태 토글 실패:", error); + res.status(500).json({ + success: false, + message: "언어 상태 변경 중 오류가 발생했습니다.", + error: { + code: "LANGUAGE_TOGGLE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * GET /api/multilang/keys + * 다국어 키 목록 조회 API + */ +export const getLangKeys = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { companyCode, menuCode, keyType, searchText } = req.query; + logger.info("다국어 키 목록 조회 요청", { + query: req.query, user: req.user, }); - if (!langKeys || !Array.isArray(langKeys) || langKeys.length === 0) { - res.status(400).json({ - success: false, - message: "langKeys 배열이 필요합니다.", - }); - return; - } - - // 캐시 키 생성 - const cacheKey = `${companyCode}_${userLang}_${langKeys.sort().join("_")}`; - - // 캐시 확인 - const cached = translationCache.get(cacheKey); - if (cached && Date.now() - cached.timestamp < CACHE_TTL) { - logger.info("캐시된 번역 데이터 사용", { - cacheKey, - keyCount: langKeys.length, - }); - res.status(200).json({ - success: true, - data: cached.data, - message: "캐시된 다국어 텍스트 조회 성공", - fromCache: true, - }); - return; - } - - // 1. 모든 키에 대한 마스터 정보를 한번에 조회 - logger.info("다국어 키 마스터 배치 조회 시작", { - keyCount: langKeys.length, + const multiLangService = new MultiLangService(); + const langKeys = await multiLangService.getLangKeys({ + companyCode: companyCode as string, + menuCode: menuCode as string, + keyType: keyType as string, + searchText: searchText as string, }); - const langKeyMasters = await prisma.$queryRaw` - SELECT key_id, lang_key, company_code - FROM multi_lang_key_master - WHERE lang_key = ANY(${langKeys}::varchar[]) - AND (company_code = ${companyCode}::varchar OR company_code = '*') - ORDER BY - CASE WHEN company_code = ${companyCode}::varchar THEN 1 ELSE 2 END, - lang_key, - company_code - `; - - logger.info("다국어 키 마스터 배치 조회 결과", { - requestedKeys: langKeys.length, - foundKeys: langKeyMasters.length, - }); - - if (langKeyMasters.length === 0) { - // 마스터 데이터가 없으면 기본값 반환 - const defaultTranslations = getDefaultTranslations( - langKeys, - userLang as string - ); - - // 캐시에 저장 - translationCache.set(cacheKey, { - data: defaultTranslations, - timestamp: Date.now(), - }); - - res.status(200).json({ - success: true, - data: defaultTranslations, - message: "기본값으로 다국어 텍스트 조회 성공", - fromCache: false, - }); - return; - } - - // 2. 모든 key_id를 추출 - const keyIds = langKeyMasters.map((master: any) => master.key_id); - - // 3. 요청된 언어와 한국어 번역을 한번에 조회 - const translations = await prisma.$queryRaw` - SELECT - mlt.key_id, - mlt.lang_code, - mlt.lang_text, - mlkm.lang_key - FROM multi_lang_text mlt - JOIN multi_lang_key_master mlkm ON mlt.key_id = mlkm.key_id - WHERE mlt.key_id = ANY(${keyIds}::numeric[]) - AND mlt.lang_code IN (${userLang}::varchar, 'KR') - ORDER BY - mlt.key_id, - CASE WHEN mlt.lang_code = ${userLang}::varchar THEN 1 ELSE 2 END - `; - - logger.info("번역 텍스트 배치 조회 결과", { - keyIds: keyIds.length, - translations: translations.length, - }); - - // 4. 결과를 키별로 정리 - const result: Record = {}; - - for (const langKey of langKeys) { - const master = langKeyMasters.find((m) => m.lang_key === langKey); - - if (master) { - const keyId = master.key_id; - - // 요청된 언어 번역 찾기 - let translation = translations.find( - (t) => t.key_id === keyId && t.lang_code === userLang - ); - - // 요청된 언어가 없으면 한국어 번역 찾기 - if (!translation) { - translation = translations.find( - (t) => t.key_id === keyId && t.lang_code === "KR" - ); - } - - // 번역이 있으면 사용, 없으면 기본값 - if (translation) { - result[langKey] = translation.lang_text; - } else { - result[langKey] = getDefaultTranslation(langKey, userLang as string); - } - } else { - // 마스터 데이터가 없으면 기본값 - result[langKey] = getDefaultTranslation(langKey, userLang as string); - } - } - - // 5. 캐시에 저장 - translationCache.set(cacheKey, { - data: result, - timestamp: Date.now(), - }); - - logger.info("다국어 텍스트 배치 조회 완료", { - requestedKeys: langKeys.length, - resultKeys: Object.keys(result).length, - cacheKey, - }); - - res.status(200).json({ + const response: ApiResponse = { success: true, - data: result, - message: "다국어 텍스트 배치 조회 성공", - fromCache: false, - }); + message: "다국어 키 목록 조회 성공", + data: langKeys, + }; + + res.status(200).json(response); } catch (error) { - logger.error("다국어 텍스트 배치 조회 실패", { error }); + logger.error("다국어 키 목록 조회 실패:", error); res.status(500).json({ success: false, - message: "다국어 텍스트 배치 조회 중 오류가 발생했습니다.", - error: error instanceof Error ? error.message : "Unknown error", + message: "다국어 키 목록 조회 중 오류가 발생했습니다.", + error: { + code: "LANG_KEYS_LIST_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * GET /api/multilang/keys/:keyId/texts + * 특정 키의 다국어 텍스트 조회 API + */ +export const getLangTexts = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { keyId } = req.params; + logger.info("다국어 텍스트 조회 요청", { keyId, user: req.user }); + + const multiLangService = new MultiLangService(); + const langTexts = await multiLangService.getLangTexts(parseInt(keyId)); + + const response: ApiResponse = { + success: true, + message: "다국어 텍스트 조회 성공", + data: langTexts, + }; + + res.status(200).json(response); + } catch (error) { + logger.error("다국어 텍스트 조회 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 텍스트 조회 중 오류가 발생했습니다.", + error: { + code: "LANG_TEXTS_LIST_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * POST /api/multilang/keys + * 다국어 키 생성 API + */ +export const createLangKey = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const keyData: CreateLangKeyRequest = req.body; + logger.info("다국어 키 생성 요청", { keyData, user: req.user }); + + // 필수 입력값 검증 + if (!keyData.companyCode || !keyData.langKey) { + res.status(400).json({ + success: false, + message: "회사 코드와 언어 키는 필수입니다.", + error: { + code: "MISSING_REQUIRED_FIELDS", + details: "companyCode and langKey are required", + }, + }); + return; + } + + const multiLangService = new MultiLangService(); + const keyId = await multiLangService.createLangKey({ + ...keyData, + createdBy: req.user?.userId || "system", + updatedBy: req.user?.userId || "system", + }); + + const response: ApiResponse = { + success: true, + message: "다국어 키가 성공적으로 생성되었습니다.", + data: keyId, + }; + + res.status(201).json(response); + } catch (error) { + logger.error("다국어 키 생성 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 키 생성 중 오류가 발생했습니다.", + error: { + code: "LANG_KEY_CREATE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * PUT /api/multilang/keys/:keyId + * 다국어 키 수정 API + */ +export const updateLangKey = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { keyId } = req.params; + const keyData: UpdateLangKeyRequest = req.body; + + logger.info("다국어 키 수정 요청", { keyId, keyData, user: req.user }); + + const multiLangService = new MultiLangService(); + await multiLangService.updateLangKey(parseInt(keyId), { + ...keyData, + updatedBy: req.user?.userId || "system", + }); + + const response: ApiResponse = { + success: true, + message: "다국어 키가 성공적으로 수정되었습니다.", + data: "수정 완료", + }; + + res.status(200).json(response); + } catch (error) { + logger.error("다국어 키 수정 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 키 수정 중 오류가 발생했습니다.", + error: { + code: "LANG_KEY_UPDATE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * DELETE /api/multilang/keys/:keyId + * 다국어 키 삭제 API + */ +export const deleteLangKey = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { keyId } = req.params; + logger.info("다국어 키 삭제 요청", { keyId, user: req.user }); + + const multiLangService = new MultiLangService(); + await multiLangService.deleteLangKey(parseInt(keyId)); + + const response: ApiResponse = { + success: true, + message: "다국어 키가 성공적으로 삭제되었습니다.", + data: "삭제 완료", + }; + + res.status(200).json(response); + } catch (error) { + logger.error("다국어 키 삭제 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 키 삭제 중 오류가 발생했습니다.", + error: { + code: "LANG_KEY_DELETE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * PUT /api/multilang/keys/:keyId/toggle + * 다국어 키 상태 토글 API + */ +export const toggleLangKey = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { keyId } = req.params; + logger.info("다국어 키 상태 토글 요청", { keyId, user: req.user }); + + const multiLangService = new MultiLangService(); + const result = await multiLangService.toggleLangKey(parseInt(keyId)); + + const response: ApiResponse = { + success: true, + message: `다국어 키가 ${result}되었습니다.`, + data: result, + }; + + res.status(200).json(response); + } catch (error) { + logger.error("다국어 키 상태 토글 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 키 상태 변경 중 오류가 발생했습니다.", + error: { + code: "LANG_KEY_TOGGLE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * POST /api/multilang/keys/:keyId/texts + * 다국어 텍스트 저장/수정 API + */ +export const saveLangTexts = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { keyId } = req.params; + const textData: SaveLangTextsRequest = req.body; + + logger.info("다국어 텍스트 저장 요청", { keyId, textData, user: req.user }); + + // 필수 입력값 검증 + if ( + !textData.texts || + !Array.isArray(textData.texts) || + textData.texts.length === 0 + ) { + res.status(400).json({ + success: false, + message: "텍스트 데이터는 필수입니다.", + error: { + code: "MISSING_REQUIRED_FIELDS", + details: "texts array is required", + }, + }); + return; + } + + const multiLangService = new MultiLangService(); + await multiLangService.saveLangTexts(parseInt(keyId), { + texts: textData.texts.map((text) => ({ + ...text, + createdBy: req.user?.userId || "system", + updatedBy: req.user?.userId || "system", + })), + }); + + const response: ApiResponse = { + success: true, + message: "다국어 텍스트가 성공적으로 저장되었습니다.", + data: "저장 완료", + }; + + res.status(200).json(response); + } catch (error) { + logger.error("다국어 텍스트 저장 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 텍스트 저장 중 오류가 발생했습니다.", + error: { + code: "LANG_TEXTS_SAVE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, }); } }; /** * GET /api/multilang/user-text/:companyCode/:menuCode/:langKey - * 단일 다국어 텍스트 조회 API (하위 호환성 유지) + * 사용자별 다국어 텍스트 조회 API */ -export const getUserText = async (req: AuthenticatedRequest, res: Response) => { +export const getUserText = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { try { const { companyCode, menuCode, langKey } = req.params; const { userLang } = req.query; - logger.info("단일 다국어 텍스트 조회 요청", { + logger.info("사용자별 다국어 텍스트 조회 요청", { companyCode, menuCode, langKey, @@ -204,122 +498,215 @@ export const getUserText = async (req: AuthenticatedRequest, res: Response) => { user: req.user, }); - // 배치 API를 사용하여 단일 키 조회 - const batchResult = await getBatchTranslations( - { - ...req, - body: { langKeys: [langKey] }, - query: { companyCode, menuCode, userLang }, - } as any, - res - ); + if (!userLang) { + res.status(400).json({ + success: false, + message: "사용자 언어는 필수입니다.", + error: { + code: "MISSING_USER_LANG", + details: "userLang query parameter is required", + }, + }); + return; + } - // 배치 API에서 이미 응답을 보냈으므로 여기서는 아무것도 하지 않음 - return; + const multiLangService = new MultiLangService(); + const langText = await multiLangService.getUserText({ + companyCode, + menuCode, + langKey, + userLang: userLang as string, + }); + + const response: ApiResponse = { + success: true, + message: "사용자별 다국어 텍스트 조회 성공", + data: langText, + }; + + res.status(200).json(response); } catch (error) { - logger.error("단일 다국어 텍스트 조회 실패", { error }); + logger.error("사용자별 다국어 텍스트 조회 실패:", error); res.status(500).json({ success: false, - message: "다국어 텍스트 조회 중 오류가 발생했습니다.", - error: error instanceof Error ? error.message : "Unknown error", + message: "사용자별 다국어 텍스트 조회 중 오류가 발생했습니다.", + error: { + code: "USER_TEXT_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, }); } }; /** - * 기본 번역 텍스트 반환 (개별 키) + * GET /api/multilang/text/:companyCode/:langKey/:langCode + * 특정 키의 다국어 텍스트 조회 API */ -function getDefaultTranslation(langKey: string, userLang: string): string { - const defaultKoreanTexts: Record = { - "button.add": "추가", - "button.add.top.level": "최상위 메뉴 추가", - "button.add.sub": "하위 메뉴 추가", - "button.edit": "수정", - "button.delete": "삭제", - "button.cancel": "취소", - "button.save": "저장", - "button.register": "등록", - "form.menu.name": "메뉴명", - "form.menu.url": "URL", - "form.menu.description": "설명", - "form.menu.type": "메뉴 타입", - "form.status": "상태", - "form.company": "회사", - "table.header.menu.name": "메뉴명", - "table.header.menu.url": "URL", - "table.header.status": "상태", - "table.header.company": "회사", - "table.header.actions": "작업", - "filter.company": "회사", - "filter.search": "검색", - "filter.reset": "초기화", - "menu.type.title": "메뉴 타입", - "menu.type.admin": "관리자", - "menu.type.user": "사용자", - "status.active": "활성화", - "status.inactive": "비활성화", - "form.lang.key": "언어 키", - "form.lang.key.select": "언어 키 선택", - "form.menu.name.placeholder": "메뉴명을 입력하세요", - "form.menu.url.placeholder": "URL을 입력하세요", - "form.menu.description.placeholder": "설명을 입력하세요", - "form.menu.sequence": "순서", - "form.menu.sequence.placeholder": "순서를 입력하세요", - "form.status.active": "활성", - "form.status.inactive": "비활성", - "form.company.select": "회사 선택", - "form.company.common": "공통", - "form.company.submenu.note": "하위메뉴는 회사별로 관리됩니다", - "filter.company.common": "공통", - "filter.search.placeholder": "검색어를 입력하세요", - "modal.menu.register.title": "메뉴 등록", - }; - - return defaultKoreanTexts[langKey] || langKey; -} - -/** - * 기본 번역 텍스트 반환 (배치) - */ -function getDefaultTranslations( - langKeys: string[], - userLang: string -): Record { - const result: Record = {}; - - for (const langKey of langKeys) { - result[langKey] = getDefaultTranslation(langKey, userLang); - } - - return result; -} - -/** - * 캐시 초기화 (개발/테스트용) - */ -export const clearCache = async (req: AuthenticatedRequest, res: Response) => { +export const getLangText = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { try { - const beforeSize = translationCache.size; - translationCache.clear(); + const { companyCode, langKey, langCode } = req.params; - logger.info("다국어 캐시 초기화 완료", { - beforeSize, - afterSize: 0, + logger.info("특정 키의 다국어 텍스트 조회 요청", { + companyCode, + langKey, + langCode, user: req.user, }); - res.status(200).json({ + const multiLangService = new MultiLangService(); + const langText = await multiLangService.getLangText( + companyCode, + langKey, + langCode + ); + + const response: ApiResponse = { success: true, - message: "캐시가 초기화되었습니다.", - beforeSize, - afterSize: 0, - }); + message: "특정 키의 다국어 텍스트 조회 성공", + data: langText, + }; + + res.status(200).json(response); } catch (error) { - logger.error("캐시 초기화 실패", { error }); + logger.error("특정 키의 다국어 텍스트 조회 실패:", error); res.status(500).json({ success: false, - message: "캐시 초기화 중 오류가 발생했습니다.", - error: error instanceof Error ? error.message : "Unknown error", + message: "특정 키의 다국어 텍스트 조회 중 오류가 발생했습니다.", + error: { + code: "LANG_TEXT_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * DELETE /api/multilang/languages/:langCode + * 언어 삭제 API + */ +export const deleteLanguage = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { langCode } = req.params; + logger.info("언어 삭제 요청", { langCode, user: req.user }); + + if (!langCode) { + res.status(400).json({ + success: false, + message: "언어 코드가 필요합니다.", + error: { + code: "MISSING_LANG_CODE", + details: "langCode parameter is required", + }, + }); + return; + } + + const multiLangService = new MultiLangService(); + await multiLangService.deleteLanguage(langCode); + + const response: ApiResponse = { + success: true, + message: "언어가 성공적으로 삭제되었습니다.", + data: "삭제 완료", + }; + + res.status(200).json(response); + } catch (error) { + logger.error("언어 삭제 실패:", error); + res.status(500).json({ + success: false, + message: "언어 삭제 중 오류가 발생했습니다.", + error: { + code: "LANGUAGE_DELETE_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, + }); + } +}; + +/** + * POST /api/multilang/batch + * 다국어 텍스트 배치 조회 API + */ +export const getBatchTranslations = async ( + req: Request, + res: Response +): Promise => { + try { + const { companyCode, menuCode, userLang } = req.query; + const { + langKeys, + companyCode: bodyCompanyCode, + menuCode: bodyMenuCode, + userLang: bodyUserLang, + } = req.body; + + // query params에서 읽지 못한 경우 body에서 읽기 + const finalCompanyCode = companyCode || bodyCompanyCode; + const finalMenuCode = menuCode || bodyMenuCode; + const finalUserLang = userLang || bodyUserLang; + + logger.info("다국어 텍스트 배치 조회 요청", { + companyCode: finalCompanyCode, + menuCode: finalMenuCode, + userLang: finalUserLang, + keyCount: langKeys?.length || 0, + }); + + if (!langKeys || !Array.isArray(langKeys) || langKeys.length === 0) { + res.status(400).json({ + success: false, + message: "langKeys 배열이 필요합니다.", + error: { + code: "MISSING_LANG_KEYS", + details: "langKeys array is required", + }, + }); + return; + } + + if (!finalCompanyCode || !finalUserLang) { + res.status(400).json({ + success: false, + message: "companyCode와 userLang은 필수입니다.", + error: { + code: "MISSING_REQUIRED_PARAMS", + details: "companyCode and userLang are required", + }, + }); + return; + } + + const multiLangService = new MultiLangService(); + const translations = await multiLangService.getBatchTranslations({ + companyCode: finalCompanyCode as string, + menuCode: finalMenuCode as string, + userLang: finalUserLang as string, + langKeys, + }); + + const response: ApiResponse> = { + success: true, + message: "다국어 텍스트 배치 조회 성공", + data: translations, + }; + + res.status(200).json(response); + } catch (error) { + logger.error("다국어 텍스트 배치 조회 실패:", error); + res.status(500).json({ + success: false, + message: "다국어 텍스트 배치 조회 중 오류가 발생했습니다.", + error: { + code: "BATCH_TRANSLATION_ERROR", + details: error instanceof Error ? error.message : "Unknown error", + }, }); } }; -- 2.43.0 From 37ded5a543b1568c845200a8d9eae1c648d288e0 Mon Sep 17 00:00:00 2001 From: kjs Date: Tue, 23 Sep 2025 09:27:15 +0900 Subject: [PATCH 2/4] Merge branch 'main' of http://39.117.244.52:3000/kjs/ERP-node -- 2.43.0 From f160a33b94d3281d2c2a6d02e232a98a7f7e656b Mon Sep 17 00:00:00 2001 From: leeheejin Date: Tue, 23 Sep 2025 10:45:53 +0900 Subject: [PATCH 3/4] =?UTF-8?q?=EC=8A=A4=ED=81=AC=EB=A1=A4=20=EA=B8=B0?= =?UTF-8?q?=EB=8A=A5=20=ED=8F=AC=ED=95=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend-node/package-lock.json | 126 +++++++++ backend-node/package.json | 1 + .../src/database/DatabaseConnectorFactory.ts | 52 ++++ backend-node/src/database/MySQLConnector.ts | 175 +++++++++++++ .../src/database/PostgreSQLConnector.ts | 145 +++++++++++ .../src/interfaces/DatabaseConnector.ts | 27 ++ .../src/services/dbConnectionManager.ts | 59 +++++ .../services/externalDbConnectionService.ts | 246 ++++-------------- frontend/components/admin/SqlQueryModal.tsx | 128 ++++----- 9 files changed, 703 insertions(+), 256 deletions(-) create mode 100644 backend-node/src/database/DatabaseConnectorFactory.ts create mode 100644 backend-node/src/database/MySQLConnector.ts create mode 100644 backend-node/src/database/PostgreSQLConnector.ts create mode 100644 backend-node/src/interfaces/DatabaseConnector.ts create mode 100644 backend-node/src/services/dbConnectionManager.ts diff --git a/backend-node/package-lock.json b/backend-node/package-lock.json index ee373fa8..06920113 100644 --- a/backend-node/package-lock.json +++ b/backend-node/package-lock.json @@ -21,6 +21,7 @@ "joi": "^17.11.0", "jsonwebtoken": "^9.0.2", "multer": "^1.4.5-lts.1", + "mysql2": "^3.15.0", "nodemailer": "^6.9.7", "pg": "^8.16.3", "prisma": "^5.7.1", @@ -3612,6 +3613,15 @@ "integrity": "sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q==", "license": "MIT" }, + "node_modules/aws-ssl-profiles": { + "version": "1.1.2", + "resolved": "https://registry.npmjs.org/aws-ssl-profiles/-/aws-ssl-profiles-1.1.2.tgz", + "integrity": "sha512-NZKeq9AfyQvEeNlN0zSYAaWrmBffJh3IELMZfRpJVWgrpEbtEpnjvzqBPf+mxoI287JohRDoa+/nsfqqiZmF6g==", + "license": "MIT", + "engines": { + "node": ">= 6.0.0" + } + }, "node_modules/axios": { "version": "1.11.0", "resolved": "https://registry.npmjs.org/axios/-/axios-1.11.0.tgz", @@ -4457,6 +4467,15 @@ "node": ">=0.4.0" } }, + "node_modules/denque": { + "version": "2.1.0", + "resolved": "https://registry.npmjs.org/denque/-/denque-2.1.0.tgz", + "integrity": "sha512-HVQE3AAb/pxF8fQAoiqpvg9i3evqug3hoiwakOyZAwJm+6vZehbkYXZ0l4JxS+I3QxM97v5aaRNhj8v5oBhekw==", + "license": "Apache-2.0", + "engines": { + "node": ">=0.10" + } + }, "node_modules/depd": { "version": "2.0.0", "resolved": "https://registry.npmjs.org/depd/-/depd-2.0.0.tgz", @@ -5413,6 +5432,15 @@ "url": "https://github.com/sponsors/ljharb" } }, + "node_modules/generate-function": { + "version": "2.3.1", + "resolved": "https://registry.npmjs.org/generate-function/-/generate-function-2.3.1.tgz", + "integrity": "sha512-eeB5GfMNeevm/GRYq20ShmsaGcmI81kIX2K9XQx5miC8KdHaC6Jm0qQ8ZNeGOi7wYB8OsdxKs+Y2oVuTFuVwKQ==", + "license": "MIT", + "dependencies": { + "is-property": "^1.0.2" + } + }, "node_modules/generic-pool": { "version": "3.9.0", "resolved": "https://registry.npmjs.org/generic-pool/-/generic-pool-3.9.0.tgz", @@ -5959,6 +5987,12 @@ "node": ">=8" } }, + "node_modules/is-property": { + "version": "1.0.2", + "resolved": "https://registry.npmjs.org/is-property/-/is-property-1.0.2.tgz", + "integrity": "sha512-Ks/IoX00TtClbGQr4TWXemAnktAQvYB7HzcCxDGqEZU6oCmb2INHuOoKxbtR+HFkmYWBKv/dOZtGRiAjDhj92g==", + "license": "MIT" + }, "node_modules/is-stream": { "version": "2.0.1", "resolved": "https://registry.npmjs.org/is-stream/-/is-stream-2.0.1.tgz", @@ -6914,6 +6948,12 @@ "node": ">= 12.0.0" } }, + "node_modules/long": { + "version": "5.3.2", + "resolved": "https://registry.npmjs.org/long/-/long-5.3.2.tgz", + "integrity": "sha512-mNAgZ1GmyNhD7AuqnTG3/VQ26o760+ZYBPKjPvugO8+nLbYfX6TVpJPseBvopbdY+qpZ/lKUnmEc1LeZYS3QAA==", + "license": "Apache-2.0" + }, "node_modules/lru-cache": { "version": "5.1.1", "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-5.1.1.tgz", @@ -6924,6 +6964,21 @@ "yallist": "^3.0.2" } }, + "node_modules/lru.min": { + "version": "1.1.2", + "resolved": "https://registry.npmjs.org/lru.min/-/lru.min-1.1.2.tgz", + "integrity": "sha512-Nv9KddBcQSlQopmBHXSsZVY5xsdlZkdH/Iey0BlcBYggMd4two7cZnKOK9vmy3nY0O5RGH99z1PCeTpPqszUYg==", + "license": "MIT", + "engines": { + "bun": ">=1.0.0", + "deno": ">=1.30.0", + "node": ">=8.0.0" + }, + "funding": { + "type": "github", + "url": "https://github.com/sponsors/wellwelwel" + } + }, "node_modules/make-dir": { "version": "4.0.0", "resolved": "https://registry.npmjs.org/make-dir/-/make-dir-4.0.0.tgz", @@ -7138,6 +7193,63 @@ "node": ">= 6.0.0" } }, + "node_modules/mysql2": { + "version": "3.15.0", + "resolved": "https://registry.npmjs.org/mysql2/-/mysql2-3.15.0.tgz", + "integrity": "sha512-tT6pomf5Z/I7Jzxu8sScgrYBMK9bUFWd7Kbo6Fs1L0M13OOIJ/ZobGKS3Z7tQ8Re4lj+LnLXIQVZZxa3fhYKzA==", + "license": "MIT", + "dependencies": { + "aws-ssl-profiles": "^1.1.1", + "denque": "^2.1.0", + "generate-function": "^2.3.1", + "iconv-lite": "^0.7.0", + "long": "^5.2.1", + "lru.min": "^1.0.0", + "named-placeholders": "^1.1.3", + "seq-queue": "^0.0.5", + "sqlstring": "^2.3.2" + }, + "engines": { + "node": ">= 8.0" + } + }, + "node_modules/mysql2/node_modules/iconv-lite": { + "version": "0.7.0", + "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.7.0.tgz", + "integrity": "sha512-cf6L2Ds3h57VVmkZe+Pn+5APsT7FpqJtEhhieDCvrE2MK5Qk9MyffgQyuxQTm6BChfeZNtcOLHp9IcWRVcIcBQ==", + "license": "MIT", + "dependencies": { + "safer-buffer": ">= 2.1.2 < 3.0.0" + }, + "engines": { + "node": ">=0.10.0" + }, + "funding": { + "type": "opencollective", + "url": "https://opencollective.com/express" + } + }, + "node_modules/named-placeholders": { + "version": "1.1.3", + "resolved": "https://registry.npmjs.org/named-placeholders/-/named-placeholders-1.1.3.tgz", + "integrity": "sha512-eLoBxg6wE/rZkJPhU/xRX1WTpkFEwDJEN96oxFrTsqBdbT5ec295Q+CoHrL9IT0DipqKhmGcaZmwOt8OON5x1w==", + "license": "MIT", + "dependencies": { + "lru-cache": "^7.14.1" + }, + "engines": { + "node": ">=12.0.0" + } + }, + "node_modules/named-placeholders/node_modules/lru-cache": { + "version": "7.18.3", + "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-7.18.3.tgz", + "integrity": "sha512-jumlc0BIUrS3qJGgIkWZsyfAM7NCWiBcCDhnd+3NNM5KbBmLTgHVfWBcg6W+rLUsIpzpERPsvwUP7CckAQSOoA==", + "license": "ISC", + "engines": { + "node": ">=12" + } + }, "node_modules/natural-compare": { "version": "1.4.0", "resolved": "https://registry.npmjs.org/natural-compare/-/natural-compare-1.4.0.tgz", @@ -8226,6 +8338,11 @@ "node": ">= 0.8" } }, + "node_modules/seq-queue": { + "version": "0.0.5", + "resolved": "https://registry.npmjs.org/seq-queue/-/seq-queue-0.0.5.tgz", + "integrity": "sha512-hr3Wtp/GZIc/6DAGPDcV4/9WoZhjrkXsi5B/07QgX8tsdc6ilr7BFM6PM6rbdAX1kFSDYeZGLipIZZKyQP0O5Q==" + }, "node_modules/serve-static": { "version": "1.16.2", "resolved": "https://registry.npmjs.org/serve-static/-/serve-static-1.16.2.tgz", @@ -8431,6 +8548,15 @@ "dev": true, "license": "BSD-3-Clause" }, + "node_modules/sqlstring": { + "version": "2.3.3", + "resolved": "https://registry.npmjs.org/sqlstring/-/sqlstring-2.3.3.tgz", + "integrity": "sha512-qC9iz2FlN7DQl3+wjwn3802RTyjCx7sDvfQEXchwa6CWOx07/WVfh91gBmQ9fahw8snwGEWU3xGzOt4tFyHLxg==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, "node_modules/stack-trace": { "version": "0.0.10", "resolved": "https://registry.npmjs.org/stack-trace/-/stack-trace-0.0.10.tgz", diff --git a/backend-node/package.json b/backend-node/package.json index 258475e9..7c7e9fb8 100644 --- a/backend-node/package.json +++ b/backend-node/package.json @@ -39,6 +39,7 @@ "joi": "^17.11.0", "jsonwebtoken": "^9.0.2", "multer": "^1.4.5-lts.1", + "mysql2": "^3.15.0", "nodemailer": "^6.9.7", "pg": "^8.16.3", "prisma": "^5.7.1", diff --git a/backend-node/src/database/DatabaseConnectorFactory.ts b/backend-node/src/database/DatabaseConnectorFactory.ts new file mode 100644 index 00000000..6bb55d88 --- /dev/null +++ b/backend-node/src/database/DatabaseConnectorFactory.ts @@ -0,0 +1,52 @@ +import { DatabaseConnector, ConnectionConfig } from '../interfaces/DatabaseConnector'; +import { PostgreSQLConnector } from './PostgreSQLConnector'; + +export class DatabaseConnectorFactory { + private static connectors = new Map(); + + static async createConnector( + type: string, + config: ConnectionConfig, + connectionId: number // Added connectionId for unique key + ): Promise { + const key = `${type}-${connectionId}`; // Use connectionId for unique key + if (this.connectors.has(key)) { + return this.connectors.get(key)!; + } + + let connector: DatabaseConnector; + + switch (type.toLowerCase()) { + case 'postgresql': + connector = new PostgreSQLConnector(config); + break; + // Add other database types here + default: + throw new Error(`지원하지 않는 데이터베이스 타입: ${type}`); + } + + this.connectors.set(key, connector); + return connector; + } + + static async getConnector(connectionId: number, type: string): Promise { + const key = `${type}-${connectionId}`; + return this.connectors.get(key); + } + + static async closeConnector(connectionId: number, type: string): Promise { + const key = `${type}-${connectionId}`; + const connector = this.connectors.get(key); + if (connector) { + await connector.disconnect(); + this.connectors.delete(key); + } + } + + static async closeAll(): Promise { + for (const connector of this.connectors.values()) { + await connector.disconnect(); + } + this.connectors.clear(); + } +} \ No newline at end of file diff --git a/backend-node/src/database/MySQLConnector.ts b/backend-node/src/database/MySQLConnector.ts new file mode 100644 index 00000000..6d27bad6 --- /dev/null +++ b/backend-node/src/database/MySQLConnector.ts @@ -0,0 +1,175 @@ +import * as mysql from 'mysql2/promise'; +import { DatabaseConnector, ConnectionConfig, QueryResult } from '../interfaces/DatabaseConnector'; +import { ConnectionTestResult, TableInfo } from '../types/externalDbTypes'; + +export class MySQLConnector implements DatabaseConnector { + private connection: mysql.Connection | null = null; + private config: ConnectionConfig; + + constructor(config: ConnectionConfig) { + this.config = config; + } + + async connect(): Promise { + if (this.connection) { + throw new Error('이미 연결되어 있습니다.'); + } + + this.connection = await mysql.createConnection({ + host: this.config.host, + port: this.config.port, + database: this.config.database, + user: this.config.username, + password: this.config.password, + connectTimeout: this.config.connectionTimeout || 30000, + ssl: this.config.sslEnabled ? { rejectUnauthorized: false } : undefined, + }); + } + + async disconnect(): Promise { + if (this.connection) { + await this.connection.end(); + this.connection = null; + } + } + + async testConnection(): Promise { + const startTime = Date.now(); + try { + await this.connect(); + + const [versionResult] = await this.connection!.query('SELECT VERSION() as version'); + const [sizeResult] = await this.connection!.query( + 'SELECT SUM(data_length + index_length) as size FROM information_schema.tables WHERE table_schema = DATABASE()' + ); + + const responseTime = Date.now() - startTime; + + return { + success: true, + message: 'MySQL 연결이 성공했습니다.', + details: { + response_time: responseTime, + server_version: (versionResult as any)[0]?.version || '알 수 없음', + database_size: this.formatBytes(parseInt((sizeResult as any)[0]?.size || '0')), + }, + }; + } catch (error) { + return { + success: false, + message: 'MySQL 연결에 실패했습니다.', + error: { + code: 'CONNECTION_FAILED', + details: error instanceof Error ? error.message : '알 수 없는 오류', + }, + }; + } finally { + await this.disconnect(); + } + } + + async executeQuery(query: string): Promise { + if (!this.connection) { + await this.connect(); + } + + try { + const [rows, fields] = await this.connection!.query(query); + return { + rows: rows as any[], + rowCount: Array.isArray(rows) ? rows.length : 0, + fields: (fields as mysql.FieldPacket[]).map(field => ({ + name: field.name, + dataType: field.type.toString(), + })), + }; + } finally { + await this.disconnect(); + } + } + + async getTables(): Promise { + if (!this.connection) { + await this.connect(); + } + + try { + const [tables] = await this.connection!.query(` + SELECT + t.TABLE_NAME as table_name, + t.TABLE_COMMENT as table_description + FROM information_schema.TABLES t + WHERE t.TABLE_SCHEMA = DATABASE() + ORDER BY t.TABLE_NAME + `); + + const result: TableInfo[] = []; + + for (const table of tables as any[]) { + const [columns] = await this.connection!.query(` + SELECT + COLUMN_NAME as column_name, + DATA_TYPE as data_type, + IS_NULLABLE as is_nullable, + COLUMN_DEFAULT as column_default + FROM information_schema.COLUMNS + WHERE TABLE_SCHEMA = DATABASE() + AND TABLE_NAME = ? + ORDER BY ORDINAL_POSITION + `, [table.table_name]); + + result.push({ + table_name: table.table_name, + description: table.table_description || null, + columns: columns as any[], + }); + } + + return result; + } finally { + await this.disconnect(); + } + } + + async getColumns(tableName: string): Promise> { + if (!this.connection) { + await this.connect(); + } + + try { + const [columns] = await this.connection!.query(` + SELECT + COLUMN_NAME as name, + DATA_TYPE as dataType, + IS_NULLABLE = 'YES' as isNullable, + COLUMN_DEFAULT as defaultValue + FROM information_schema.COLUMNS + WHERE TABLE_SCHEMA = DATABASE() + AND TABLE_NAME = ? + ORDER BY ORDINAL_POSITION + `, [tableName]); + + return (columns as any[]).map(col => ({ + name: col.name, + dataType: col.dataType, + isNullable: col.isNullable, + defaultValue: col.defaultValue, + })); + } finally { + await this.disconnect(); + } + } + + private formatBytes(bytes: number): string { + if (bytes === 0) return '0 Bytes'; + const k = 1024; + const sizes = ['Bytes', 'KB', 'MB', 'GB', 'TB']; + const i = Math.floor(Math.log(bytes) / Math.log(k)); + return parseFloat((bytes / Math.pow(k, i)).toFixed(2)) + ' ' + sizes[i]; + } +} diff --git a/backend-node/src/database/PostgreSQLConnector.ts b/backend-node/src/database/PostgreSQLConnector.ts new file mode 100644 index 00000000..1a6065a4 --- /dev/null +++ b/backend-node/src/database/PostgreSQLConnector.ts @@ -0,0 +1,145 @@ +import { Client } from 'pg'; +import { DatabaseConnector, ConnectionConfig, QueryResult } from '../interfaces/DatabaseConnector'; +import { ConnectionTestResult, TableInfo } from '../types/externalDbTypes'; + +export class PostgreSQLConnector implements DatabaseConnector { + private client: Client | null = null; + private config: ConnectionConfig; + + constructor(config: ConnectionConfig) { + this.config = config; + } + + async connect(): Promise { + if (this.client) { + await this.disconnect(); + } + const clientConfig: any = { + host: this.config.host, + port: this.config.port, + database: this.config.database, + user: this.config.user, + password: this.config.password, + }; + + if (this.config.connectionTimeoutMillis != null) { + clientConfig.connectionTimeoutMillis = this.config.connectionTimeoutMillis; + } + + if (this.config.queryTimeoutMillis != null) { + clientConfig.query_timeout = this.config.queryTimeoutMillis; + } + + if (this.config.ssl != null) { + clientConfig.ssl = this.config.ssl; + } + + this.client = new Client(clientConfig); + await this.client.connect(); + } + + async disconnect(): Promise { + if (this.client) { + await this.client.end(); + this.client = null; + } + } + + async testConnection(): Promise { + const startTime = Date.now(); + try { + await this.connect(); + const result = await this.client!.query("SELECT version(), pg_database_size(current_database()) as size"); + const responseTime = Date.now() - startTime; + await this.disconnect(); + return { + success: true, + message: "PostgreSQL 연결이 성공했습니다.", + details: { + response_time: responseTime, + server_version: result.rows[0]?.version || "알 수 없음", + database_size: this.formatBytes(parseInt(result.rows[0]?.size || "0")), + }, + }; + } catch (error: any) { + await this.disconnect(); + return { + success: false, + message: "PostgreSQL 연결에 실패했습니다.", + error: { + code: "CONNECTION_FAILED", + details: error.message || "알 수 없는 오류", + }, + }; + } + } + + async executeQuery(query: string): Promise { + try { + await this.connect(); + const result = await this.client!.query(query); + await this.disconnect(); + return { + rows: result.rows, + rowCount: result.rowCount ?? undefined, + fields: result.fields ?? undefined, + }; + } catch (error: any) { + await this.disconnect(); + throw new Error(`PostgreSQL 쿼리 실행 실패: ${error.message}`); + } + } + + async getTables(): Promise { + try { + await this.connect(); + const result = await this.client!.query(` + SELECT + t.table_name, + obj_description(quote_ident(t.table_name)::regclass::oid, 'pg_class') as table_description + FROM information_schema.tables t + WHERE t.table_schema = 'public' + AND t.table_type = 'BASE TABLE' + ORDER BY t.table_name; + `); + await this.disconnect(); + return result.rows.map((row) => ({ + table_name: row.table_name, + description: row.table_description, + columns: [], // Columns will be fetched by getColumns + })); + } catch (error: any) { + await this.disconnect(); + throw new Error(`PostgreSQL 테이블 목록 조회 실패: ${error.message}`); + } + } + + async getColumns(tableName: string): Promise { + try { + await this.connect(); + const result = await this.client!.query(` + SELECT + column_name, + data_type, + is_nullable, + column_default + FROM information_schema.columns + WHERE table_schema = 'public' AND table_name = $1 + ORDER BY ordinal_position; + `, [tableName]); + await this.disconnect(); + return result.rows; + } catch (error: any) { + await this.disconnect(); + throw new Error(`PostgreSQL 컬럼 정보 조회 실패: ${error.message}`); + } + } + + private formatBytes(bytes: number): string { + if (bytes === 0) return "0 Bytes"; + const k = 1024; + const sizes = ["Bytes", "KB", "MB", "GB", "TB"]; + const i = Math.floor(Math.log(bytes) / Math.log(k)); + return parseFloat((bytes / Math.pow(k, i)).toFixed(2)) + " " + sizes[i]; + } +} \ No newline at end of file diff --git a/backend-node/src/interfaces/DatabaseConnector.ts b/backend-node/src/interfaces/DatabaseConnector.ts new file mode 100644 index 00000000..c8980eef --- /dev/null +++ b/backend-node/src/interfaces/DatabaseConnector.ts @@ -0,0 +1,27 @@ +import { ConnectionTestResult, TableInfo } from '../types/externalDbTypes'; + +export interface ConnectionConfig { + host: string; + port: number; + database: string; + user: string; + password: string; + connectionTimeoutMillis?: number; + queryTimeoutMillis?: number; + ssl?: boolean | { rejectUnauthorized: boolean }; +} + +export interface QueryResult { + rows: any[]; + rowCount?: number; + fields?: any[]; +} + +export interface DatabaseConnector { + connect(): Promise; + disconnect(): Promise; + testConnection(): Promise; + executeQuery(query: string): Promise; + getTables(): Promise; + getColumns(tableName: string): Promise; // 특정 테이블의 컬럼 정보 조회 +} \ No newline at end of file diff --git a/backend-node/src/services/dbConnectionManager.ts b/backend-node/src/services/dbConnectionManager.ts new file mode 100644 index 00000000..78500c48 --- /dev/null +++ b/backend-node/src/services/dbConnectionManager.ts @@ -0,0 +1,59 @@ +import { DatabaseConnectorFactory } from '../database/DatabaseConnectorFactory'; +import { ConnectionConfig, QueryResult } from '../interfaces/DatabaseConnector'; +import { ConnectionTestResult, TableInfo } from '../types/externalDbTypes'; + +export class DbConnectionManager { + static async testConnection( + connectionId: number, + dbType: string, + config: ConnectionConfig + ): Promise { + const connector = await DatabaseConnectorFactory.createConnector(dbType, config, connectionId); + try { + return await connector.testConnection(); + } finally { + await DatabaseConnectorFactory.closeConnector(connectionId, dbType); // Close after test + } + } + + static async executeQuery( + connectionId: number, + dbType: string, + config: ConnectionConfig, + query: string + ): Promise { + const connector = await DatabaseConnectorFactory.createConnector(dbType, config, connectionId); + try { + return await connector.executeQuery(query); + } finally { + await DatabaseConnectorFactory.closeConnector(connectionId, dbType); + } + } + + static async getTables( + connectionId: number, + dbType: string, + config: ConnectionConfig + ): Promise { + const connector = await DatabaseConnectorFactory.createConnector(dbType, config, connectionId); + try { + return await connector.getTables(); + } finally { + await DatabaseConnectorFactory.closeConnector(connectionId, dbType); + } + } + + static async getColumns( + connectionId: number, + dbType: string, + config: ConnectionConfig, + tableName: string + ): Promise { + const connector = await DatabaseConnectorFactory.createConnector(dbType, config, connectionId); + try { + return await connector.getColumns(tableName); + } finally { + await DatabaseConnectorFactory.closeConnector(connectionId, dbType); + } + } +} \ No newline at end of file diff --git a/backend-node/src/services/externalDbConnectionService.ts b/backend-node/src/services/externalDbConnectionService.ts index 8039ebb0..bd9f8e86 100644 --- a/backend-node/src/services/externalDbConnectionService.ts +++ b/backend-node/src/services/externalDbConnectionService.ts @@ -9,6 +9,7 @@ import { TableInfo, } from "../types/externalDbTypes"; import { PasswordEncryption } from "../utils/passwordEncryption"; +import { DbConnectionManager } from "./dbConnectionManager"; const prisma = new PrismaClient(); @@ -321,8 +322,6 @@ export class ExternalDbConnectionService { static async testConnectionById( id: number ): Promise { - const startTime = Date.now(); - try { // 저장된 연결 정보 조회 const connection = await prisma.external_db_connections.findUnique({ @@ -353,40 +352,20 @@ export class ExternalDbConnectionService { }; } - // 테스트용 데이터 준비 - const testData = { - db_type: connection.db_type, + // 연결 설정 준비 + const config = { host: connection.host, port: connection.port, - database_name: connection.database_name, - username: connection.username, + database: connection.database_name, + user: connection.username, password: decryptedPassword, - connection_timeout: connection.connection_timeout || undefined, - ssl_enabled: connection.ssl_enabled || undefined + connectionTimeoutMillis: connection.connection_timeout != null ? connection.connection_timeout * 1000 : undefined, + queryTimeoutMillis: connection.query_timeout != null ? connection.query_timeout * 1000 : undefined, + ssl: connection.ssl_enabled === "Y" ? { rejectUnauthorized: false } : false }; - // 실제 연결 테스트 수행 - switch (connection.db_type.toLowerCase()) { - case "postgresql": - return await this.testPostgreSQLConnection(testData, startTime); - case "mysql": - return await this.testMySQLConnection(testData, startTime); - case "oracle": - return await this.testOracleConnection(testData, startTime); - case "mssql": - return await this.testMSSQLConnection(testData, startTime); - case "sqlite": - return await this.testSQLiteConnection(testData, startTime); - default: - return { - success: false, - message: `지원하지 않는 데이터베이스 타입입니다: ${testData.db_type}`, - error: { - code: "UNSUPPORTED_DB_TYPE", - details: `${testData.db_type} 타입은 현재 지원하지 않습니다.`, - }, - }; - } + // DbConnectionManager를 통한 연결 테스트 + return await DbConnectionManager.testConnection(id, connection.db_type, config); } catch (error) { return { success: false, @@ -399,132 +378,6 @@ export class ExternalDbConnectionService { } } - /** - * PostgreSQL 연결 테스트 - */ - private static async testPostgreSQLConnection( - testData: any, - startTime: number - ): Promise { - const { Client } = await import("pg"); - const client = new Client({ - host: testData.host, - port: testData.port, - database: testData.database_name, - user: testData.username, - password: testData.password, - connectionTimeoutMillis: (testData.connection_timeout || 30) * 1000, - ssl: testData.ssl_enabled === "Y" ? { rejectUnauthorized: false } : false, - }); - - try { - await client.connect(); - const result = await client.query( - "SELECT version(), pg_database_size(current_database()) as size" - ); - const responseTime = Date.now() - startTime; - - await client.end(); - - return { - success: true, - message: "PostgreSQL 연결이 성공했습니다.", - details: { - response_time: responseTime, - server_version: result.rows[0]?.version || "알 수 없음", - database_size: this.formatBytes( - parseInt(result.rows[0]?.size || "0") - ), - }, - }; - } catch (error) { - try { - await client.end(); - } catch (endError) { - // 연결 종료 오류는 무시 - } - - return { - success: false, - message: "PostgreSQL 연결에 실패했습니다.", - error: { - code: "CONNECTION_FAILED", - details: error instanceof Error ? error.message : "알 수 없는 오류", - }, - }; - } - } - - /** - * MySQL 연결 테스트 (모의 구현) - */ - private static async testMySQLConnection( - testData: any, - startTime: number - ): Promise { - // MySQL 라이브러리가 없으므로 모의 구현 - return { - success: false, - message: "MySQL 연결 테스트는 현재 지원하지 않습니다.", - error: { - code: "NOT_IMPLEMENTED", - details: "MySQL 라이브러리가 설치되지 않았습니다.", - }, - }; - } - - /** - * Oracle 연결 테스트 (모의 구현) - */ - private static async testOracleConnection( - testData: any, - startTime: number - ): Promise { - return { - success: false, - message: "Oracle 연결 테스트는 현재 지원하지 않습니다.", - error: { - code: "NOT_IMPLEMENTED", - details: "Oracle 라이브러리가 설치되지 않았습니다.", - }, - }; - } - - /** - * SQL Server 연결 테스트 (모의 구현) - */ - private static async testMSSQLConnection( - testData: any, - startTime: number - ): Promise { - return { - success: false, - message: "SQL Server 연결 테스트는 현재 지원하지 않습니다.", - error: { - code: "NOT_IMPLEMENTED", - details: "SQL Server 라이브러리가 설치되지 않았습니다.", - }, - }; - } - - /** - * SQLite 연결 테스트 (모의 구현) - */ - private static async testSQLiteConnection( - testData: any, - startTime: number - ): Promise { - return { - success: false, - message: "SQLite 연결 테스트는 현재 지원하지 않습니다.", - error: { - code: "NOT_IMPLEMENTED", - details: - "SQLite는 파일 기반이므로 네트워크 연결 테스트가 불가능합니다.", - }, - }; - } - /** * 바이트 크기를 읽기 쉬운 형태로 변환 */ @@ -622,36 +475,26 @@ export class ExternalDbConnectionService { }; } - // DB 타입에 따른 쿼리 실행 - switch (connection.db_type.toLowerCase()) { - case "postgresql": - return await this.executePostgreSQLQuery(connection, decryptedPassword, query); - case "mysql": - return { - success: false, - message: "MySQL 쿼리 실행은 현재 지원하지 않습니다." - }; - case "oracle": - return { - success: false, - message: "Oracle 쿼리 실행은 현재 지원하지 않습니다." - }; - case "mssql": - return { - success: false, - message: "SQL Server 쿼리 실행은 현재 지원하지 않습니다." - }; - case "sqlite": - return { - success: false, - message: "SQLite 쿼리 실행은 현재 지원하지 않습니다." - }; - default: - return { - success: false, - message: `지원하지 않는 데이터베이스 타입입니다: ${connection.db_type}` - }; - } + // 연결 설정 준비 + const config = { + host: connection.host, + port: connection.port, + database: connection.database_name, + user: connection.username, + password: decryptedPassword, + connectionTimeoutMillis: connection.connection_timeout != null ? connection.connection_timeout * 1000 : undefined, + queryTimeoutMillis: connection.query_timeout != null ? connection.query_timeout * 1000 : undefined, + ssl: connection.ssl_enabled === "Y" ? { rejectUnauthorized: false } : false + }; + + // DbConnectionManager를 통한 쿼리 실행 + const result = await DbConnectionManager.executeQuery(id, connection.db_type, config, query); + + return { + success: true, + message: "쿼리가 성공적으로 실행되었습니다.", + data: result.rows + }; } catch (error) { console.error("쿼리 실행 오류:", error); return { @@ -740,15 +583,26 @@ export class ExternalDbConnectionService { }; } - switch (connection.db_type.toLowerCase()) { - case "postgresql": - return await this.getPostgreSQLTables(connection, decryptedPassword); - default: - return { - success: false, - message: `지원하지 않는 데이터베이스 타입입니다: ${connection.db_type}` - }; - } + // 연결 설정 준비 + const config = { + host: connection.host, + port: connection.port, + database: connection.database_name, + user: connection.username, + password: decryptedPassword, + connectionTimeoutMillis: connection.connection_timeout != null ? connection.connection_timeout * 1000 : undefined, + queryTimeoutMillis: connection.query_timeout != null ? connection.query_timeout * 1000 : undefined, + ssl: connection.ssl_enabled === "Y" ? { rejectUnauthorized: false } : false + }; + + // DbConnectionManager를 통한 테이블 목록 조회 + const tables = await DbConnectionManager.getTables(id, connection.db_type, config); + + return { + success: true, + message: "테이블 목록을 조회했습니다.", + data: tables + }; } catch (error) { console.error("테이블 목록 조회 오류:", error); return { diff --git a/frontend/components/admin/SqlQueryModal.tsx b/frontend/components/admin/SqlQueryModal.tsx index cdc85786..de508db7 100644 --- a/frontend/components/admin/SqlQueryModal.tsx +++ b/frontend/components/admin/SqlQueryModal.tsx @@ -122,7 +122,7 @@ export const SqlQueryModal: React.FC = ({ isOpen, onClose, c return ( - + {connectionName} - SQL 쿼리 실행 @@ -131,7 +131,7 @@ export const SqlQueryModal: React.FC = ({ isOpen, onClose, c {/* 쿼리 입력 영역 */} -
+
{/* 테이블 선택 */}
@@ -168,28 +168,32 @@ export const SqlQueryModal: React.FC = ({ isOpen, onClose, c {/* 테이블 정보 */}

사용 가능한 테이블

-
- {tables.map((table) => ( -
-
-

{table.table_name}

- -
- {table.description && ( -

{table.description}

- )} -
- {table.columns.map((column: TableColumn) => ( -
- {column.column_name} - ({column.data_type}) +
+
+ {tables.map((table) => ( +
+
+
+

{table.table_name}

+
- ))} + {table.description && ( +

{table.description}

+ )} +
+ {table.columns.map((column: TableColumn) => ( +
+ {column.column_name} + ({column.data_type}) +
+ ))} +
+
-
- ))} + ))} +
@@ -218,7 +222,7 @@ export const SqlQueryModal: React.FC = ({ isOpen, onClose, c
{/* 결과 섹션 */} -
+
{loading ? "쿼리 실행 중..." : results.length > 0 ? `${results.length}개의 결과가 있습니다.` : "실행된 쿼리가 없습니다."} @@ -227,45 +231,49 @@ export const SqlQueryModal: React.FC = ({ isOpen, onClose, c {/* 결과 그리드 */}
-
- - {results.length > 0 ? ( - <> - - - {Object.keys(results[0]).map((key) => ( - - {key} - - ))} - - - - {results.map((row: QueryResult, i: number) => ( - - {Object.values(row).map((value, j) => ( - - {value === null ? ( - NULL - ) : ( - String(value) - )} - +
+
+
+
+ {results.length > 0 ? ( + <> + + + {Object.keys(results[0]).map((key) => ( + + {key} + + ))} + + + + {results.map((row: QueryResult, i: number) => ( + + {Object.values(row).map((value, j) => ( + + {value === null ? ( + NULL + ) : ( + String(value) + )} + + ))} + ))} + + + ) : ( + + + + {loading ? "쿼리 실행 중..." : "쿼리를 실행하면 결과가 여기에 표시됩니다."} + - ))} - - - ) : ( - - - - {loading ? "쿼리 실행 중..." : "쿼리를 실행하면 결과가 여기에 표시됩니다."} - - - - )} -
+ + )} + +
+
-- 2.43.0 From 3083ffc0a3b49f4a97fdeb9ce060b0cbaeea8b3b Mon Sep 17 00:00:00 2001 From: leeheejin Date: Tue, 23 Sep 2025 12:34:34 +0900 Subject: [PATCH 4/4] =?UTF-8?q?=EC=99=B8=EB=B6=80=EC=BB=A4=EB=84=A5?= =?UTF-8?q?=EC=85=98=EA=B4=80=EB=A6=AC=20=EC=88=98=EC=A0=95=EC=8B=9C=20?= =?UTF-8?q?=EC=97=B0=EA=B2=B0=ED=85=8C=EC=8A=A4=ED=8A=B8=20=EB=AC=B8?= =?UTF-8?q?=EC=A0=9C=20=ED=95=B4=EA=B2=B0=EA=B3=BC=20=ED=94=84=EB=A1=A0?= =?UTF-8?q?=ED=8A=B8=20=EC=95=BD=EA=B0=84=20=EC=88=98=EC=A0=95=ED=95=9C=20?= =?UTF-8?q?=EB=82=B4=EC=9A=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- frontend/app/(main)/admin/page.tsx | 38 +++++++++---------- .../admin/ExternalDbConnectionModal.tsx | 21 +++++----- frontend/components/layout/AppLayout.tsx | 12 +++++- 3 files changed, 39 insertions(+), 32 deletions(-) diff --git a/frontend/app/(main)/admin/page.tsx b/frontend/app/(main)/admin/page.tsx index e4bec481..b320ab45 100644 --- a/frontend/app/(main)/admin/page.tsx +++ b/frontend/app/(main)/admin/page.tsx @@ -5,13 +5,13 @@ import Link from "next/link"; */ export default function AdminPage() { return ( -
+
{/* 관리자 기능 카드들 */} -
+
-
+
@@ -24,8 +24,8 @@ export default function AdminPage() {
-
- +
+

권한 관리

@@ -36,8 +36,8 @@ export default function AdminPage() {
-
- +
+

시스템 설정

@@ -48,8 +48,8 @@ export default function AdminPage() {
-
- +
+

통계 및 리포트

@@ -61,7 +61,7 @@ export default function AdminPage() {
-
+
@@ -74,14 +74,14 @@ export default function AdminPage() {
{/* 표준 관리 섹션 */} -
+

표준 관리

-
- +
+

웹타입 관리

@@ -94,8 +94,8 @@ export default function AdminPage() {
-
- +
+

템플릿 관리

@@ -108,8 +108,8 @@ export default function AdminPage() {
-
- +
+

테이블 관리

@@ -122,8 +122,8 @@ export default function AdminPage() {
-
- +
+

컴포넌트 관리

diff --git a/frontend/components/admin/ExternalDbConnectionModal.tsx b/frontend/components/admin/ExternalDbConnectionModal.tsx index b86050f8..4959f6fe 100644 --- a/frontend/components/admin/ExternalDbConnectionModal.tsx +++ b/frontend/components/admin/ExternalDbConnectionModal.tsx @@ -211,18 +211,17 @@ export const ExternalDbConnectionModal: React.FC setTestingConnection(true); setTestResult(null); - const testData: ConnectionTestRequest = { - db_type: formData.db_type, - host: formData.host, - port: formData.port, - database_name: formData.database_name, - username: formData.username, - password: formData.password, - connection_timeout: formData.connection_timeout, - ssl_enabled: formData.ssl_enabled, - }; + // 편집 모드일 때만 연결 테스트 실행 + if (!isEditMode || !connection?.id) { + toast({ + title: "연결 테스트 불가", + description: "연결을 먼저 저장한 후 테스트할 수 있습니다.", + variant: "destructive", + }); + return; + } - const result = await ExternalDbConnectionAPI.testConnection(testData); + const result = await ExternalDbConnectionAPI.testConnection(connection.id); setTestResult(result); if (result.success) { diff --git a/frontend/components/layout/AppLayout.tsx b/frontend/components/layout/AppLayout.tsx index f99c72f5..22cd259b 100644 --- a/frontend/components/layout/AppLayout.tsx +++ b/frontend/components/layout/AppLayout.tsx @@ -307,7 +307,11 @@ function AppLayoutInner({ children }: AppLayoutProps) {
0 ? "ml-6" : ""}`} onClick={() => handleMenuClick(menu)} > @@ -328,7 +332,11 @@ function AppLayoutInner({ children }: AppLayoutProps) { {menu.children?.map((child: any) => (
handleMenuClick(child)} > {child.icon} -- 2.43.0