自動テスト実装 Ｖ取引区分マスタ

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

@@ -633,3 +633,66 @@ class TestImportFileToDb:
         assert result_src_count[0]['count(*)'] == 8
 
         # teardown
+
+    def test_load_08_tran_kbn_mst_ok(self, mapper):
+        table_name_org = mapper.get_org_table(mapper.CONDKEY_TRAN_KBN_MST)
+        table_name_src = mapper.get_src_table(mapper.CONDKEY_TRAN_KBN_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_TRAN_KBN_MST,
+            "src_file_path": path.join(self.test_file_path_load_individual, "tran_kbn_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_TRAN_KBN_MST,
+            "src_file_path": path.join(self.test_file_path_load_individual, "tran_kbn_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.v_tran_cd = o.v_tran_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

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

@@ -0,0 +1,5 @@
+"v_tran_cd"	"sub_no"	"nm"	"start_dt"	"end_dt"	"dsp_odr"	"rec_sts_kbn"	"ins_dt"	"upd_dt"
+"10001"	"1"	"Veeva取引区分名01-1"	"20230101"	"99991231"	"1"	"0"	"2023-05-09 12:00:01"	"2023-05-09 13:00:01"
+"10001"	"2"	"Veeva取引区分名01-2"	"20230102"	"99991231"	"1"	"0"	"2023-05-09 12:00:02"	"2023-05-09 13:00:02"
+"10001"	"3"	"Veeva取引区分名01-3"	"20230103"	"99991231"	"1"	"0"	"2023-05-09 12:00:03"	"2023-05-09 13:00:03"
+"10001"	"4"	"Veeva取引区分名01-4"	"20230104"	"99991231"	"1"	"0"	"2023-05-09 12:00:04"	"2023-05-09 13:00:04"

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

@@ -0,0 +1,5 @@
+"v_tran_cd"	"sub_no"	"nm"	"start_dt"	"end_dt"	"dsp_odr"	"rec_sts_kbn"	"ins_dt"	"upd_dt"
+"10001"	"3"	"Veeva取引区分名01-3"	"20230201"	"20301231"	"1"	"0"	"2023-05-09 12:00:03"	"2023-05-09 13:00:03"
+"10001"	"4"	"Veeva取引区分名01-4"	"20230202"	"20301231"	"1"	"0"	"2023-05-09 12:00:04"	"2023-05-09 13:00:04"
+"10001"	"5"	"Veeva取引区分名01-5"	"20230203"	"20301231"	"1"	"0"	"2023-05-09 12:00:05"	"2023-05-09 13:00:05"
+"10002"	"1"	"Veeva取引区分名02-1"	"20230204"	"20301231"	"1"	"0"	"2023-05-09 12:00:06"	"2023-05-09 13:00:06"