feat: COM_高度先進医療のテストコード作成
This commit is contained in:
shimoda.m@nds-tyo.co.jp
parent
aff5013f15
commit
4cd848afde
@ -0,0 +1,305 @@
|
||||
from datetime import datetime
|
||||
|
||||
import pytest
|
||||
|
||||
from src.batch.common.batch_config import BatchConfig
|
||||
from src.batch.ultmarc.utmp_tables.table_mapper.concrete import \
|
||||
com_hamtec_mapper
|
||||
from src.db.database import Database
|
||||
from tests.testing_utility import (assert_table_results,
|
||||
create_delete_sql_with_parameter,
|
||||
create_insert_sql_with_parameter,
|
||||
create_ultmarc_common_column_names,
|
||||
create_ultmarc_common_column_values,
|
||||
create_ultmarc_table_mapper_sut,
|
||||
create_ultmarc_test_csv, get_module_name)
|
||||
|
||||
|
||||
class TestComHamtecMapper:
|
||||
"""COM_高度先進医療"""
|
||||
|
||||
db: Database
|
||||
batch_config: BatchConfig
|
||||
table_columns = ["hamtec_cd", "hamtec_div", "hamtec_name"] + create_ultmarc_common_column_names()
|
||||
|
||||
@pytest.fixture(autouse=True, scope='function')
|
||||
def pre_test(self, database: Database):
|
||||
"""テスト実行前後処理"""
|
||||
self.batch_config = BatchConfig.get_instance()
|
||||
# setup
|
||||
self.db = database
|
||||
self.db.connect()
|
||||
self.db.begin()
|
||||
|
||||
# testing
|
||||
yield
|
||||
|
||||
# teardown
|
||||
self.db.rollback()
|
||||
self.db.disconnect()
|
||||
|
||||
def test_insert_record(self, expect_datetime: datetime, expect_date_str: str):
|
||||
"""
|
||||
Cases:
|
||||
COM_高度先進医療テーブルにレコードを登録する
|
||||
Arranges:
|
||||
- CSVデータを用意する
|
||||
- 追加対象となるレコードを削除する
|
||||
Expects:
|
||||
- 登録内容が期待値と一致すること
|
||||
"""
|
||||
|
||||
# Arrange
|
||||
# 処理日設定
|
||||
self.batch_config.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d')
|
||||
# テストデータ作成
|
||||
csv_floating_data_lst = [
|
||||
['001', '2', '直流電流による骨電気治療法', 'A'],
|
||||
['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）', 'A'],
|
||||
['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療', 'A'],
|
||||
['004', '1', '顔面骨、頭蓋骨の観血的移動術', 'A'],
|
||||
['005', '1', '造血器腫瘍のＤＮＡ診断', 'A'],
|
||||
['006', '1', '培養細胞による先天性代謝異常診断（胎児又は新生児に係るものに限る）', 'A']
|
||||
]
|
||||
test_data_list = [
|
||||
f'"021","{data[0]}","{data[1]}","{data[3]}","20141113","20141114","{data[2]}","1","2014/11/21 22:53:44","VANLOAD",,,"2014/11/21 22:53:44"'
|
||||
for data in csv_floating_data_lst
|
||||
]
|
||||
test_dat_file = create_ultmarc_test_csv(test_data_list)
|
||||
# 一旦全データをDBから削除
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_hamtec', {'1': '1'})
|
||||
self.db.execute(delete_sql, delete_parameter)
|
||||
|
||||
# sut(system under test)作成
|
||||
for i, line in enumerate(test_dat_file, start=1):
|
||||
sut: com_hamtec_mapper.ComHamtecMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_hamtec_mapper.ComHamtecMapper, f'{i}行目:マッパークラスが期通りか'
|
||||
|
||||
# Act
|
||||
sut.make_query()
|
||||
sut.execute_queries()
|
||||
|
||||
# Assert
|
||||
# 期待値作成
|
||||
# 期待値となるモジュール名
|
||||
module_name = get_module_name(com_hamtec_mapper)
|
||||
expect_data = csv_floating_data_lst[i - 1]
|
||||
expect_row = [expect_data[0], expect_data[1], expect_data[2]] + create_ultmarc_common_column_values(
|
||||
regist_ymd=expect_date_str,
|
||||
sys_regist_date=expect_datetime,
|
||||
regist_prgm_id=module_name,
|
||||
sys_update_date=expect_datetime,
|
||||
update_prgm_id=module_name
|
||||
)
|
||||
expect_rows = [{c: r for c, r in zip(self.table_columns, expect_row)}]
|
||||
actual_rows = self.db.execute_select(f"SELECT * FROM src05.com_hamtec WHERE hamtec_cd = '{expect_data[0]}'")
|
||||
|
||||
# 期待値検査
|
||||
assert_table_results(actual_rows, expect_rows, line_number=i, ignore_col_name=['sys_update_date', 'sys_regist_date'])
|
||||
|
||||
# 動的日付項目の個別確認
|
||||
for actual_row, expect_row in zip(actual_rows, expect_rows):
|
||||
for actual_col_name, expect_col_name in zip(actual_row, expect_row):
|
||||
if actual_col_name in ['sys_regist_date', 'sys_update_date']:
|
||||
assert actual_row[actual_col_name] <= expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時以前であること'
|
||||
|
||||
def test_update_record(self, expect_datetime: datetime, expect_date_str: str):
|
||||
"""
|
||||
Cases:
|
||||
COM_高度先進医療テーブルのレコードを更新する
|
||||
Arranges:
|
||||
- CSVデータを用意する
|
||||
- 追加対象となるレコードを登録する
|
||||
Expects:
|
||||
- 登録内容が期待値と一致すること
|
||||
"""
|
||||
|
||||
# Arrange
|
||||
# 処理日設定
|
||||
self.batch_config.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d')
|
||||
# テストデータ作成
|
||||
csv_floating_data_lst = [
|
||||
['001', '', '', 'A'],
|
||||
['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）', 'B'],
|
||||
['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療', 'B'],
|
||||
['004', '1', '顔面骨、頭蓋骨の観血的移動術', 'B'],
|
||||
['005', '', '造血器腫瘍のＤＮＡ診断', 'B'],
|
||||
['006', '1', '', 'B']
|
||||
]
|
||||
test_data_list = [
|
||||
f'"021","{data[0]}","{data[1]}","{data[3]}","20141113","20141114","{data[2]}","1","2014/11/21 22:53:44","VANLOAD",,,"2014/11/21 22:53:44"'
|
||||
for data in csv_floating_data_lst
|
||||
]
|
||||
test_dat_file = create_ultmarc_test_csv(test_data_list)
|
||||
|
||||
# 一旦全データをDBから削除
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_hamtec', {'1': '1'})
|
||||
self.db.execute(delete_sql, delete_parameter)
|
||||
|
||||
db_floating_data_list = [
|
||||
['001', '2', '直流電流による骨電気治療法'],
|
||||
['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）'],
|
||||
['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療'],
|
||||
['004', '1', '顔面骨、頭蓋骨の観血的移動術'],
|
||||
['005', '1', '造血器腫瘍のＤＮＡ診断'],
|
||||
['006', '1', '培養細胞による先天性代謝異常診断（胎児又は新生児に係るものに限る）']
|
||||
]
|
||||
# モジュール名
|
||||
module_name = get_module_name(com_hamtec_mapper)
|
||||
# テスト対象のデータをDBに登録
|
||||
for row in db_floating_data_list:
|
||||
code, div, name = row
|
||||
# DBに登録するテストデータ
|
||||
test_sql_data = [code, div, name] + create_ultmarc_common_column_values(
|
||||
regist_ymd=expect_date_str,
|
||||
sys_regist_date=expect_datetime,
|
||||
regist_prgm_id=module_name,
|
||||
sys_update_date=expect_datetime,
|
||||
update_prgm_id=module_name
|
||||
)
|
||||
insert_sql, insert_parameter = create_insert_sql_with_parameter(
|
||||
'src05.com_hamtec',
|
||||
self.table_columns,
|
||||
test_sql_data
|
||||
)
|
||||
self.db.execute(insert_sql, insert_parameter)
|
||||
|
||||
# sut(system under test)作成
|
||||
for i, line in enumerate(test_dat_file, start=1):
|
||||
sut: com_hamtec_mapper.ComHamtecMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_hamtec_mapper.ComHamtecMapper, f'{i}行目: マッパークラスが期待通りか'
|
||||
|
||||
# Act
|
||||
sut.make_query()
|
||||
sut.execute_queries()
|
||||
|
||||
# Assert
|
||||
# 期待値作成
|
||||
|
||||
expect_data = csv_floating_data_lst[i - 1]
|
||||
hamtec_div = expect_data[1] if expect_data[3] == 'B' else db_floating_data_list[i - 1][1]
|
||||
hamtec_name = expect_data[2] if expect_data[3] == 'B' else db_floating_data_list[i - 1][2]
|
||||
expect_row = [expect_data[0], hamtec_div, hamtec_name] + create_ultmarc_common_column_values(
|
||||
regist_ymd=expect_date_str,
|
||||
update_ymd=expect_date_str if expect_data[3] == 'B' else None, # レコードがあり、項目が設定されている場合、更新日が登録される
|
||||
sys_regist_date=expect_datetime,
|
||||
regist_prgm_id=module_name,
|
||||
sys_update_date=datetime.now() if expect_data[3] == 'B' else expect_datetime, # レコードがあり、項目が設定されている場合、更新日が登録される
|
||||
update_prgm_id=module_name
|
||||
)
|
||||
expect_rows = [{c: r for c, r in zip(self.table_columns, expect_row)}]
|
||||
actual_rows = self.db.execute_select(f"SELECT * FROM src05.com_hamtec WHERE hamtec_cd = '{expect_data[0]}'")
|
||||
|
||||
# 期待値検査
|
||||
assert_table_results(actual_rows, expect_rows, line_number=i, ignore_col_name=['sys_update_date', 'sys_regist_date'])
|
||||
# 動的日付項目の個別確認
|
||||
for actual_row, expect_row in zip(actual_rows, expect_rows):
|
||||
for actual_col_name, expect_col_name in zip(actual_row, expect_row):
|
||||
if actual_col_name == 'sys_regist_date':
|
||||
assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること'
|
||||
if actual_col_name == 'sys_update_date':
|
||||
# 更新されている場合
|
||||
if expect_data[3] == 'B':
|
||||
assert actual_row[actual_col_name] < expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時以前であること'
|
||||
else:
|
||||
assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること'
|
||||
|
||||
def test_logical_delete_record_one(self, expect_datetime: datetime, expect_date_str: str):
|
||||
"""
|
||||
Cases:
|
||||
COM_高度先進医療テーブルのレコードを論理削除する
|
||||
Arranges:
|
||||
- CSVデータを用意する
|
||||
- 追加対象となるレコードを登録する
|
||||
Expects:
|
||||
- 登録内容が期待値と一致すること
|
||||
"""
|
||||
|
||||
# Arrange
|
||||
# 処理日設定
|
||||
self.batch_config.syor_date = datetime.strftime(datetime.now(), '%Y/%m/%d')
|
||||
# テストデータ作成
|
||||
# 3カラム目、論理削除されるかどうか
|
||||
csv_floating_data_lst = [
|
||||
['001', '', '', 'A'],
|
||||
['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）', 'B'],
|
||||
['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療', 'B'],
|
||||
['004', '1', '顔面骨、頭蓋骨の観血的移動術', 'C'],
|
||||
['005', '', '造血器腫瘍のＤＮＡ診断', 'B'],
|
||||
['006', '1', '', 'B']
|
||||
]
|
||||
test_data_list = [
|
||||
f'"021","{data[0]}","{data[1]}","{data[3]}","20141113","20141114","{data[2]}","1","2014/11/21 22:53:44","VANLOAD",,,"2014/11/21 22:53:44"'
|
||||
for data in csv_floating_data_lst
|
||||
]
|
||||
test_dat_file = create_ultmarc_test_csv(test_data_list)
|
||||
# 一旦全データをDBから削除
|
||||
delete_sql, delete_parameter = create_delete_sql_with_parameter('src05.com_hamtec', {'1': '1'})
|
||||
self.db.execute(delete_sql, delete_parameter)
|
||||
|
||||
# テスト対象のデータをDBに登録
|
||||
db_floating_data_list = [
|
||||
['001', '', ''],
|
||||
['002', '1', '電磁波温熱療法（放射線療法と併用しないもの）'],
|
||||
['003', '2', '微小銅線による脳血管性病変に対しての電気的凝固治療'],
|
||||
['004', '1', '顔面骨、頭蓋骨の観血的移動術'],
|
||||
['005', '', '造血器腫瘍のＤＮＡ診断'],
|
||||
['006', '1', '']
|
||||
]
|
||||
# モジュール名
|
||||
module_name = get_module_name(com_hamtec_mapper)
|
||||
for row in db_floating_data_list:
|
||||
code, div, name = row
|
||||
# DBに登録するテストデータ
|
||||
test_sql_data = [code, div, name] + create_ultmarc_common_column_values(
|
||||
regist_ymd=expect_date_str,
|
||||
sys_regist_date=expect_datetime,
|
||||
regist_prgm_id=module_name,
|
||||
sys_update_date=expect_datetime,
|
||||
update_prgm_id=module_name
|
||||
)
|
||||
insert_sql, insert_parameter = create_insert_sql_with_parameter(
|
||||
'src05.com_hamtec',
|
||||
self.table_columns,
|
||||
test_sql_data
|
||||
)
|
||||
self.db.execute(insert_sql, insert_parameter)
|
||||
|
||||
# sut(system under test)作成
|
||||
for i, line in enumerate(test_dat_file, start=1):
|
||||
sut: com_hamtec_mapper.ComHamtecMapper = create_ultmarc_table_mapper_sut(line, self.db)
|
||||
assert type(sut) is com_hamtec_mapper.ComHamtecMapper, f'{i}行目: マッパークラスが期待通りか'
|
||||
|
||||
# Act
|
||||
sut.make_query()
|
||||
sut.execute_queries()
|
||||
|
||||
# Assert
|
||||
# 期待値作成
|
||||
expect_data = csv_floating_data_lst[i - 1]
|
||||
hamtec_div = expect_data[1] if expect_data[3] == 'B' else db_floating_data_list[i - 1][1]
|
||||
hamtec_name = expect_data[2] if expect_data[3] == 'B' else db_floating_data_list[i - 1][2]
|
||||
expect_row = [expect_data[0], hamtec_div, hamtec_name] + create_ultmarc_common_column_values(
|
||||
regist_ymd=expect_date_str,
|
||||
update_ymd=expect_date_str if expect_data[3] == 'B' else None, # メンテナンス区分!=C 更新日が登録される
|
||||
delete_ymd=expect_date_str if expect_data[3] == 'C' else None, # メンテナンス区分==C 削除日が登録される
|
||||
sys_regist_date=expect_datetime,
|
||||
regist_prgm_id=module_name,
|
||||
sys_update_date=datetime.now() if expect_data[3] != 'A' else expect_datetime,
|
||||
update_prgm_id=module_name
|
||||
)
|
||||
expect_rows = [{c: r for c, r in zip(self.table_columns, expect_row)}]
|
||||
actual_rows = self.db.execute_select(f"SELECT * FROM src05.com_hamtec WHERE hamtec_cd = '{expect_data[0]}'")
|
||||
|
||||
# 期待値検査
|
||||
assert_table_results(actual_rows, expect_rows, line_number=i, ignore_col_name=['sys_update_date', 'sys_regist_date'])
|
||||
# 動的日付項目の個別確認
|
||||
for actual_row, expect_row in zip(actual_rows, expect_rows):
|
||||
for actual_col_name, expect_col_name in zip(actual_row, expect_row):
|
||||
if actual_col_name == 'sys_regist_date':
|
||||
assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること'
|
||||
if actual_col_name == 'sys_update_date':
|
||||
if expect_data[3] != 'A':
|
||||
assert actual_row[actual_col_name] <= expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時以前であること'
|
||||
else:
|
||||
assert actual_row[actual_col_name] == expect_row[expect_col_name], f'{i}行目:{actual_col_name}が、期待値の日時と一致すること'
|
||||
Loading…
x
Reference in New Issue
Block a user