Skip to content

[fix/migration]: 마이그레이션 파일 기존 데이터 보존되도록 수정 #36

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
joojae02 merged 1 commit into from
Mar 19, 2026
Merged

[fix/migration]: 마이그레이션 파일 기존 데이터 보존되도록 수정 #36

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
143 changes: 106 additions & 37 deletions src/migrations/1773932177809-ChangeHazardTypeToEnum.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ export class ChangeHazardTypeToEnum1773932177809 implements MigrationInterface {
name = 'ChangeHazardTypeToEnum1773932177809'

public async up(queryRunner: QueryRunner): Promise<void> {
// 1. FK / index / unique 제약 제거
await queryRunner.query(`ALTER TABLE "likes" DROP CONSTRAINT "FK_likes_markerId"`);
await queryRunner.query(`ALTER TABLE "likes" DROP CONSTRAINT "FK_likes_userId"`);
await queryRunner.query(`ALTER TABLE "images" DROP CONSTRAINT "FK_images_reportId"`);
Expand All @@ -14,32 +15,96 @@ export class ChangeHazardTypeToEnum1773932177809 implements MigrationInterface {
await queryRunner.query(`ALTER TABLE "comments" DROP CONSTRAINT "FK_comments_userId"`);
await queryRunner.query(`DROP INDEX "public"."IDX_markers_location"`);
await queryRunner.query(`ALTER TABLE "likes" DROP CONSTRAINT "UQ_likes_markerId_userId"`);

// 2. safety_mungo_reports PK / 컬럼 변경
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" DROP CONSTRAINT "PK_safety_mungo_reports"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" DROP COLUMN "externalReportId"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" DROP COLUMN "occurenceDate"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" ADD "id" character varying NOT NULL`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" RENAME COLUMN "externalReportId" TO "id"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" ADD CONSTRAINT "PK_e87234aaed949f9e93cbe7235d5" PRIMARY KEY ("id")`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" ADD "occurrenceDate" date`);
await queryRunner.query(`ALTER TABLE "reports" DROP COLUMN "hazardType"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" RENAME COLUMN "occurenceDate" TO "occurrenceDate"`);

// 3. hazardType: VARCHAR → ENUM (데이터 보존)
await queryRunner.query(`CREATE TYPE "public"."reports_hazardtype_enum" AS ENUM('FIRE', 'FLOOD', 'LANDSLIDE', 'SINKHOLE', 'ROAD_DAMAGE', 'COLLAPSE', 'BUILDING_DAMAGE', 'CHEMICAL', 'TRAFFIC', 'CONSTRUCTION', 'OTHER')`);
await queryRunner.query(`ALTER TABLE "reports" ADD "hazardType" "public"."reports_hazardtype_enum" NOT NULL`);

// 기존 한국어 값을 enum 값으로 매핑
await queryRunner.query(`
UPDATE "reports" SET "hazardType" = CASE "hazardType"
WHEN '화재' THEN 'FIRE'
WHEN '침수' THEN 'FLOOD'
WHEN '침수위험' THEN 'FLOOD'
WHEN '산사태' THEN 'LANDSLIDE'
WHEN '낙석위험' THEN 'LANDSLIDE'
WHEN '싱크홀' THEN 'SINKHOLE'
WHEN '도로파손' THEN 'ROAD_DAMAGE'
WHEN '도로 파손' THEN 'ROAD_DAMAGE'
WHEN '보도블록파손' THEN 'ROAD_DAMAGE'
WHEN '미끄러운도로' THEN 'ROAD_DAMAGE'
WHEN '붕괴' THEN 'COLLAPSE'
WHEN '건물 손상' THEN 'BUILDING_DAMAGE'
WHEN '화학 사고' THEN 'CHEMICAL'
WHEN '교통 사고' THEN 'TRAFFIC'
WHEN '신호등고장' THEN 'TRAFFIC'
WHEN '가드레일파손' THEN 'TRAFFIC'
WHEN '불법주정차' THEN 'TRAFFIC'
WHEN '공사 중' THEN 'CONSTRUCTION'
WHEN '공사구간' THEN 'CONSTRUCTION'
WHEN '가로등고장' THEN 'OTHER'
ELSE 'OTHER'
END
WHERE "hazardType" NOT IN ('FIRE', 'FLOOD', 'LANDSLIDE', 'SINKHOLE', 'ROAD_DAMAGE', 'COLLAPSE', 'BUILDING_DAMAGE', 'CHEMICAL', 'TRAFFIC', 'CONSTRUCTION', 'OTHER')
`);

await queryRunner.query(`ALTER TABLE "reports" ALTER COLUMN "hazardType" TYPE "public"."reports_hazardtype_enum" USING "hazardType"::"public"."reports_hazardtype_enum"`);

// 4. markers hazardType 동일 처리
await queryRunner.query(`CREATE TYPE "public"."markers_hazardtype_enum" AS ENUM('FIRE', 'FLOOD', 'LANDSLIDE', 'SINKHOLE', 'ROAD_DAMAGE', 'COLLAPSE', 'BUILDING_DAMAGE', 'CHEMICAL', 'TRAFFIC', 'CONSTRUCTION', 'OTHER')`);

await queryRunner.query(`
UPDATE "markers" SET "hazardType" = CASE "hazardType"
WHEN '화재' THEN 'FIRE'
WHEN '침수' THEN 'FLOOD'
WHEN '침수위험' THEN 'FLOOD'
WHEN '산사태' THEN 'LANDSLIDE'
WHEN '낙석위험' THEN 'LANDSLIDE'
WHEN '싱크홀' THEN 'SINKHOLE'
WHEN '도로파손' THEN 'ROAD_DAMAGE'
WHEN '도로 파손' THEN 'ROAD_DAMAGE'
WHEN '보도블록파손' THEN 'ROAD_DAMAGE'
WHEN '미끄러운도로' THEN 'ROAD_DAMAGE'
WHEN '붕괴' THEN 'COLLAPSE'
WHEN '건물 손상' THEN 'BUILDING_DAMAGE'
WHEN '화학 사고' THEN 'CHEMICAL'
WHEN '교통 사고' THEN 'TRAFFIC'
WHEN '신호등고장' THEN 'TRAFFIC'
WHEN '가드레일파손' THEN 'TRAFFIC'
WHEN '불법주정차' THEN 'TRAFFIC'
WHEN '공사 중' THEN 'CONSTRUCTION'
WHEN '공사구간' THEN 'CONSTRUCTION'
WHEN '가로등고장' THEN 'OTHER'
ELSE 'OTHER'
END
WHERE "hazardType" NOT IN ('FIRE', 'FLOOD', 'LANDSLIDE', 'SINKHOLE', 'ROAD_DAMAGE', 'COLLAPSE', 'BUILDING_DAMAGE', 'CHEMICAL', 'TRAFFIC', 'CONSTRUCTION', 'OTHER')
`);

await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "hazardType" TYPE "public"."markers_hazardtype_enum" USING "hazardType"::"public"."markers_hazardtype_enum"`);

// 5. hazardLevel enum 타입명 변경 (hazard_level → reports/markers 별도)
await queryRunner.query(`ALTER TYPE "public"."hazard_level" RENAME TO "hazard_level_old"`);
await queryRunner.query(`CREATE TYPE "public"."reports_hazardlevel_enum" AS ENUM('LOW', 'MEDIUM', 'HIGH')`);
await queryRunner.query(`ALTER TABLE "reports" ALTER COLUMN "hazardLevel" TYPE "public"."reports_hazardlevel_enum" USING "hazardLevel"::"text"::"public"."reports_hazardlevel_enum"`);
await queryRunner.query(`CREATE TYPE "public"."markers_hazardlevel_enum" AS ENUM('LOW', 'MEDIUM', 'HIGH')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "hazardLevel" TYPE "public"."markers_hazardlevel_enum" USING "hazardLevel"::"text"::"public"."markers_hazardlevel_enum"`);
await queryRunner.query(`DROP TYPE "public"."hazard_level_old"`);

// 6. marker_source enum 타입명 변경
await queryRunner.query(`ALTER TYPE "public"."marker_source" RENAME TO "marker_source_old"`);
await queryRunner.query(`CREATE TYPE "public"."markers_source_enum" AS ENUM('report', 'safety_mungo_report')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "source" TYPE "public"."markers_source_enum" USING "source"::"text"::"public"."markers_source_enum"`);
await queryRunner.query(`DROP TYPE "public"."marker_source_old"`);
await queryRunner.query(`ALTER TABLE "markers" DROP COLUMN "hazardType"`);
await queryRunner.query(`CREATE TYPE "public"."markers_hazardtype_enum" AS ENUM('FIRE', 'FLOOD', 'LANDSLIDE', 'SINKHOLE', 'ROAD_DAMAGE', 'COLLAPSE', 'BUILDING_DAMAGE', 'CHEMICAL', 'TRAFFIC', 'CONSTRUCTION', 'OTHER')`);
await queryRunner.query(`ALTER TABLE "markers" ADD "hazardType" "public"."markers_hazardtype_enum" NOT NULL`);
await queryRunner.query(`ALTER TYPE "public"."hazard_level" RENAME TO "hazard_level_old"`);
await queryRunner.query(`CREATE TYPE "public"."markers_hazardlevel_enum" AS ENUM('LOW', 'MEDIUM', 'HIGH')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "hazardLevel" TYPE "public"."markers_hazardlevel_enum" USING "hazardLevel"::"text"::"public"."markers_hazardlevel_enum"`);
await queryRunner.query(`DROP TYPE "public"."hazard_level_old"`);
await queryRunner.query(`ALTER TABLE "markers" DROP COLUMN "createdAt"`);
await queryRunner.query(`ALTER TABLE "markers" ADD "createdAt" TIMESTAMP NOT NULL DEFAULT now()`);

// 7. markers.createdAt TIMESTAMPTZ → TIMESTAMP
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "createdAt" TYPE TIMESTAMP USING "createdAt"::timestamp`);

// 8. FK / index / unique 재생성 (TypeORM 기본 네이밍)
await queryRunner.query(`ALTER TABLE "likes" ADD CONSTRAINT "UQ_4a3557bfa59a2f1f2268206f396" UNIQUE ("markerId", "userId")`);
await queryRunner.query(`ALTER TABLE "likes" ADD CONSTRAINT "FK_c3ac1525ed1ebf2b66f4f5cdde2" FOREIGN KEY ("markerId") REFERENCES "markers"("id") ON DELETE CASCADE ON UPDATE NO ACTION`);
await queryRunner.query(`ALTER TABLE "likes" ADD CONSTRAINT "FK_cfd8e81fac09d7339a32e57d904" FOREIGN KEY ("userId") REFERENCES "users"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`);
Expand All @@ -52,6 +117,7 @@ export class ChangeHazardTypeToEnum1773932177809 implements MigrationInterface {
}

public async down(queryRunner: QueryRunner): Promise<void> {
// FK / unique 제거
await queryRunner.query(`ALTER TABLE "comments" DROP CONSTRAINT "FK_7e8d7c49f218ebb14314fdb3749"`);
await queryRunner.query(`ALTER TABLE "comments" DROP CONSTRAINT "FK_dccbd961df7c3e58e1aa193c1f4"`);
await queryRunner.query(`ALTER TABLE "markers" DROP CONSTRAINT "FK_ebe551887d8c7bb1cc0c7b04895"`);
Expand All @@ -61,34 +127,37 @@ export class ChangeHazardTypeToEnum1773932177809 implements MigrationInterface {
await queryRunner.query(`ALTER TABLE "likes" DROP CONSTRAINT "FK_cfd8e81fac09d7339a32e57d904"`);
await queryRunner.query(`ALTER TABLE "likes" DROP CONSTRAINT "FK_c3ac1525ed1ebf2b66f4f5cdde2"`);
await queryRunner.query(`ALTER TABLE "likes" DROP CONSTRAINT "UQ_4a3557bfa59a2f1f2268206f396"`);
await queryRunner.query(`ALTER TABLE "markers" DROP COLUMN "createdAt"`);
await queryRunner.query(`ALTER TABLE "markers" ADD "createdAt" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now()`);
await queryRunner.query(`CREATE TYPE "public"."hazard_level_old" AS ENUM('LOW', 'MEDIUM', 'HIGH')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "hazardLevel" TYPE "public"."hazard_level_old" USING "hazardLevel"::"text"::"public"."hazard_level_old"`);
await queryRunner.query(`DROP TYPE "public"."markers_hazardlevel_enum"`);
await queryRunner.query(`ALTER TYPE "public"."hazard_level_old" RENAME TO "hazard_level"`);
await queryRunner.query(`ALTER TABLE "markers" DROP COLUMN "hazardType"`);
await queryRunner.query(`DROP TYPE "public"."markers_hazardtype_enum"`);
await queryRunner.query(`ALTER TABLE "markers" ADD "hazardType" character varying NOT NULL`);
await queryRunner.query(`CREATE TYPE "public"."marker_source_old" AS ENUM('report', 'safety_mungo_report')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "source" TYPE "public"."marker_source_old" USING "source"::"text"::"public"."marker_source_old"`);

// markers.createdAt → TIMESTAMPTZ 복원
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "createdAt" TYPE TIMESTAMPTZ USING "createdAt"::timestamptz`);

// marker_source 복원
await queryRunner.query(`CREATE TYPE "public"."marker_source" AS ENUM('report', 'safety_mungo_report')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "source" TYPE "public"."marker_source" USING "source"::"text"::"public"."marker_source"`);
await queryRunner.query(`DROP TYPE "public"."markers_source_enum"`);
await queryRunner.query(`ALTER TYPE "public"."marker_source_old" RENAME TO "marker_source"`);
await queryRunner.query(`CREATE TYPE "public"."hazard_level_old" AS ENUM('LOW', 'MEDIUM', 'HIGH')`);
await queryRunner.query(`ALTER TABLE "reports" ALTER COLUMN "hazardLevel" TYPE "public"."hazard_level_old" USING "hazardLevel"::"text"::"public"."hazard_level_old"`);

// hazardLevel 복원
await queryRunner.query(`CREATE TYPE "public"."hazard_level" AS ENUM('LOW', 'MEDIUM', 'HIGH')`);
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "hazardLevel" TYPE "public"."hazard_level" USING "hazardLevel"::"text"::"public"."hazard_level"`);
await queryRunner.query(`DROP TYPE "public"."markers_hazardlevel_enum"`);
await queryRunner.query(`ALTER TABLE "reports" ALTER COLUMN "hazardLevel" TYPE "public"."hazard_level" USING "hazardLevel"::"text"::"public"."hazard_level"`);
await queryRunner.query(`DROP TYPE "public"."reports_hazardlevel_enum"`);
await queryRunner.query(`ALTER TYPE "public"."hazard_level_old" RENAME TO "hazard_level"`);
await queryRunner.query(`ALTER TABLE "reports" DROP COLUMN "hazardType"`);

// hazardType → VARCHAR 복원
await queryRunner.query(`ALTER TABLE "markers" ALTER COLUMN "hazardType" TYPE VARCHAR USING "hazardType"::text`);
await queryRunner.query(`DROP TYPE "public"."markers_hazardtype_enum"`);
await queryRunner.query(`ALTER TABLE "reports" ALTER COLUMN "hazardType" TYPE VARCHAR USING "hazardType"::text`);
await queryRunner.query(`DROP TYPE "public"."reports_hazardtype_enum"`);
await queryRunner.query(`ALTER TABLE "reports" ADD "hazardType" character varying NOT NULL`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" DROP COLUMN "occurrenceDate"`);

// safety_mungo_reports 복원
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" RENAME COLUMN "occurrenceDate" TO "occurenceDate"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" DROP CONSTRAINT "PK_e87234aaed949f9e93cbe7235d5"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" DROP COLUMN "id"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" ADD "occurenceDate" date`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" ADD "externalReportId" character varying NOT NULL`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" RENAME COLUMN "id" TO "externalReportId"`);
await queryRunner.query(`ALTER TABLE "safety_mungo_reports" ADD CONSTRAINT "PK_safety_mungo_reports" PRIMARY KEY ("externalReportId")`);

// FK / index / unique 복원 (원래 이름)
await queryRunner.query(`ALTER TABLE "likes" ADD CONSTRAINT "UQ_likes_markerId_userId" UNIQUE ("markerId", "userId")`);
await queryRunner.query(`CREATE INDEX "IDX_markers_location" ON "markers" USING GiST ("location") `);
await queryRunner.query(`CREATE INDEX "IDX_markers_location" ON "markers" USING GiST ("location")`);
await queryRunner.query(`ALTER TABLE "comments" ADD CONSTRAINT "FK_comments_userId" FOREIGN KEY ("userId") REFERENCES "users"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`);
await queryRunner.query(`ALTER TABLE "comments" ADD CONSTRAINT "FK_comments_markerId" FOREIGN KEY ("markerId") REFERENCES "markers"("id") ON DELETE CASCADE ON UPDATE NO ACTION`);
await queryRunner.query(`ALTER TABLE "markers" ADD CONSTRAINT "FK_markers_safetyMungoReportId" FOREIGN KEY ("safetyMungoReportId") REFERENCES "safety_mungo_reports"("externalReportId") ON DELETE CASCADE ON UPDATE NO ACTION`);
Expand Down
Loading