diff --git a/docs/migration/development/data-sync/01_part_mng_sync.sql b/docs/migration/development/data-sync/01_part_mng_sync.sql new file mode 100644 index 00000000..64a01c30 --- /dev/null +++ b/docs/migration/development/data-sync/01_part_mng_sync.sql @@ -0,0 +1,67 @@ +BEGIN; + +CREATE TEMP TABLE part_mng_sync_stage ( + part_no varchar, + material varchar, + heat_treatment_hardness varchar, + heat_treatment_method varchar, + surface_treatment varchar, + maker varchar, + part_type varchar, + spec varchar, + acctfg varchar, + odrfg varchar, + unit_dc varchar, + unitmang_dc varchar, + unitchng_nb varchar, + lot_fg varchar, + use_yn varchar, + qc_fg varchar, + setitem_fg varchar, + req_fg varchar, + unit_length varchar, + unit_qty varchar +); + +\copy part_mng_sync_stage FROM '/tmp/part_mng_sync.csv' WITH CSV HEADER + +UPDATE part_mng P SET + material = NULLIF(S.material, ''), + heat_treatment_hardness = NULLIF(S.heat_treatment_hardness, ''), + heat_treatment_method = NULLIF(S.heat_treatment_method, ''), + surface_treatment = NULLIF(S.surface_treatment, ''), + maker = NULLIF(S.maker, ''), + part_type = NULLIF(S.part_type, ''), + spec = NULLIF(S.spec, ''), + acctfg = NULLIF(S.acctfg, ''), + odrfg = NULLIF(S.odrfg, ''), + unit_dc = NULLIF(S.unit_dc, ''), + unitmang_dc = NULLIF(S.unitmang_dc, ''), + unitchng_nb = CASE WHEN S.unitchng_nb = '' THEN P.unitchng_nb ELSE S.unitchng_nb::numeric END, + lot_fg = NULLIF(S.lot_fg, ''), + use_yn = NULLIF(S.use_yn, ''), + qc_fg = NULLIF(S.qc_fg, ''), + setitem_fg = NULLIF(S.setitem_fg, ''), + req_fg = NULLIF(S.req_fg, ''), + unit_length = NULLIF(S.unit_length, ''), + unit_qty = NULLIF(S.unit_qty, ''), + is_last = COALESCE(P.is_last, '1'), + edit_date = NOW() +FROM part_mng_sync_stage S +WHERE P.part_no = S.part_no; + +COMMIT; + +SELECT + COUNT(*) AS total, + COUNT(NULLIF(material,'')) AS material_filled, + COUNT(NULLIF(acctfg,'')) AS acctfg_filled, + COUNT(NULLIF(unit_dc,'')) AS unit_dc_filled, + COUNT(NULLIF(part_type,'')) AS part_type_filled, + COUNT(NULLIF(spec,'')) AS spec_filled, + COUNT(NULLIF(maker,'')) AS maker_filled, + COUNT(NULLIF(is_last,'')) AS is_last_filled +FROM part_mng; + +SELECT part_no, material, spec, part_type, acctfg, odrfg, unit_dc, unitmang_dc, unitchng_nb, lot_fg, use_yn, qc_fg, setitem_fg, req_fg + FROM part_mng WHERE part_no = '000AN003000'; diff --git a/docs/migration/development/data-sync/README.md b/docs/migration/development/data-sync/README.md new file mode 100644 index 00000000..6d400fd7 --- /dev/null +++ b/docs/migration/development/data-sync/README.md @@ -0,0 +1,69 @@ +# 개발관리 데이터 동기화 스크립트 + +운영DB(`211.115.91.141:11133/waceplm`) → RPS DB(`11134/vexplor_rps`)로 마이그레이션 시 누락된 데이터를 part_no 매칭으로 채워 넣는 1회성 스크립트 모음. + +테이블 DDL/스키마는 [../ddl-extracted/](../ddl-extracted/)에서 별도 관리. 본 디렉토리는 **데이터 row 동기화** 전용. + +--- + +## 01_part_mng_sync.sql + +**대상**: `part_mng` 8,176건 — 운영DB에서 채워져 있던 컬럼이 RPS 마이그레이션 시 누락된 사례. + +**왜 필요했나**: 2026-05-12 PART 상세 다이얼로그 검증 중 발견. 품번/품명만 표시되고 재료/규격/계정구분/조달구분/재고단위/관리단위/환산수량/LOT구분/사용여부/검사여부/SET품여부/의뢰여부 등 거의 모든 컬럼이 NULL. 운영DB 같은 part_no는 정상적으로 채워져 있어서 마이그레이션 누락이 원인. + +**동기화 대상 컬럼 20개**: +- 재료/형상: `material` / `heat_treatment_hardness` / `heat_treatment_method` / `surface_treatment` +- 기본: `maker` / `part_type` / `spec` +- ERP 분류: `acctfg` / `odrfg` / `unit_dc` / `unitmang_dc` / `unitchng_nb` +- Y/N: `lot_fg` / `use_yn` / `qc_fg` / `setitem_fg` / `req_fg` +- 단위: `unit_length` / `unit_qty` +- 상태: `is_last` (마이그레이션 시 NULL이라 PART_MNG.is_last='1' 조건의 모든 매퍼 쿼리가 0건 반환되던 부수 문제도 함께 수정) + +**실행 절차**: + +```bash +# 1) 운영DB → CSV export (is_last='1' 인 8,243건) +PGPASSWORD='waceplm0909!!' psql -h 211.115.91.141 -p 11133 -U postgres -d waceplm -c "\copy (SELECT part_no, COALESCE(material,''), COALESCE(heat_treatment_hardness,''), ..., COALESCE(unit_qty::text,'') FROM part_mng WHERE is_last='1') TO '/tmp/part_mng_sync.csv' WITH CSV HEADER" + +# 2) RPS 에 import + UPDATE FROM JOIN +PGPASSWORD='vexplor0909!!' psql -h 211.115.91.141 -p 11134 -U postgres -d vexplor_rps -f 01_part_mng_sync.sql +``` + +**결과 (2026-05-12 실행)**: + +| 컬럼 | 동기화 전 | 동기화 후 | +|---|---:|---:| +| material | 0 | 301 | +| acctfg | 0 | 8,172 | +| unit_dc | 0 | 8,176 | +| part_type | 639 | 703 | +| spec | 0 | 7,466 | +| is_last | 0 | 8,176 | +| (전체) | 8,176 | 8,176 | + +**미동기화 (의도적 보류)**: 운영DB에만 있는 67건 (운영 8,243 - RPS 8,176). part_no 자체가 RPS 에 미존재. 신규 INSERT 별 작업 필요. + +**검증 SQL**: + +```sql +-- 채움 비율 +SELECT + COUNT(*) AS total, + COUNT(NULLIF(material,'')) AS material_filled, + COUNT(NULLIF(acctfg,'')) AS acctfg_filled, + COUNT(NULLIF(unit_dc,'')) AS unit_dc_filled, + COUNT(NULLIF(part_type,'')) AS part_type_filled, + COUNT(NULLIF(spec,'')) AS spec_filled, + COUNT(NULLIF(is_last,'')) AS is_last_filled +FROM part_mng; + +-- 샘플 행 (운영 스크린샷과 비교) +SELECT part_no, material, spec, part_type, acctfg, odrfg, unit_dc, unitmang_dc, + unitchng_nb, lot_fg, use_yn, qc_fg, setitem_fg, req_fg + FROM part_mng WHERE part_no = '000AN003000'; +``` + +**1:1 정합성**: 운영DB의 컬럼 값을 그대로 복사. NULL 인 운영 컬럼은 RPS 도 NULL 유지 (덮어쓰기 안 함). `unitchng_nb` 만 numeric 캐스팅. + +**재실행 안전**: idempotent — 같은 데이터로 다시 UPDATE 만 일어남.