Merge pull request 'dev' (#54) from dev into main
Reviewed-on: http://39.117.244.52:3000/kjs/ERP-node/pulls/54
This commit is contained in:
commit
4b148ee823
|
|
@ -35,6 +35,20 @@ model external_call_configs {
|
||||||
updated_date DateTime? @default(now()) @updatedAt @db.Timestamp(6)
|
updated_date DateTime? @default(now()) @updatedAt @db.Timestamp(6)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
model db_type_categories {
|
||||||
|
type_code String @id @db.VarChar(20)
|
||||||
|
display_name String @db.VarChar(50)
|
||||||
|
icon String? @db.VarChar(50)
|
||||||
|
color String? @db.VarChar(20)
|
||||||
|
sort_order Int? @default(0)
|
||||||
|
is_active Boolean @default(true)
|
||||||
|
created_at DateTime @default(now()) @db.Timestamp(6)
|
||||||
|
updated_at DateTime @default(now()) @updatedAt @db.Timestamp(6)
|
||||||
|
|
||||||
|
// 관계 설정
|
||||||
|
external_db_connections external_db_connections[]
|
||||||
|
}
|
||||||
|
|
||||||
model external_db_connections {
|
model external_db_connections {
|
||||||
id Int @id @default(autoincrement())
|
id Int @id @default(autoincrement())
|
||||||
connection_name String @db.VarChar(100)
|
connection_name String @db.VarChar(100)
|
||||||
|
|
@ -59,9 +73,11 @@ model external_db_connections {
|
||||||
updated_by String? @db.VarChar(50)
|
updated_by String? @db.VarChar(50)
|
||||||
|
|
||||||
// 관계
|
// 관계
|
||||||
|
db_type_category db_type_categories? @relation(fields: [db_type], references: [type_code])
|
||||||
collection_configs data_collection_configs[]
|
collection_configs data_collection_configs[]
|
||||||
|
|
||||||
@@index([connection_name], map: "idx_external_db_connections_name")
|
@@index([connection_name], map: "idx_external_db_connections_name")
|
||||||
|
@@index([db_type], map: "idx_external_db_connections_db_type")
|
||||||
}
|
}
|
||||||
|
|
||||||
model admin_supply_mng {
|
model admin_supply_mng {
|
||||||
|
|
|
||||||
|
|
@ -31,6 +31,7 @@ import layoutRoutes from "./routes/layoutRoutes";
|
||||||
import dataRoutes from "./routes/dataRoutes";
|
import dataRoutes from "./routes/dataRoutes";
|
||||||
import testButtonDataflowRoutes from "./routes/testButtonDataflowRoutes";
|
import testButtonDataflowRoutes from "./routes/testButtonDataflowRoutes";
|
||||||
import externalDbConnectionRoutes from "./routes/externalDbConnectionRoutes";
|
import externalDbConnectionRoutes from "./routes/externalDbConnectionRoutes";
|
||||||
|
import dbTypeCategoryRoutes from "./routes/dbTypeCategoryRoutes";
|
||||||
import ddlRoutes from "./routes/ddlRoutes";
|
import ddlRoutes from "./routes/ddlRoutes";
|
||||||
import entityReferenceRoutes from "./routes/entityReferenceRoutes";
|
import entityReferenceRoutes from "./routes/entityReferenceRoutes";
|
||||||
// import collectionRoutes from "./routes/collectionRoutes"; // 임시 주석
|
// import collectionRoutes from "./routes/collectionRoutes"; // 임시 주석
|
||||||
|
|
@ -129,6 +130,7 @@ app.use("/api/screen", screenStandardRoutes);
|
||||||
app.use("/api/data", dataRoutes);
|
app.use("/api/data", dataRoutes);
|
||||||
app.use("/api/test-button-dataflow", testButtonDataflowRoutes);
|
app.use("/api/test-button-dataflow", testButtonDataflowRoutes);
|
||||||
app.use("/api/external-db-connections", externalDbConnectionRoutes);
|
app.use("/api/external-db-connections", externalDbConnectionRoutes);
|
||||||
|
app.use("/api/db-type-categories", dbTypeCategoryRoutes);
|
||||||
app.use("/api/ddl", ddlRoutes);
|
app.use("/api/ddl", ddlRoutes);
|
||||||
app.use("/api/entity-reference", entityReferenceRoutes);
|
app.use("/api/entity-reference", entityReferenceRoutes);
|
||||||
// app.use("/api/collections", collectionRoutes); // 임시 주석
|
// app.use("/api/collections", collectionRoutes); // 임시 주석
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,215 @@
|
||||||
|
import { Request, Response } from "express";
|
||||||
|
import { DbTypeCategoryService } from "../services/dbTypeCategoryService";
|
||||||
|
import { AuthenticatedRequest } from "../types/auth";
|
||||||
|
|
||||||
|
export class DbTypeCategoryController {
|
||||||
|
/**
|
||||||
|
* GET /api/db-type-categories
|
||||||
|
* 모든 DB 타입 카테고리 조회
|
||||||
|
*/
|
||||||
|
static async getAllCategories(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const result = await DbTypeCategoryService.getAllCategories();
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 조회 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* GET /api/db-type-categories/:typeCode
|
||||||
|
* 특정 DB 타입 카테고리 조회
|
||||||
|
*/
|
||||||
|
static async getCategoryByTypeCode(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const { typeCode } = req.params;
|
||||||
|
|
||||||
|
if (!typeCode) {
|
||||||
|
return res.status(400).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 코드가 필요합니다."
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const result = await DbTypeCategoryService.getCategoryByTypeCode(typeCode);
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(404).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 조회 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* POST /api/db-type-categories
|
||||||
|
* DB 타입 카테고리 생성
|
||||||
|
*/
|
||||||
|
static async createCategory(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const { type_code, display_name, icon, color, sort_order } = req.body;
|
||||||
|
|
||||||
|
if (!type_code || !display_name) {
|
||||||
|
return res.status(400).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 코드와 표시명은 필수입니다."
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const result = await DbTypeCategoryService.createCategory({
|
||||||
|
type_code,
|
||||||
|
display_name,
|
||||||
|
icon,
|
||||||
|
color,
|
||||||
|
sort_order
|
||||||
|
});
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.status(201).json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 생성 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 생성 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* PUT /api/db-type-categories/:typeCode
|
||||||
|
* DB 타입 카테고리 수정
|
||||||
|
*/
|
||||||
|
static async updateCategory(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const { typeCode } = req.params;
|
||||||
|
const { display_name, icon, color, sort_order, is_active } = req.body;
|
||||||
|
|
||||||
|
if (!typeCode) {
|
||||||
|
return res.status(400).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 코드가 필요합니다."
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const result = await DbTypeCategoryService.updateCategory(typeCode, {
|
||||||
|
display_name,
|
||||||
|
icon,
|
||||||
|
color,
|
||||||
|
sort_order,
|
||||||
|
is_active
|
||||||
|
});
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 수정 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 수정 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DELETE /api/db-type-categories/:typeCode
|
||||||
|
* DB 타입 카테고리 삭제 (비활성화)
|
||||||
|
*/
|
||||||
|
static async deleteCategory(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const { typeCode } = req.params;
|
||||||
|
|
||||||
|
if (!typeCode) {
|
||||||
|
return res.status(400).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 코드가 필요합니다."
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const result = await DbTypeCategoryService.deleteCategory(typeCode);
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 삭제 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 삭제 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* GET /api/db-type-categories/stats/connections
|
||||||
|
* DB 타입별 연결 통계 조회
|
||||||
|
*/
|
||||||
|
static async getConnectionStatsByType(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const result = await DbTypeCategoryService.getConnectionStatsByType();
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입별 통계 조회 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입별 통계 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* POST /api/db-type-categories/initialize
|
||||||
|
* 기본 DB 타입 카테고리 초기화
|
||||||
|
*/
|
||||||
|
static async initializeDefaultCategories(req: AuthenticatedRequest, res: Response) {
|
||||||
|
try {
|
||||||
|
const result = await DbTypeCategoryService.initializeDefaultCategories();
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("기본 카테고리 초기화 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "기본 카테고리 초기화 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,49 @@
|
||||||
|
import { Router } from "express";
|
||||||
|
import { DbTypeCategoryController } from "../controllers/dbTypeCategoryController";
|
||||||
|
import { authenticateToken } from "../middleware/authMiddleware";
|
||||||
|
|
||||||
|
const router = Router();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* GET /api/db-type-categories
|
||||||
|
* 모든 DB 타입 카테고리 조회
|
||||||
|
*/
|
||||||
|
router.get("/", authenticateToken, DbTypeCategoryController.getAllCategories);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* GET /api/db-type-categories/stats/connections
|
||||||
|
* DB 타입별 연결 통계 조회
|
||||||
|
*/
|
||||||
|
router.get("/stats/connections", authenticateToken, DbTypeCategoryController.getConnectionStatsByType);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* GET /api/db-type-categories/:typeCode
|
||||||
|
* 특정 DB 타입 카테고리 조회
|
||||||
|
*/
|
||||||
|
router.get("/:typeCode", authenticateToken, DbTypeCategoryController.getCategoryByTypeCode);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* POST /api/db-type-categories
|
||||||
|
* DB 타입 카테고리 생성
|
||||||
|
*/
|
||||||
|
router.post("/", authenticateToken, DbTypeCategoryController.createCategory);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* POST /api/db-type-categories/initialize
|
||||||
|
* 기본 DB 타입 카테고리 초기화
|
||||||
|
*/
|
||||||
|
router.post("/initialize", authenticateToken, DbTypeCategoryController.initializeDefaultCategories);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* PUT /api/db-type-categories/:typeCode
|
||||||
|
* DB 타입 카테고리 수정
|
||||||
|
*/
|
||||||
|
router.put("/:typeCode", authenticateToken, DbTypeCategoryController.updateCategory);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DELETE /api/db-type-categories/:typeCode
|
||||||
|
* DB 타입 카테고리 삭제 (비활성화)
|
||||||
|
*/
|
||||||
|
router.delete("/:typeCode", authenticateToken, DbTypeCategoryController.deleteCategory);
|
||||||
|
|
||||||
|
export default router;
|
||||||
|
|
@ -85,6 +85,46 @@ router.get(
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* GET /api/external-db-connections/grouped
|
||||||
|
* DB 타입별로 그룹화된 외부 DB 연결 목록 조회
|
||||||
|
*/
|
||||||
|
router.get(
|
||||||
|
"/grouped",
|
||||||
|
authenticateToken,
|
||||||
|
async (req: AuthenticatedRequest, res: Response) => {
|
||||||
|
try {
|
||||||
|
const filter: ExternalDbConnectionFilter = {
|
||||||
|
db_type: req.query.db_type as string,
|
||||||
|
is_active: req.query.is_active as string,
|
||||||
|
company_code: req.query.company_code as string,
|
||||||
|
search: req.query.search as string,
|
||||||
|
};
|
||||||
|
|
||||||
|
// 빈 값 제거
|
||||||
|
Object.keys(filter).forEach((key) => {
|
||||||
|
if (!filter[key as keyof ExternalDbConnectionFilter]) {
|
||||||
|
delete filter[key as keyof ExternalDbConnectionFilter];
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
const result = await ExternalDbConnectionService.getConnectionsGroupedByType(filter);
|
||||||
|
|
||||||
|
if (result.success) {
|
||||||
|
return res.status(200).json(result);
|
||||||
|
} else {
|
||||||
|
return res.status(400).json(result);
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("그룹화된 외부 DB 연결 목록 조회 오류:", error);
|
||||||
|
return res.status(500).json({
|
||||||
|
success: false,
|
||||||
|
message: "그룹화된 연결 목록 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* GET /api/external-db-connections/:id
|
* GET /api/external-db-connections/:id
|
||||||
|
|
@ -264,6 +304,8 @@ router.post(
|
||||||
|
|
||||||
// 테스트용 비밀번호가 제공된 경우 사용
|
// 테스트용 비밀번호가 제공된 경우 사용
|
||||||
const testData = req.body.password ? { password: req.body.password } : undefined;
|
const testData = req.body.password ? { password: req.body.password } : undefined;
|
||||||
|
console.log(`🔍 [API] 연결테스트 요청 - ID: ${id}, 비밀번호 제공됨: ${!!req.body.password}`);
|
||||||
|
|
||||||
const result = await ExternalDbConnectionService.testConnectionById(id, testData);
|
const result = await ExternalDbConnectionService.testConnectionById(id, testData);
|
||||||
|
|
||||||
return res.status(200).json({
|
return res.status(200).json({
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,320 @@
|
||||||
|
import { PrismaClient } from "@prisma/client";
|
||||||
|
|
||||||
|
const prisma = new PrismaClient();
|
||||||
|
|
||||||
|
export interface DbTypeCategory {
|
||||||
|
type_code: string;
|
||||||
|
display_name: string;
|
||||||
|
icon?: string | null;
|
||||||
|
color?: string | null;
|
||||||
|
sort_order?: number | null;
|
||||||
|
is_active: boolean;
|
||||||
|
created_at: Date;
|
||||||
|
updated_at: Date;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface CreateDbTypeCategoryRequest {
|
||||||
|
type_code: string;
|
||||||
|
display_name: string;
|
||||||
|
icon?: string;
|
||||||
|
color?: string;
|
||||||
|
sort_order?: number;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface UpdateDbTypeCategoryRequest {
|
||||||
|
display_name?: string;
|
||||||
|
icon?: string;
|
||||||
|
color?: string;
|
||||||
|
sort_order?: number;
|
||||||
|
is_active?: boolean;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface ApiResponse<T> {
|
||||||
|
success: boolean;
|
||||||
|
data?: T;
|
||||||
|
message: string;
|
||||||
|
error?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export class DbTypeCategoryService {
|
||||||
|
/**
|
||||||
|
* 모든 DB 타입 카테고리 조회
|
||||||
|
*/
|
||||||
|
static async getAllCategories(): Promise<ApiResponse<DbTypeCategory[]>> {
|
||||||
|
try {
|
||||||
|
const categories = await prisma.db_type_categories.findMany({
|
||||||
|
where: { is_active: true },
|
||||||
|
orderBy: [
|
||||||
|
{ sort_order: 'asc' },
|
||||||
|
{ display_name: 'asc' }
|
||||||
|
]
|
||||||
|
});
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
data: categories,
|
||||||
|
message: "DB 타입 카테고리 목록을 조회했습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 조회 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 특정 DB 타입 카테고리 조회
|
||||||
|
*/
|
||||||
|
static async getCategoryByTypeCode(typeCode: string): Promise<ApiResponse<DbTypeCategory>> {
|
||||||
|
try {
|
||||||
|
const category = await prisma.db_type_categories.findUnique({
|
||||||
|
where: { type_code: typeCode }
|
||||||
|
});
|
||||||
|
|
||||||
|
if (!category) {
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "해당 DB 타입 카테고리를 찾을 수 없습니다."
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
data: category,
|
||||||
|
message: "DB 타입 카테고리를 조회했습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 조회 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DB 타입 카테고리 생성
|
||||||
|
*/
|
||||||
|
static async createCategory(data: CreateDbTypeCategoryRequest): Promise<ApiResponse<DbTypeCategory>> {
|
||||||
|
try {
|
||||||
|
// 중복 체크
|
||||||
|
const existing = await prisma.db_type_categories.findUnique({
|
||||||
|
where: { type_code: data.type_code }
|
||||||
|
});
|
||||||
|
|
||||||
|
if (existing) {
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "이미 존재하는 DB 타입 코드입니다."
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
const category = await prisma.db_type_categories.create({
|
||||||
|
data: {
|
||||||
|
type_code: data.type_code,
|
||||||
|
display_name: data.display_name,
|
||||||
|
icon: data.icon,
|
||||||
|
color: data.color,
|
||||||
|
sort_order: data.sort_order || 0
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
data: category,
|
||||||
|
message: "DB 타입 카테고리가 생성되었습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 생성 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 생성 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DB 타입 카테고리 수정
|
||||||
|
*/
|
||||||
|
static async updateCategory(typeCode: string, data: UpdateDbTypeCategoryRequest): Promise<ApiResponse<DbTypeCategory>> {
|
||||||
|
try {
|
||||||
|
const category = await prisma.db_type_categories.update({
|
||||||
|
where: { type_code: typeCode },
|
||||||
|
data: {
|
||||||
|
display_name: data.display_name,
|
||||||
|
icon: data.icon,
|
||||||
|
color: data.color,
|
||||||
|
sort_order: data.sort_order,
|
||||||
|
is_active: data.is_active,
|
||||||
|
updated_at: new Date()
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
data: category,
|
||||||
|
message: "DB 타입 카테고리가 수정되었습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 수정 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 수정 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DB 타입 카테고리 삭제 (비활성화)
|
||||||
|
*/
|
||||||
|
static async deleteCategory(typeCode: string): Promise<ApiResponse<void>> {
|
||||||
|
try {
|
||||||
|
// 해당 타입을 사용하는 연결이 있는지 확인
|
||||||
|
const connectionsCount = await prisma.external_db_connections.count({
|
||||||
|
where: {
|
||||||
|
db_type: typeCode,
|
||||||
|
is_active: "Y"
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
if (connectionsCount > 0) {
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: `해당 DB 타입을 사용하는 연결이 ${connectionsCount}개 있어 삭제할 수 없습니다.`
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
await prisma.db_type_categories.update({
|
||||||
|
where: { type_code: typeCode },
|
||||||
|
data: {
|
||||||
|
is_active: false,
|
||||||
|
updated_at: new Date()
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
message: "DB 타입 카테고리가 삭제되었습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입 카테고리 삭제 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입 카테고리 삭제 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DB 타입별 연결 통계 조회
|
||||||
|
*/
|
||||||
|
static async getConnectionStatsByType(): Promise<ApiResponse<any[]>> {
|
||||||
|
try {
|
||||||
|
const stats = await prisma.external_db_connections.groupBy({
|
||||||
|
by: ['db_type'],
|
||||||
|
where: { is_active: "Y" },
|
||||||
|
_count: {
|
||||||
|
id: true
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
// 카테고리 정보와 함께 반환
|
||||||
|
const categories = await prisma.db_type_categories.findMany({
|
||||||
|
where: { is_active: true }
|
||||||
|
});
|
||||||
|
|
||||||
|
const result = categories.map(category => {
|
||||||
|
const stat = stats.find(s => s.db_type === category.type_code);
|
||||||
|
return {
|
||||||
|
...category,
|
||||||
|
connection_count: stat?._count.id || 0
|
||||||
|
};
|
||||||
|
});
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
data: result,
|
||||||
|
message: "DB 타입별 연결 통계를 조회했습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("DB 타입별 통계 조회 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "DB 타입별 통계 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 기본 DB 타입 카테고리 초기화
|
||||||
|
*/
|
||||||
|
static async initializeDefaultCategories(): Promise<ApiResponse<void>> {
|
||||||
|
try {
|
||||||
|
const defaultCategories = [
|
||||||
|
{
|
||||||
|
type_code: 'postgresql',
|
||||||
|
display_name: 'PostgreSQL',
|
||||||
|
icon: 'postgresql',
|
||||||
|
color: '#336791',
|
||||||
|
sort_order: 1
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type_code: 'oracle',
|
||||||
|
display_name: 'Oracle',
|
||||||
|
icon: 'oracle',
|
||||||
|
color: '#F80000',
|
||||||
|
sort_order: 2
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type_code: 'mysql',
|
||||||
|
display_name: 'MySQL',
|
||||||
|
icon: 'mysql',
|
||||||
|
color: '#4479A1',
|
||||||
|
sort_order: 3
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type_code: 'mariadb',
|
||||||
|
display_name: 'MariaDB',
|
||||||
|
icon: 'mariadb',
|
||||||
|
color: '#003545',
|
||||||
|
sort_order: 4
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type_code: 'mssql',
|
||||||
|
display_name: 'SQL Server',
|
||||||
|
icon: 'mssql',
|
||||||
|
color: '#CC2927',
|
||||||
|
sort_order: 5
|
||||||
|
}
|
||||||
|
];
|
||||||
|
|
||||||
|
for (const category of defaultCategories) {
|
||||||
|
await prisma.db_type_categories.upsert({
|
||||||
|
where: { type_code: category.type_code },
|
||||||
|
update: {},
|
||||||
|
create: category
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
message: "기본 DB 타입 카테고리가 초기화되었습니다."
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("기본 카테고리 초기화 오류:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "기본 카테고리 초기화 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -81,6 +81,93 @@ export class ExternalDbConnectionService {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DB 타입별로 그룹화된 외부 DB 연결 목록 조회
|
||||||
|
*/
|
||||||
|
static async getConnectionsGroupedByType(
|
||||||
|
filter: ExternalDbConnectionFilter = {}
|
||||||
|
): Promise<ApiResponse<Record<string, ExternalDbConnection[]>>> {
|
||||||
|
try {
|
||||||
|
// 기본 연결 목록 조회
|
||||||
|
const connectionsResult = await this.getConnections(filter);
|
||||||
|
|
||||||
|
if (!connectionsResult.success || !connectionsResult.data) {
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "연결 목록 조회에 실패했습니다."
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
// DB 타입 카테고리 정보 조회
|
||||||
|
const categories = await prisma.db_type_categories.findMany({
|
||||||
|
where: { is_active: true },
|
||||||
|
orderBy: [
|
||||||
|
{ sort_order: 'asc' },
|
||||||
|
{ display_name: 'asc' }
|
||||||
|
]
|
||||||
|
});
|
||||||
|
|
||||||
|
// DB 타입별로 그룹화
|
||||||
|
const groupedConnections: Record<string, any> = {};
|
||||||
|
|
||||||
|
// 카테고리 정보를 포함한 그룹 초기화
|
||||||
|
categories.forEach((category: any) => {
|
||||||
|
groupedConnections[category.type_code] = {
|
||||||
|
category: {
|
||||||
|
type_code: category.type_code,
|
||||||
|
display_name: category.display_name,
|
||||||
|
icon: category.icon,
|
||||||
|
color: category.color,
|
||||||
|
sort_order: category.sort_order
|
||||||
|
},
|
||||||
|
connections: []
|
||||||
|
};
|
||||||
|
});
|
||||||
|
|
||||||
|
// 연결을 해당 타입 그룹에 배치
|
||||||
|
connectionsResult.data.forEach(connection => {
|
||||||
|
if (groupedConnections[connection.db_type]) {
|
||||||
|
groupedConnections[connection.db_type].connections.push(connection);
|
||||||
|
} else {
|
||||||
|
// 카테고리에 없는 DB 타입인 경우 기타 그룹에 추가
|
||||||
|
if (!groupedConnections['other']) {
|
||||||
|
groupedConnections['other'] = {
|
||||||
|
category: {
|
||||||
|
type_code: 'other',
|
||||||
|
display_name: '기타',
|
||||||
|
icon: 'database',
|
||||||
|
color: '#6B7280',
|
||||||
|
sort_order: 999
|
||||||
|
},
|
||||||
|
connections: []
|
||||||
|
};
|
||||||
|
}
|
||||||
|
groupedConnections['other'].connections.push(connection);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
// 연결이 없는 빈 그룹 제거
|
||||||
|
Object.keys(groupedConnections).forEach(key => {
|
||||||
|
if (groupedConnections[key].connections.length === 0) {
|
||||||
|
delete groupedConnections[key];
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
data: groupedConnections,
|
||||||
|
message: `DB 타입별로 그룹화된 연결 목록을 조회했습니다.`
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
console.error("그룹화된 연결 목록 조회 실패:", error);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: "그룹화된 연결 목록 조회 중 오류가 발생했습니다.",
|
||||||
|
error: error instanceof Error ? error.message : "알 수 없는 오류"
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 특정 외부 DB 연결 조회
|
* 특정 외부 DB 연결 조회
|
||||||
*/
|
*/
|
||||||
|
|
@ -371,8 +458,10 @@ export class ExternalDbConnectionService {
|
||||||
let password: string | null;
|
let password: string | null;
|
||||||
if (testData?.password) {
|
if (testData?.password) {
|
||||||
password = testData.password;
|
password = testData.password;
|
||||||
|
console.log(`🔍 [연결테스트] 새로 입력된 비밀번호 사용: ${password.substring(0, 3)}***`);
|
||||||
} else {
|
} else {
|
||||||
password = await this.getDecryptedPassword(id);
|
password = await this.getDecryptedPassword(id);
|
||||||
|
console.log(`🔍 [연결테스트] 저장된 비밀번호 사용: ${password ? password.substring(0, 3) + '***' : 'null'}`);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!password) {
|
if (!password) {
|
||||||
|
|
@ -398,9 +487,34 @@ export class ExternalDbConnectionService {
|
||||||
ssl: connection.ssl_enabled === "Y" ? { rejectUnauthorized: false } : false
|
ssl: connection.ssl_enabled === "Y" ? { rejectUnauthorized: false } : false
|
||||||
};
|
};
|
||||||
|
|
||||||
// DatabaseConnectorFactory를 통한 연결 테스트
|
// 연결 테스트용 임시 커넥터 생성 (캐시 사용하지 않음)
|
||||||
const connector = await DatabaseConnectorFactory.createConnector(connection.db_type, config, id);
|
let connector: any;
|
||||||
|
switch (connection.db_type.toLowerCase()) {
|
||||||
|
case 'postgresql':
|
||||||
|
const { PostgreSQLConnector } = await import('../database/PostgreSQLConnector');
|
||||||
|
connector = new PostgreSQLConnector(config);
|
||||||
|
break;
|
||||||
|
case 'oracle':
|
||||||
|
const { OracleConnector } = await import('../database/OracleConnector');
|
||||||
|
connector = new OracleConnector(config);
|
||||||
|
break;
|
||||||
|
case 'mariadb':
|
||||||
|
case 'mysql':
|
||||||
|
const { MariaDBConnector } = await import('../database/MariaDBConnector');
|
||||||
|
connector = new MariaDBConnector(config);
|
||||||
|
break;
|
||||||
|
case 'mssql':
|
||||||
|
const { MSSQLConnector } = await import('../database/MSSQLConnector');
|
||||||
|
connector = new MSSQLConnector(config);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
throw new Error(`지원하지 않는 데이터베이스 타입: ${connection.db_type}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
console.log(`🔍 [연결테스트] 새 커넥터로 DB 연결 시도 - Host: ${config.host}, DB: ${config.database}, User: ${config.user}`);
|
||||||
|
|
||||||
const testResult = await connector.testConnection();
|
const testResult = await connector.testConnection();
|
||||||
|
console.log(`🔍 [연결테스트] 결과 - Success: ${testResult.success}, Message: ${testResult.message}`);
|
||||||
|
|
||||||
return {
|
return {
|
||||||
success: testResult.success,
|
success: testResult.success,
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue