自動テスト実装 MDBコード変換表

ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/test_vjsk_load.py

@@ -885,3 +885,66 @@ class TestImportFileToDb:
         assert result_src_count[0]['count(*)'] == 6
 
         # teardown
+
+    def test_load_13_mdb_conv_mst_ok(self, mapper):
+        table_name_org = mapper.get_org_table(mapper.CONDKEY_MDB_CONV_MST)
+        table_name_src = mapper.get_src_table(mapper.CONDKEY_MDB_CONV_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_MDB_CONV_MST,
+            "src_file_path": path.join(self.test_file_path_load_individual, "mdb_conv_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_MDB_CONV_MST,
+            "src_file_path": path.join(self.test_file_path_load_individual, "mdb_conv_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.hco_vid_v = o.hco_vid_v 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

ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/mdb_conv_mst_202304280000.tsv

@@ -0,0 +1,5 @@
+"hco_vid__v"	"sub_no"	"mdb_cd"	"reliability"	"start_dt"	"rec_sts_kbn"	"ins_dt"	"upd_dt"
+"670229780011959315"	"1"	"003410424"	"0"	"20020601"	"0"	"22-03-09 13:56:19"	"22-03-09 13:56:19"
+"670230081112654862"	"0"	"004101420"	"0"	"20000101"	"9"	"17-10-17 17:06:52"	"22-03-09 14:17:34"
+"670230081112654862"	"1"	"004104997"	"2"	"20000101"	"0"	"22-03-09 14:17:33"	"22-03-09 14:17:33"
+"670230100414841865"	"0"	"003622111"	"3"	"20000101"	"9"	"17-10-17 17:06:52"	"22-03-09 14:13:49"

ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/mdb_conv_mst_202304290000.tsv

@@ -0,0 +1,5 @@
+"hco_vid__v"	"sub_no"	"mdb_cd"	"reliability"	"start_dt"	"rec_sts_kbn"	"ins_dt"	"upd_dt"
+"670230081112654862"	"1"	"004104997"	"0"	"20000101"	"0"	"22-03-09 14:17:33"	"22-03-09 14:17:33"
+"670230100414841865"	"0"	"003622111"	"0"	"20000101"	"9"	"17-10-17 17:06:52"	"22-03-09 14:13:49"
+"670230100414841865"	"1"	"003636480"	"0"	"20000101"	"0"	"22-03-09 14:13:49"	"22-03-09 14:13:49"
+"670230330673742853"	"0"	"004804003"	"0"	"20000101"	"9"	"17-10-17 17:06:52"	"22-03-09 15:20:35"