Merge pull request #205 feature-NEWDWH2021-1011-SPECIALIST into develop
This commit is contained in:
野間亜希子
commit
455c012bad
@ -78,7 +78,7 @@ class ComDrSosietyMapper(UltmarcTableMapper):
|
||||
|
||||
def make_query(self):
|
||||
# 削除『修正区分がB(修正)かつ追加削除区分が1(退職)』
|
||||
if self.record.maint_flag == 'B' and self.record.specialst_maint_div == '1':
|
||||
if self.record.maint_flag == 'B' and self.record.cont_flag == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
|
||||
@ -646,7 +646,7 @@ class ComInstAttMapper(UltmarcTableMapper):
|
||||
dcf_dsf_inst_cd = :dcfdsf_inst_code
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
PHYSICAL_DELETE_QUERY = """\
|
||||
DELETE FROM
|
||||
src05.com_inst_att
|
||||
@ -665,7 +665,7 @@ class ComInstAttMapper(UltmarcTableMapper):
|
||||
self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()}
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.adddel_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -179,7 +179,7 @@ class ComPrefcMedBaseMapper(UltmarcTableMapper):
|
||||
dcf_dsf_inst_cd = :dcfdsf_inst_code
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
PHYSICAL_DELETE_QUERY = """\
|
||||
DELETE FROM
|
||||
src05.com_prefc_med_base
|
||||
@ -198,7 +198,7 @@ class ComPrefcMedBaseMapper(UltmarcTableMapper):
|
||||
self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()}
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.adddel_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -58,7 +58,7 @@ class ComPrefcMedDisTreatMapper(UltmarcTableMapper):
|
||||
treatment_code = :treatment_code
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
PHYSICAL_DELETE_QUERY = """\
|
||||
DELETE FROM
|
||||
src05.com_prefc_med_dis_treat
|
||||
@ -79,7 +79,7 @@ class ComPrefcMedDisTreatMapper(UltmarcTableMapper):
|
||||
self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()}
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.adddel_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -58,7 +58,7 @@ class ComPrefcMedEqupmentMapper(UltmarcTableMapper):
|
||||
equipment_code = :equipment_code
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
PHYSICAL_DELETE_QUERY = """\
|
||||
DELETE FROM
|
||||
src05.com_prefc_med_equpment
|
||||
@ -79,7 +79,7 @@ class ComPrefcMedEqupmentMapper(UltmarcTableMapper):
|
||||
self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()}
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.adddel_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -54,7 +54,7 @@ class ComPrefcMedSojournOpeMapper(UltmarcTableMapper):
|
||||
cos_surgery_code = :cos_surgery_code
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
PHYSICAL_DELETE_QUERY = """\
|
||||
DELETE FROM
|
||||
src05.com_prefc_med_sojourn_ope
|
||||
@ -75,7 +75,7 @@ class ComPrefcMedSojournOpeMapper(UltmarcTableMapper):
|
||||
self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()}
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.adddel_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -59,7 +59,7 @@ class ComPrefcMedSpOutpatMapper(UltmarcTableMapper):
|
||||
specialclinic_name = :specialclinic_name
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
PHYSICAL_DELETE_QUERY = """\
|
||||
DELETE FROM
|
||||
src05.com_prefc_med_sp_outpat
|
||||
@ -80,7 +80,7 @@ class ComPrefcMedSpOutpatMapper(UltmarcTableMapper):
|
||||
self.query_parameter = {**self.query_parameter, **self.record.to_sql_parameter()}
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
# 『修正区分がB(修正)かつ追加削除区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.adddel_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -15,17 +15,17 @@ class ComSpFieldMapper(UltmarcTableMapper):
|
||||
WHERE
|
||||
dcf_pcf_dr_cd = :dcf_pcf_dr_cd
|
||||
and
|
||||
specialst_cd = :specialst_cd
|
||||
specialist_cd = :specialist_cd
|
||||
"""
|
||||
# データ登録用SQL
|
||||
INSERT_QUERY = """\
|
||||
INSERT INTO src05.com_sp_field
|
||||
(
|
||||
dcf_pcf_dr_cd,
|
||||
specialst_cd,
|
||||
specialst_maint_div,
|
||||
specialst_flg,
|
||||
specialst_publsh_ymd,
|
||||
specialist_cd,
|
||||
specialist_maint_div,
|
||||
specialist_flg,
|
||||
specialist_publsh_ymd,
|
||||
ackn_med_flg,
|
||||
ackn_med_publsh_ymd,
|
||||
guide_med_flg,
|
||||
@ -39,10 +39,10 @@ class ComSpFieldMapper(UltmarcTableMapper):
|
||||
)
|
||||
VALUES (
|
||||
:dcf_pcf_dr_cd,
|
||||
:specialst_cd,
|
||||
:specialst_maint_div,
|
||||
:specialst_flg,
|
||||
:specialst_publsh_ymd,
|
||||
:specialist_cd,
|
||||
:specialist_maint_div,
|
||||
:specialist_flg,
|
||||
:specialist_publsh_ymd,
|
||||
:ackn_med_flg,
|
||||
:ackn_med_publsh_ymd,
|
||||
:guide_med_flg,
|
||||
@ -67,7 +67,7 @@ class ComSpFieldMapper(UltmarcTableMapper):
|
||||
WHERE
|
||||
dcf_pcf_dr_cd = :dcf_pcf_dr_cd
|
||||
and
|
||||
specialst_cd = :specialst_cd
|
||||
specialist_cd = :specialist_cd
|
||||
"""
|
||||
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
@ -77,7 +77,7 @@ class ComSpFieldMapper(UltmarcTableMapper):
|
||||
WHERE
|
||||
dcf_pcf_dr_cd = :dcf_pcf_dr_cd
|
||||
and
|
||||
specialst_cd = :specialst_cd
|
||||
specialist_cd = :specialist_cd
|
||||
"""
|
||||
record: ComSpField
|
||||
|
||||
@ -91,7 +91,7 @@ class ComSpFieldMapper(UltmarcTableMapper):
|
||||
|
||||
def make_query(self):
|
||||
# 『修正区分がB(修正)かつ専門医メンテナンス区分が1(退職)』の場合、物理削除
|
||||
if self.record.maint_flag == 'B' and self.record.specialst_maint_div == '1':
|
||||
if self.record.maint_flag == 'B' and self.record.specialist_maint_div == '1':
|
||||
self.queries.append(self.PHYSICAL_DELETE_QUERY)
|
||||
return
|
||||
|
||||
@ -109,15 +109,15 @@ class ComSpFieldMapper(UltmarcTableMapper):
|
||||
return self.INSERT_QUERY
|
||||
|
||||
# 存在する場合ではUpdate
|
||||
if len(self.record.specialst_maint_div) > 0:
|
||||
set_clauses.append('specialst_maint_div = :specialst_maint_div')
|
||||
if len(self.record.specialist_maint_div) > 0:
|
||||
set_clauses.append('specialist_maint_div = :specialist_maint_div')
|
||||
|
||||
if len(self.record.specialst_flg) > 0:
|
||||
set_clauses.append('specialst_flg = :specialst_flg')
|
||||
set_clauses.append('specialst_publsh_ymd = :specialst_publsh_ymd')
|
||||
if self.record.specialst_flg == '@':
|
||||
self.query_parameter['specialst_flg'] = None
|
||||
self.query_parameter['specialst_publsh_ymd'] = None
|
||||
if len(self.record.specialist_flg) > 0:
|
||||
set_clauses.append('specialist_flg = :specialist_flg')
|
||||
set_clauses.append('specialist_publsh_ymd = :specialist_publsh_ymd')
|
||||
if self.record.specialist_flg == '@':
|
||||
self.query_parameter['specialist_flg'] = None
|
||||
self.query_parameter['specialist_publsh_ymd'] = None
|
||||
|
||||
if len(self.record.ackn_med_flg) > 0:
|
||||
set_clauses.append('ackn_med_flg = :ackn_med_flg')
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.ultmarc_table_mapper import \
|
||||
UltmarcTableMapper
|
||||
from src.batch.ultmarc.utmp_tables.tables.com_specialst_license import ComSpecialstLicense
|
||||
from src.batch.ultmarc.utmp_tables.tables.com_specialist_license import ComSpecialistLicense
|
||||
|
||||
|
||||
class ComSpecialstLicenseMapper(UltmarcTableMapper):
|
||||
class ComSpecialistLicenseMapper(UltmarcTableMapper):
|
||||
"""レイアウト区分010: COM_専門医資格 登録処理"""
|
||||
|
||||
# レコード存在確認SQL
|
||||
@ -11,16 +11,16 @@ class ComSpecialstLicenseMapper(UltmarcTableMapper):
|
||||
SELECT
|
||||
COUNT(*) AS count_num
|
||||
FROM
|
||||
src05.com_specialst_license
|
||||
src05.com_specialist_license
|
||||
WHERE
|
||||
specialst_cd = :specialst_cd
|
||||
specialist_cd = :specialist_cd
|
||||
"""
|
||||
# データ登録用SQL
|
||||
INSERT_QUERY = """\
|
||||
INSERT INTO src05.com_specialst_license
|
||||
INSERT INTO src05.com_specialist_license
|
||||
(
|
||||
specialst_cd,
|
||||
specialst_licens_name,
|
||||
specialist_cd,
|
||||
specialist_license_name,
|
||||
regist_ymd,
|
||||
sys_regist_date,
|
||||
regist_prgm_id,
|
||||
@ -28,8 +28,8 @@ class ComSpecialstLicenseMapper(UltmarcTableMapper):
|
||||
update_prgm_id
|
||||
)
|
||||
VALUES (
|
||||
:specialst_cd,
|
||||
:specialst_licens_name,
|
||||
:specialist_cd,
|
||||
:specialist_license_name,
|
||||
:execute_date_str_ymd,
|
||||
:execute_datetime,
|
||||
:program_name,
|
||||
@ -41,31 +41,31 @@ class ComSpecialstLicenseMapper(UltmarcTableMapper):
|
||||
# 変更用SQL
|
||||
UPDATE_QUERY = """\
|
||||
UPDATE
|
||||
src05.com_specialst_license
|
||||
src05.com_specialist_license
|
||||
SET
|
||||
specialst_licens_name = :specialst_licens_name,
|
||||
specialist_license_name = :specialist_license_name,
|
||||
update_ymd = :execute_date_str_ymd,
|
||||
sys_update_date = :execute_datetime,
|
||||
update_prgm_id = :program_name
|
||||
WHERE
|
||||
specialst_cd = :specialst_cd
|
||||
specialist_cd = :specialist_cd
|
||||
"""
|
||||
|
||||
# 修正区分が「C(削除)」の場合の更新SQL
|
||||
LOGICAL_DELETE_QUERY = """\
|
||||
UPDATE
|
||||
src05.com_specialst_license
|
||||
src05.com_specialist_license
|
||||
SET
|
||||
delete_ymd = :execute_date_str_ymd,
|
||||
sys_update_date = :execute_date_str_ymd,
|
||||
update_prgm_id = :program_name
|
||||
WHERE
|
||||
specialst_cd = :specialst_cd
|
||||
specialist_cd = :specialist_cd
|
||||
"""
|
||||
record: ComSpecialstLicense
|
||||
record: ComSpecialistLicense
|
||||
|
||||
def __init__(self, record: list[str], db) -> None:
|
||||
super().__init__(record, db, ComSpecialstLicense)
|
||||
super().__init__(record, db, ComSpecialistLicense)
|
||||
program_name = __name__.split('.')[-1] # 当モジュール名(現行から変わっている)
|
||||
# モジュール名をクエリパラメータに設定
|
||||
self.query_parameter['program_name'] = program_name
|
||||
@ -8,7 +8,7 @@ class ComDrSosiety(UltmarcTable):
|
||||
dcf_dr_yobi: str # 個人コード(予備)
|
||||
maint_flag: str # 修正区分
|
||||
sosiety_cd: str # 学会コード
|
||||
specialst_maint_div: str # 予備／専門医メンテ区分
|
||||
cont_flag: str # 予備／所属学会メンテ区分
|
||||
sosiety_f: str # 学会年度
|
||||
dcf_pcf_dr_cd: str # DCFPCF医師コード
|
||||
|
||||
@ -21,7 +21,7 @@ class ComDrSosiety(UltmarcTable):
|
||||
self.dcf_dr_yobi = record[3].strip()
|
||||
self.maint_flag = record[4]
|
||||
self.sosiety_cd = record[5]
|
||||
self.specialst_maint_div = record[6]
|
||||
self.cont_flag = record[6]
|
||||
self.sosiety_f = record[9]
|
||||
|
||||
# DCFPCF医師コード(レコードID + 個人コード + 個人コード(予備))
|
||||
|
||||
@ -8,10 +8,10 @@ class ComSpField(UltmarcTable):
|
||||
dcf_dr_code: str # 個人コード
|
||||
dcf_dr_yobi: str # 個人コード(予備)
|
||||
maint_flag: str # 修正区分
|
||||
specialst_cd: str # 専門医コード
|
||||
specialst_maint_div: str # 予備／専門医メンテ区分
|
||||
specialst_flg: str # 専門医フラグ
|
||||
specialst_publsh_ymd: str # 専門医掲載年月日
|
||||
specialist_cd: str # 専門医コード
|
||||
specialist_maint_div: str # 予備／専門医メンテ区分
|
||||
specialist_flg: str # 専門医フラグ
|
||||
specialist_publsh_ymd: str # 専門医掲載年月日
|
||||
ackn_med_flg: str # 認定医フラグ
|
||||
ackn_med_publsh_ymd: str # 認定医掲載年月日
|
||||
guide_med_flg: str # 指導医フラグ
|
||||
@ -26,11 +26,11 @@ class ComSpField(UltmarcTable):
|
||||
self.dcf_dr_code = record[2].strip()
|
||||
self.dcf_dr_yobi = record[3].strip()
|
||||
self.maint_flag = record[4].strip()
|
||||
self.specialst_cd = record[5].strip()
|
||||
self.specialst_maint_div = record[6].strip()
|
||||
self.specialist_cd = record[5].strip()
|
||||
self.specialist_maint_div = record[6].strip()
|
||||
|
||||
self.specialst_flg = record[9].strip()
|
||||
self.specialst_publsh_ymd = record[10].strip()
|
||||
self.specialist_flg = record[9].strip()
|
||||
self.specialist_publsh_ymd = record[10].strip()
|
||||
|
||||
self.ackn_med_flg = record[11].strip()
|
||||
self.ackn_med_publsh_ymd = record[12].strip()
|
||||
|
||||
@ -1,14 +1,14 @@
|
||||
from src.batch.ultmarc.utmp_tables.tables.ultmarc_table import UltmarcTable
|
||||
|
||||
|
||||
class ComSpecialstLicense(UltmarcTable):
|
||||
class ComSpecialistLicense(UltmarcTable):
|
||||
"""レイアウト区分010: COM_専門医資格"""
|
||||
specialst_cd: str # 専門医コード
|
||||
specialst_licens_name: str # 専門医資格名
|
||||
specialist_cd: str # 専門医コード
|
||||
specialist_license_name: str # 専門医資格名
|
||||
maint_flag: str # 修正区分
|
||||
|
||||
def __init__(self, record: list[str]):
|
||||
super().__init__(record)
|
||||
self.specialst_cd = record[1]
|
||||
self.specialist_cd = record[1]
|
||||
self.maint_flag = record[2]
|
||||
self.specialst_licens_name = record[5]
|
||||
self.specialist_license_name = record[5]
|
||||
@ -68,8 +68,8 @@ from src.batch.ultmarc.utmp_tables.table_mapper.concrete.com_blng_sec_mapper imp
|
||||
ComBlngSecMapper
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete.com_sosiety_mapper import \
|
||||
ComSosietyMapper
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete.com_specialst_license_mapper import \
|
||||
ComSpecialstLicenseMapper
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete.com_specialist_license_mapper import \
|
||||
ComSpecialistLicenseMapper
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete.com_inst_div_mapper import \
|
||||
ComInstDivMapper
|
||||
|
||||
@ -121,7 +121,7 @@ COM_TABLE_LIST = {
|
||||
# COM_学会
|
||||
"009": ComSosietyMapper,
|
||||
# COM_専門医資格
|
||||
"010": ComSpecialstLicenseMapper,
|
||||
"010": ComSpecialistLicenseMapper,
|
||||
# COM_施設区分
|
||||
"011": ComInstDivMapper,
|
||||
# COM_高度先進医療
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
"dcf_pcf_dr_cd","specialst_cd","specialst_maint_div","specialst_flg","specialst_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"dcf_pcf_dr_cd","specialist_cd","specialist_maint_div","specialist_flg","specialist_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0199430100","0003","2","1","20170401","NULL","NULL","","","20171008","20171011","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/11 21:20:37","clsComSpField"
|
||||
"0199578300","0003","2","1","20170221","1","20140810","","","20171008","20171011","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/11 21:20:37","clsComSpField"
|
||||
"0199768200","0004","2","1","20131112","","","","","20171008","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/08 17:05:14","clsComSpField"
|
||||
|
||||
|
@ -1,4 +1,4 @@
|
||||
"dcf_pcf_dr_cd","specialst_cd","specialst_maint_div","specialst_flg","specialst_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"dcf_pcf_dr_cd","specialist_cd","specialist_maint_div","specialist_flg","specialist_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0199430100","0003","2","","","1","20140401","","","20171008","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/08 17:05:14","clsComSpField"
|
||||
"0199578300","0003","2","","","1","20140401","","","20171008","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/08 17:05:14","clsComSpField"
|
||||
"0199768200","0004","2","1","20131112","","","","","20171008","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/08 17:05:14","clsComSpField"
|
||||
|
||||
|
@ -1,2 +1,2 @@
|
||||
"dcf_pcf_dr_cd","specialst_cd","specialst_maint_div","specialst_flg","specialst_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"dcf_pcf_dr_cd","specialist_cd","specialist_maint_div","specialist_flg","specialist_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0199961300","9999","2","1","20140706","1","20140401","1","20140706","20171008","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/08 17:05:14","clsComSpField"
|
||||
|
||||
|
@ -1,4 +1,4 @@
|
||||
"dcf_pcf_dr_cd","specialst_cd","specialst_maint_div","specialst_flg","specialst_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"dcf_pcf_dr_cd","specialist_cd","specialist_maint_div","specialist_flg","specialist_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0199430100","0003","2","","","1","20140401","","","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"
|
||||
"0199578300","0003","2","","","1","20140401","","","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"
|
||||
"0199768200","0004","2","1","20131112","","","","","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"
|
||||
|
||||
|
@ -1,4 +1,4 @@
|
||||
"dcf_pcf_dr_cd","specialst_cd","specialst_maint_div","specialst_flg","specialst_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"dcf_pcf_dr_cd","specialist_cd","specialist_maint_div","specialist_flg","specialist_publsh_ymd","ackn_med_flg","ackn_med_publsh_ymd","guide_med_flg","guide_med_publsh_ymd","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0199430100","0003","2","1","20170401","NULL","NULL","","","20171008","20230425","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/09 20:21:51","com_sp_field_mapper"
|
||||
"0199578300","0003","2","1","20170221","1","20140810","","","20171008","20230425","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/09 20:21:51","com_sp_field_mapper"
|
||||
"0199768200","0004","2","1","20131112","","","","","20171008","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 17:05:14","clsComSpField","2017/10/08 17:05:14","clsComSpField"
|
||||
|
||||
|
@ -69,18 +69,18 @@ class TestComSpFieldMapper:
|
||||
# 期待値ファイルを読み込む
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_sp_field_insert.csv'))
|
||||
primary_keys_dcf_pcf_dr_cd = [{'dcf_pcf_dr_cd': columns['dcf_pcf_dr_cd']} for columns in expect_data_list]
|
||||
primary_keys_specialst_cd = [{'specialst_cd': columns['specialst_cd']} for columns in expect_data_list]
|
||||
primary_keys_specialist_cd = [{'specialist_cd': columns['specialist_cd']} for columns in expect_data_list]
|
||||
actual_data_list = []
|
||||
sp_field_select_sql = """\
|
||||
SELECT * FROM src05.com_sp_field
|
||||
WHERE
|
||||
dcf_pcf_dr_cd = :dcf_pcf_dr_cd
|
||||
AND specialst_cd = :specialst_cd\
|
||||
AND specialist_cd = :specialist_cd\
|
||||
"""
|
||||
for param_dcf_pcf_dr_cd, param_specialst_cd in zip(primary_keys_dcf_pcf_dr_cd, primary_keys_specialst_cd):
|
||||
for param_dcf_pcf_dr_cd, param_specialist_cd in zip(primary_keys_dcf_pcf_dr_cd, primary_keys_specialist_cd):
|
||||
sp_field_data = self.db.execute_select(
|
||||
sp_field_select_sql,
|
||||
{**param_dcf_pcf_dr_cd, **param_specialst_cd})
|
||||
{**param_dcf_pcf_dr_cd, **param_specialist_cd})
|
||||
assert len(sp_field_data) == 1, '1件取得できていること'
|
||||
actual_data_list.append(sp_field_data[0])
|
||||
|
||||
@ -136,18 +136,18 @@ class TestComSpFieldMapper:
|
||||
# 期待値ファイルを読み込む
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_sp_field_update.csv'))
|
||||
primary_keys_dcf_pcf_dr_cd = [{'dcf_pcf_dr_cd': columns['dcf_pcf_dr_cd']} for columns in expect_data_list]
|
||||
primary_keys_specialst_cd = [{'specialst_cd': columns['specialst_cd']} for columns in expect_data_list]
|
||||
primary_keys_specialist_cd = [{'specialist_cd': columns['specialist_cd']} for columns in expect_data_list]
|
||||
actual_data_list = []
|
||||
sp_field_select_sql = """\
|
||||
SELECT * FROM src05.com_sp_field
|
||||
WHERE
|
||||
dcf_pcf_dr_cd = :dcf_pcf_dr_cd
|
||||
AND specialst_cd = :specialst_cd\
|
||||
AND specialist_cd = :specialist_cd\
|
||||
"""
|
||||
for param_dcf_pcf_dr_cd, param_specialst_cd in zip(primary_keys_dcf_pcf_dr_cd, primary_keys_specialst_cd):
|
||||
for param_dcf_pcf_dr_cd, param_specialist_cd in zip(primary_keys_dcf_pcf_dr_cd, primary_keys_specialist_cd):
|
||||
sp_field_data = self.db.execute_select(
|
||||
sp_field_select_sql,
|
||||
{**param_dcf_pcf_dr_cd, **param_specialst_cd})
|
||||
{**param_dcf_pcf_dr_cd, **param_specialist_cd})
|
||||
assert len(sp_field_data) == 1, '1件取得できていること'
|
||||
actual_data_list.append(sp_field_data[0])
|
||||
|
||||
@ -208,18 +208,18 @@ class TestComSpFieldMapper:
|
||||
actual_record_count = self.db.execute_select('SELECT COUNT(*) AS count_num FROM src05.com_sp_field')[0]['count_num']
|
||||
assert actual_record_count == len(expect_data_list), 'DBのレコード件数が期待値の件数と一致すること'
|
||||
primary_keys_dcf_pcf_dr_cd = [{'dcf_pcf_dr_cd': columns['dcf_pcf_dr_cd']} for columns in expect_data_list]
|
||||
primary_keys_specialst_cd = [{'specialst_cd': columns['specialst_cd']} for columns in expect_data_list]
|
||||
primary_keys_specialist_cd = [{'specialist_cd': columns['specialist_cd']} for columns in expect_data_list]
|
||||
actual_data_list = []
|
||||
sp_field_select_sql = """\
|
||||
SELECT * FROM src05.com_sp_field
|
||||
WHERE
|
||||
dcf_pcf_dr_cd = :dcf_pcf_dr_cd
|
||||
AND specialst_cd = :specialst_cd\
|
||||
AND specialist_cd = :specialist_cd\
|
||||
"""
|
||||
for param_dcf_pcf_dr_cd, param_specialst_cd in zip(primary_keys_dcf_pcf_dr_cd, primary_keys_specialst_cd):
|
||||
for param_dcf_pcf_dr_cd, param_specialist_cd in zip(primary_keys_dcf_pcf_dr_cd, primary_keys_specialist_cd):
|
||||
sp_field_data = self.db.execute_select(
|
||||
sp_field_select_sql,
|
||||
{**param_dcf_pcf_dr_cd, **param_specialst_cd})
|
||||
{**param_dcf_pcf_dr_cd, **param_specialist_cd})
|
||||
assert len(sp_field_data) == 1, '1件取得できていること'
|
||||
actual_data_list.append(sp_field_data[0])
|
||||
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
"specialst_cd","specialst_licens_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"specialist_cd","specialist_license_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","","20171024","20171024","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:46:19","clsComSpLicens"
|
||||
"0002","整形外科専門医","20171024","20171024","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:46:19","clsComSpLicens"
|
||||
"0003","麻酔科専門医","20171024","20171024","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:46:19","clsComSpLicens"
|
||||
|
@ -1,4 +1,4 @@
|
||||
"specialst_cd","specialst_licens_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"specialist_cd","specialist_license_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","皮膚科専門医","20171024","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:03:03","clsComSpLicens"
|
||||
"0002","整形外科専門医","20171024","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:03:03","clsComSpLicens"
|
||||
"0003","麻酔科専門医","20171024","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:03:03","clsComSpLicens"
|
||||
|
@ -1,8 +1,8 @@
|
||||
"specialst_cd","specialst_licens_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"0002","整形外科専門医","20171024","20171024","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"0003","麻酔科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"0004","産婦人科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"0005","放射線科専門医","20171024","20171024","20230515","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"0006","眼科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"0007","耳鼻咽喉科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:47:40","com_specialst_license_mapper","2023/05/15 12:47:40","com_specialst_license_mapper"
|
||||
"specialist_cd","specialist_license_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
"0002","整形外科専門医","20171024","20171024","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
"0003","麻酔科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
"0004","産婦人科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
"0005","放射線科専門医","20171024","20171024","20230515","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
"0006","眼科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
"0007","耳鼻咽喉科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:47:40","com_specialist_license_mapper","2023/05/15 12:47:40","com_specialist_license_mapper"
|
||||
|
@ -0,0 +1,8 @@
|
||||
"specialist_cd","specialist_license_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","皮膚科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
"0002","整形外科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
"0003","麻酔科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
"0004","産婦人科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
"0005","眼科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
"0006","放射線科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
"9999","あいうえおかきくけこあいうえおかきくけこあいうえお","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialist_license_mapper","2023/05/15 12:03:03","com_specialist_license_mapper"
|
||||
|
@ -1,8 +1,8 @@
|
||||
"specialst_cd","specialst_licens_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialst_license_mapper"
|
||||
"0002","整形外科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialst_license_mapper"
|
||||
"0003","麻酔科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialst_license_mapper"
|
||||
"0004","産婦人科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialst_license_mapper"
|
||||
"0005","放射線科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialst_license_mapper"
|
||||
"0006","眼科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialst_license_mapper"
|
||||
"specialist_cd","specialist_license_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialist_license_mapper"
|
||||
"0002","整形外科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialist_license_mapper"
|
||||
"0003","麻酔科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialist_license_mapper"
|
||||
"0004","産婦人科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialist_license_mapper"
|
||||
"0005","放射線科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialist_license_mapper"
|
||||
"0006","眼科専門医","20171024","20230515","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2023/05/15 12:46:19","com_specialist_license_mapper"
|
||||
"9999","ああああ","20171024","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/24 12:03:03","clsComSpLicens","2017/10/24 12:03:03","clsComSpLicens"
|
||||
|
@ -4,7 +4,7 @@ from datetime import datetime
|
||||
import pytest
|
||||
|
||||
from src.batch.common.batch_context import BatchContext
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete import com_specialst_license_mapper
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete import com_specialist_license_mapper
|
||||
from src.db.database import Database
|
||||
from tests.testing_utility import (assert_table_results,
|
||||
create_db_data_from_csv,
|
||||
@ -14,7 +14,7 @@ from tests.testing_utility import (assert_table_results,
|
||||
create_ultmarc_test_data_from_csv)
|
||||
|
||||
|
||||
class TestComSpecialstLicenseMapper:
|
||||
class TestComSpecialistLicenseMapper:
|
||||
"""レイアウト区分010: COM_専門医資格"""
|
||||
|
||||
db: Database
|
||||
@ -52,24 +52,24 @@ class TestComSpecialstLicenseMapper:
|
||||
# 処理日設定
|
||||
self.batch_context.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d')
|
||||
# テスト用のCSVを読み込む
|
||||
test_dat_file = create_ultmarc_test_data_from_csv(path.join(self.test_file_path, 'com_specialst_license_insert.csv'))
|
||||
test_dat_file = create_ultmarc_test_data_from_csv(path.join(self.test_file_path, 'com_specialist_license_insert.csv'))
|
||||
# 一旦全データをDBから削除
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_specialst_license', {'1': '1'})
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_specialist_license', {'1': '1'})
|
||||
self.db.execute(delete_sql, delete_parameter)
|
||||
|
||||
# Act
|
||||
for line_number, line in enumerate(test_dat_file, start=1):
|
||||
sut: com_specialst_license_mapper.ComSpecialstLicenseMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_specialst_license_mapper.ComSpecialstLicenseMapper, f'{line_number}行目:マッパークラスが期通りか'
|
||||
sut: com_specialist_license_mapper.ComSpecialistLicenseMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_specialist_license_mapper.ComSpecialistLicenseMapper, f'{line_number}行目:マッパークラスが期通りか'
|
||||
|
||||
sut.make_query()
|
||||
sut.execute_queries()
|
||||
|
||||
# Assert
|
||||
# 期待値ファイルを読み込む
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_specialst_license_insert.csv'))
|
||||
primary_keys = [f"'{primary_key['specialst_cd']}'" for primary_key in expect_data_list]
|
||||
actual_select_sql = f"SELECT * FROM src05.com_specialst_license WHERE specialst_cd IN ({','.join(primary_keys)})"
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_specialist_license_insert.csv'))
|
||||
primary_keys = [f"'{primary_key['specialist_cd']}'" for primary_key in expect_data_list]
|
||||
actual_select_sql = f"SELECT * FROM src05.com_specialist_license WHERE specialist_cd IN ({','.join(primary_keys)})"
|
||||
actual_data_list = self.db.execute_select(actual_select_sql)
|
||||
# 期待値検査
|
||||
ignore_columns = ['regist_ymd', 'sys_update_date', 'sys_regist_date']
|
||||
@ -97,16 +97,16 @@ class TestComSpecialstLicenseMapper:
|
||||
# 処理日設定
|
||||
self.batch_context.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d')
|
||||
# テスト用のCSVを読み込む
|
||||
test_dat_file = create_ultmarc_test_data_from_csv(path.join(self.test_file_path, 'com_specialst_license_update.csv'))
|
||||
test_dat_file = create_ultmarc_test_data_from_csv(path.join(self.test_file_path, 'com_specialist_license_update.csv'))
|
||||
# 一旦全データをDBから削除
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_specialst_license', {'1': '1'})
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_specialist_license', {'1': '1'})
|
||||
self.db.execute(delete_sql, delete_parameter)
|
||||
# テストデータをDBに登録
|
||||
# DBデータを読み込む
|
||||
test_sql_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'db_com_specialst_license_before_update.csv'))
|
||||
test_sql_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'db_com_specialist_license_before_update.csv'))
|
||||
for test_data in test_sql_data_list:
|
||||
insert_sql, insert_parameter = create_insert_sql_with_parameter(
|
||||
'src05.com_specialst_license',
|
||||
'src05.com_specialist_license',
|
||||
test_data.keys(),
|
||||
test_data.values()
|
||||
)
|
||||
@ -114,16 +114,16 @@ class TestComSpecialstLicenseMapper:
|
||||
|
||||
# Act
|
||||
for line_number, line in enumerate(test_dat_file, start=1):
|
||||
sut: com_specialst_license_mapper.ComSpecialstLicenseMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_specialst_license_mapper.ComSpecialstLicenseMapper, f'{line_number}行目:マッパークラスが期通りか'
|
||||
sut: com_specialist_license_mapper.ComSpecialistLicenseMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_specialist_license_mapper.ComSpecialistLicenseMapper, f'{line_number}行目:マッパークラスが期通りか'
|
||||
sut.make_query()
|
||||
sut.execute_queries()
|
||||
|
||||
# Assert
|
||||
# 期待値ファイルを読み込む
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_specialst_license_update.csv'))
|
||||
primary_keys = [f"'{primary_key['specialst_cd']}'" for primary_key in expect_data_list]
|
||||
actual_select_sql = f"SELECT * FROM src05.com_specialst_license WHERE specialst_cd IN ({','.join(primary_keys)})"
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_specialist_license_update.csv'))
|
||||
primary_keys = [f"'{primary_key['specialist_cd']}'" for primary_key in expect_data_list]
|
||||
actual_select_sql = f"SELECT * FROM src05.com_specialist_license WHERE specialist_cd IN ({','.join(primary_keys)})"
|
||||
actual_data_list = self.db.execute_select(actual_select_sql)
|
||||
# 期待値検査
|
||||
ignore_columns = ['regist_ymd', 'update_ymd', 'sys_update_date', 'sys_regist_date']
|
||||
@ -154,16 +154,16 @@ class TestComSpecialstLicenseMapper:
|
||||
# 処理日設定
|
||||
self.batch_context.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d')
|
||||
# テスト用のCSVを読み込む
|
||||
test_dat_file = create_ultmarc_test_data_from_csv(path.join(self.test_file_path, 'com_specialst_license_delete.csv'))
|
||||
test_dat_file = create_ultmarc_test_data_from_csv(path.join(self.test_file_path, 'com_specialist_license_delete.csv'))
|
||||
# 一旦全データをDBから削除
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_specialst_license', {'1': '1'})
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_specialist_license', {'1': '1'})
|
||||
self.db.execute(delete_sql, delete_parameter)
|
||||
# テストデータをDBに登録
|
||||
# DBデータを読み込む
|
||||
test_sql_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'db_com_specialst_license_before_delete.csv'))
|
||||
test_sql_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'db_com_specialist_license_before_delete.csv'))
|
||||
for test_data in test_sql_data_list:
|
||||
insert_sql, insert_parameter = create_insert_sql_with_parameter(
|
||||
'src05.com_specialst_license',
|
||||
'src05.com_specialist_license',
|
||||
test_data.keys(),
|
||||
test_data.values()
|
||||
)
|
||||
@ -171,16 +171,16 @@ class TestComSpecialstLicenseMapper:
|
||||
|
||||
# Act
|
||||
for line_number, line in enumerate(test_dat_file, start=1):
|
||||
sut: com_specialst_license_mapper.ComSpecialstLicenseMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_specialst_license_mapper.ComSpecialstLicenseMapper, f'{line_number}行目:マッパークラスが期通りか'
|
||||
sut: com_specialist_license_mapper.ComSpecialistLicenseMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_specialist_license_mapper.ComSpecialistLicenseMapper, f'{line_number}行目:マッパークラスが期通りか'
|
||||
sut.make_query()
|
||||
sut.execute_queries()
|
||||
|
||||
# Assert
|
||||
# 期待値ファイルを読み込む
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_specialst_license_delete.csv'))
|
||||
primary_keys = [f"'{primary_key['specialst_cd']}'" for primary_key in expect_data_list]
|
||||
actual_select_sql = f"SELECT * FROM src05.com_specialst_license WHERE specialst_cd IN ({','.join(primary_keys)})"
|
||||
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_specialist_license_delete.csv'))
|
||||
primary_keys = [f"'{primary_key['specialist_cd']}'" for primary_key in expect_data_list]
|
||||
actual_select_sql = f"SELECT * FROM src05.com_specialist_license WHERE specialist_cd IN ({','.join(primary_keys)})"
|
||||
actual_data_list = self.db.execute_select(actual_select_sql)
|
||||
# 期待値検査
|
||||
ignore_columns = ['regist_ymd', 'update_ymd', 'delete_ymd', 'sys_update_date', 'sys_regist_date']
|
||||
@ -1,8 +0,0 @@
|
||||
"specialst_cd","specialst_licens_name","regist_ymd","update_ymd","delete_ymd","regist_date","create_user","update_date","update_user","sys_regist_date","regist_prgm_id","sys_update_date","update_prgm_id"
|
||||
"0001","皮膚科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
"0002","整形外科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
"0003","麻酔科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
"0004","産婦人科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
"0005","眼科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
"0006","放射線科専門医","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
"9999","あいうえおかきくけこあいうえおかきくけこあいうえお","20230515","NULL","NULL","NULL","NULL","NULL","NULL","2023/05/15 12:03:03","com_specialst_license_mapper","2023/05/15 12:03:03","com_specialst_license_mapper"
|
||||
|
Loading…
x
Reference in New Issue
Block a user