kevinveenbirkenbach/baserow-ifto
1
0
Fork 0
mirror of https://github.com/kevinveenbirkenbach/baserow-ifto.git synced 2024-11-25 20:31:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

added new variable

Browse Source
This commit is contained in:
Kevin Veen-Birkenbach 2023-09-05 02:44:23 +02:00
parent 1e36759a21
commit cdcdbd1293
1 changed files with 15 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
matrix_builder.py
View File

@ -4,31 +4,32 @@ class MatrixBuilder:
def __init__(self, data_processor, tables_data, verbose=False): def __init__(self, data_processor, tables_data, verbose=False):
self.data_processor = data_processor self.data_processor = data_processor
self.tables_data = tables_data self.tables_data = tables_data
self.lazy_loaded_tables_data = {} # Neue Arbeitsvariable
self.verbose = verbose self.verbose = verbose
self.matrix = {} # Klassenvariable
def build_multitable_matrix(self): def build_multitable_matrix(self):
matrix = {}
for table_name, table_rows in self.tables_data.items(): for table_name, table_rows in self.tables_data.items():
self.print_verbose_message(f"Building matrix for table: {table_name}") self.print_verbose_message(f"Building matrix for table: {table_name}")
matrix[table_name] = self._build_matrix_for_table(table_name, table_rows.copy()) self.matrix[table_name] = self._build_matrix_for_table(table_name, table_rows.copy())
return matrix return self.matrix
def _build_matrix_for_table(self, table_name, table_rows, reference_map={}): def _build_matrix_for_table(self, table_name, table_rows, reference_map={}):
self.print_verbose_message(f"Starting matrix build for table: {table_name}") self.print_verbose_message(f"Starting matrix build for table: {table_name}")
matrix = {table_name: table_rows} self.matrix[table_name] = table_rows
reference_map = reference_map.copy() reference_map = reference_map.copy()
self._process_link_fields(table_name, reference_map) self._process_link_fields(table_name, reference_map)
self._populate_matrix_with_related_content(matrix, table_name, table_rows, reference_map) self._populate_matrix_with_related_content(table_name, table_rows, reference_map)
return matrix[table_name] return self.matrix[table_name]
def _populate_matrix_with_related_content(self, matrix, table_name, table_rows, reference_map): def _populate_matrix_with_related_content(self, table_name, table_rows, reference_map):
for table_row in table_rows: for table_row in table_rows:
for column_name, cell_content in table_row.items(): for column_name, cell_content in table_row.items():
if column_name in reference_map: if column_name in reference_map:
self.print_verbose_message(f"Handling linked content for column: {column_name}") self.print_verbose_message(f"Handling linked content for column: {column_name}")
self._handle_linked_content(matrix, table_row, column_name, cell_content, reference_map) self._handle_linked_content(table_row, column_name, cell_content, reference_map)
def _handle_linked_content(self, matrix, table_row, column_name, cell_content, reference_map): def _handle_linked_content(self, table_row, column_name, cell_content, reference_map):
link_table_id = reference_map[column_name]["link_row_table_id"] link_table_id = reference_map[column_name]["link_row_table_id"]
link_field_id = reference_map[column_name]["link_row_related_field_id"] link_field_id = reference_map[column_name]["link_row_related_field_id"]
@ -36,17 +37,17 @@ class MatrixBuilder:
raise Exception("link_row_related_field_id has to be a positive number") raise Exception("link_row_related_field_id has to be a positive number")
self.print_verbose_message(f"Fetching related content for table ID: {link_table_id} and field ID: {link_field_id}") self.print_verbose_message(f"Fetching related content for table ID: {link_table_id} and field ID: {link_field_id}")
new_content = self._fetch_related_content(matrix, cell_content, link_table_id, link_field_id, reference_map) new_content = self._fetch_related_content(cell_content, link_table_id, link_field_id, reference_map)
table_row[column_name] = new_content table_row[column_name] = new_content
def _fetch_related_content(self, matrix, cell_content, link_table_id, link_field_id, reference_map): def _fetch_related_content(self, cell_content, link_table_id, link_field_id, reference_map):
new_content = [] new_content = []
for entry in cell_content: for entry in cell_content:
related_cell_id = self._generate_related_cell_identifier(link_table_id, link_field_id, entry["id"]) related_cell_id = self._generate_related_cell_identifier(link_table_id, link_field_id, entry["id"])
self.print_verbose_message(f"Generated related cell identifier: {related_cell_id}") self.print_verbose_message(f"Generated related cell identifier: {related_cell_id}")
if related_cell_id not in reference_map.get("embeded", []): if related_cell_id not in reference_map.get("embeded", []):
reference_map.setdefault("embeded", []).append(related_cell_id) reference_map.setdefault("embeded", []).append(related_cell_id)
matrix[link_table_id] = self._build_matrix_for_table(link_table_id, self.tables_data[link_table_id].copy(), reference_map) self.matrix[link_table_id] = self._build_matrix_for_table(link_table_id, self.lazy_loaded_tables_data.get(link_table_id, []).copy(), reference_map)
new_content.append(entry) new_content.append(entry)
return new_content return new_content
@ -62,9 +63,9 @@ class MatrixBuilder:
def _load_table_data_if_missing(self, link_field): def _load_table_data_if_missing(self, link_field):
link_table_id = link_field["link_row_table_id"] link_table_id = link_field["link_row_table_id"]
if link_table_id not in self.tables_data: if link_table_id not in self.lazy_loaded_tables_data:
self.print_verbose_message(f"Loading data for missing table ID: {link_table_id}") self.print_verbose_message(f"Loading data for missing table ID: {link_table_id}")
self.tables_data[link_table_id] = self.data_processor.get_all_rows_from_table(link_table_id) self.lazy_loaded_tables_data[link_table_id] = self.data_processor.get_all_rows_from_table(link_table_id)
def _update_reference_map(self, link_field, reference_map): def _update_reference_map(self, link_field, reference_map):
field_name = f"field_{link_field['id']}" field_name = f"field_{link_field['id']}"