自動テスト実装 V卸得意先情報マスタ
This commit is contained in:
parent
5ac63d6f4f
commit
c33940eee1
@ -822,3 +822,66 @@ class TestImportFileToDb:
|
||||
assert result_src_count[0]['count(*)'] == 6
|
||||
|
||||
# teardown
|
||||
|
||||
def test_load_12_whs_customer_mst_ok(self, mapper):
|
||||
table_name_org = mapper.get_org_table(mapper.CONDKEY_WHS_CUSTOMER_MST)
|
||||
table_name_src = mapper.get_src_table(mapper.CONDKEY_WHS_CUSTOMER_MST)
|
||||
|
||||
# setup
|
||||
self.batch_context.is_vjsk_stock_import_day = True
|
||||
self.db.execute(f"truncate table {table_name_src}")
|
||||
|
||||
# assertion1 (insert 4row)
|
||||
|
||||
# 処理実行
|
||||
target_dict = {
|
||||
"condkey": mapper.CONDKEY_WHS_CUSTOMER_MST,
|
||||
"src_file_path": path.join(self.test_file_path_load_individual, "whs_customer_mst_202304280000.tsv")
|
||||
}
|
||||
VjskDataLoadManager.load(target_dict)
|
||||
|
||||
# 期待値データファイル読み込み
|
||||
assert_list = create_vjsk_assertion_list(target_dict["src_file_path"])
|
||||
# orgテーブル結果を取得
|
||||
result_org = self.db.execute_select(f"select * from {table_name_org}")
|
||||
# 突合から除外する項目
|
||||
ignore_columns = ['dwh_upd_dt']
|
||||
# orgテーブル結果が期待値通りかを突合
|
||||
assert_table_results(result_org, assert_list, ignore_columns)
|
||||
# srcテーブル結果を取得
|
||||
result_src = self.db.execute_select(f"select * from {table_name_src}")
|
||||
# 突合から除外する項目
|
||||
ignore_columns = ['dwh_upd_dt']
|
||||
# srcテーブル結果が期待値通りかを突合
|
||||
assert_table_results(result_src, assert_list, ignore_columns)
|
||||
|
||||
# assertion2 (update 2row +insert 2row)
|
||||
|
||||
# 処理実行
|
||||
target_dict = {
|
||||
"condkey": mapper.CONDKEY_WHS_CUSTOMER_MST,
|
||||
"src_file_path": path.join(self.test_file_path_load_individual, "whs_customer_mst_202304290000.tsv")
|
||||
}
|
||||
VjskDataLoadManager.load(target_dict)
|
||||
|
||||
# 期待値データファイル読み込み
|
||||
assert_list = create_vjsk_assertion_list(target_dict["src_file_path"])
|
||||
# orgテーブル結果を取得
|
||||
result_org = self.db.execute_select(f"select * from {table_name_org}")
|
||||
# 突合から除外する項目
|
||||
ignore_columns = ['dwh_upd_dt']
|
||||
# orgテーブル結果が期待値通りかを突合
|
||||
assert_table_results(result_org, assert_list, ignore_columns)
|
||||
# srcテーブル結果(orgテーブル結果のPK値で一致するもの)を取得
|
||||
result_src = self.db.execute_select(
|
||||
f"select * from {table_name_src} s inner join {table_name_org} o on (s.whs_cd = o.whs_cd and s.whs_sub_cd = o.whs_sub_cd and s.customer_cd = o.customer_cd and s.sub_num = o.sub_num)")
|
||||
# 突合から除外する項目
|
||||
ignore_columns = ['dwh_upd_dt']
|
||||
# srcテーブル結果が期待値通りかを突合
|
||||
assert_table_results(result_src, assert_list, ignore_columns)
|
||||
|
||||
# srcテーブル結果のレコード件数 (insert 4row + update 2row + insert 2row = 6row)
|
||||
result_src_count = self.db.execute_select(f"select count(*) from {table_name_src} ")
|
||||
assert result_src_count[0]['count(*)'] == 6
|
||||
|
||||
# teardown
|
||||
|
||||
5
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_customer_mst_202304280000.tsv
vendored
Normal file
5
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_customer_mst_202304280000.tsv
vendored
Normal file
@ -0,0 +1,5 @@
|
||||
"whs_cd" "whs_sub_cd" "customer_cd" "sub_no" "start_dt" "end_dt" "org_cd" "src_org_cd" "nm" "kn_nm" "addr" "kn_addr" "zip_cd" "tel_no" "rec_sts_kbn" "ins_dt" "upd_dt"
|
||||
"006" "01" "1002900000" "0" "20000101" "99991231" "11" "1131A2283316" "辻内科小児科医院 " "ツジナイカシヨウニカ イイン" "長崎県 佐世保市皆瀬町29 " "ナガサキケン サセボシカイゼチヨウ 29" "8570144" "0956492319" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
"006" "01" "1005400000" "0" "20000101" "99991231" "12" "1211C3415515" "医療法人 愛恵会 佐世保愛恵病院 " "イリヨウホウジンアイケイカイサセボアイケイビ" "長崎県 佐世保市瀬戸越4丁目 2−15 " "ナガサキケン サセボシセトゴシ 4チヨウメ 2-15" "8570134" "0956493335" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
"006" "01" "1007200000" "0" "20000101" "99991231" "11" "1131A2407312" "医療法人 山祇診療所 " "イリヨウホウジンヤマズミシンリヨウジヨ" "長崎県 佐世保市山祇町 19−36 " "ナガサキケン サセボシヤマズミチョウ" "8570822" "0956313633" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
"006" "01" "1007800000" "0" "20000101" "99991231" "11" "1121A2402213" "医療法人道仁会 品川医院 " "イリヨウホウジンドウジンカイ シナガワイイン" "長崎県 佐世保市柚木町2188 " "ナガサキケン サセボシユノキチヨウ 2188" "8570112" "0956460005" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
|
5
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_customer_mst_202304290000.tsv
vendored
Normal file
5
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_customer_mst_202304290000.tsv
vendored
Normal file
@ -0,0 +1,5 @@
|
||||
"whs_cd" "whs_sub_cd" "customer_cd" "sub_no" "start_dt" "end_dt" "org_cd" "src_org_cd" "nm" "kn_nm" "addr" "kn_addr" "zip_cd" "tel_no" "rec_sts_kbn" "ins_dt" "upd_dt"
|
||||
"006" "01" "1007200000" "0" "20000101" "99991231" "11" "1131A2407312" "医療法人 山祇診療所2 " "イリヨウホウジンヤマズミシンリヨウジヨ" "長崎県 佐世保市山祇町 19−36 " "ナガサキケン サセボシヤマズミチョウ" "8570822" "0956313633" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
"006" "01" "1007800000" "0" "20000101" "99991231" "11" "1121A2402213" "医療法人道仁会 品川医院2 " "イリヨウホウジンドウジンカイ シナガワイイン" "長崎県 佐世保市柚木町2188 " "ナガサキケン サセボシユノキチヨウ 2188" "8570112" "0956460005" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
"006" "01" "1008000000" "0" "20000101" "99991231" "11" "1131A2283316" "北原整形外科医院2 " "キタハラセイケイゲカ イイン" "長崎県 佐世保市瀬戸越町4丁目1298−1 " "ナガサキケン サセボシセトゴシチヨウ 1298-1" "8570135" "0956497773" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
"006" "01" "1009100000" "0" "20000101" "99991231" "11" "1121A2224212" "山口医院2 " "ヤマグチイイン" "長崎県 佐世保市春日町29−14 " "ナガサキケン サセボシカスガチヨウ29-14" "8570011" "0956228610" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
|
||||
|
Loading…
x
Reference in New Issue
Block a user