xml2db data flow test

xml2db_data_flow_test.py

import pandas as pd
import xml2db

data_model = xml2db.DataModel.create_from_xsd_file(
  xsd_file=xsd_path,
  db_schema=db_schema,
  connection_string=connection_string,
  model_config=model_config,
)
document = data_model.parse_xml(
  xml_file="tests/remit_data_flow_tests/remit_table1_v2_anonymized_input.xml"
)
document.insert_into_target_tables()
result_df = pd.read_sql_query(con=sql_engine, sql="select * from the_whole_joined_schema")

with open(
        r"tests/remit_data_flow_tests/remit_table1_v2_expected_output.pickle", "rb"
) as f:
  expected_df = pickle.load(f)

pd.testing.assert_frame_equal(result, expected_df)