Source: factory.core/ObjSimulation.py
Extends ObjData to provide simulation-specific functionality including
table reference tracking during simulation runs.
| Method | Signature | Description |
|---|---|---|
| enable_table_tracking | enable_table_tracking(simulation_guid: str, module_name: str, simulation_guid_sql: Optional[str] = None) -> None |
Enable table tracking for a simulation run. |
| flush_tracked_tables | flush_tracked_tables() -> None |
Persist currently tracked tables to database without disabling tracking. |
| disable_table_tracking | disable_table_tracking() -> None |
Disable table tracking and persist tracked data. |
| track_sql | track_sql(sql: str) -> None |
|
| get_simulation_guid_sql | get_simulation_guid_sql() -> Optional[str] |
Returns the SQL query used to retrieve simulation GUIDs. |
| get_tracked_tables | get_tracked_tables() -> Dict[str, Set[str]] |
|
| get_simulation_table_usage | get_simulation_table_usage(simulation_guid: str) -> list |
Retrieve all table usage for a specific simulation run. |
| create_simulation_tables | create_simulation_tables() -> None |
Create the def_simulation_table if it doesn't exist. |
| sql_format | sql_format(sql: str) -> str |
|
| sql_status | sql_status() -> str |
|
| sql_read_object | sql_read_object(in_sql: str, DB = 0, fields = '', prefix = '_') -> int |
|
| sql_execute | sql_execute(sql: str, alt_db = 0) -> tuple |
|
| sql_execute_many | sql_execute_many(sql: str, data: list, alt_db = 0) -> tuple |
|
| sql_get_normalized_headings | sql_get_normalized_headings(table_name: str) -> tuple |
|
| sql_get_normalized_data | sql_get_normalized_data(table_name: str, columns: list, pk_values: list = None) -> list |
|
| sql_compare_tables | sql_compare_tables(table1: str, table2: str) -> bool |
|
| sql_get_value | sql_get_value(sql: str, alt_db = 0) -> str |
|
| sql_get_value_buffer | sql_get_value_buffer(sql: str, alt_db = 0) -> str |
|
| sql_get_int | sql_get_int(sql: str, alt_db = 0) -> int |
|
| sql_get_int_buffer | sql_get_int_buffer(sql: str, alt_db = 0) -> int |
|
| sql_get_values | sql_get_values(sql: str, alt_db = 0) -> list |
|
| sql_get_values_buffer | sql_get_values_buffer(sql: str, remote_db = 0) -> list |
|
| sql_get_values_dict | sql_get_values_dict(sql: str, alt_db = 0) -> dict |
|
| sql_get_tuple | sql_get_tuple(sql: str, alt_db = 0) -> tuple |
|
| sql_get_tuple_set | sql_get_tuple_set(sql: str, alt_db = 0) -> list |
|
| sql_get_tuple_buffer | sql_get_tuple_buffer(sql: str, alt_db = 0) -> tuple |
|
| sql_get_value_int | sql_get_value_int(sql: str) -> int |
|
| sql_get_dict | sql_get_dict(sql: str, alt_db = 0) -> dict |
|
| sql_get_dictionary_list | sql_get_dictionary_list(sql: str, alt_db = 0, base_col: str = '', lower_limit: int = -1, upper_limit: int = -1) -> list |
|
| sql_get_dataframe | sql_get_dataframe(sql: str, alt_db = 0) |
|
| sql_get_dictionary | sql_get_dictionary(sql: str, alt_db = 0) -> dict |
|
| sql_get_frame | sql_get_frame(sql: str, alt_db = 0) |
|
| sql_get_dict_buffer | sql_get_dict_buffer(sql: str, alt_db = 0) -> dict |
|
| sql_get_series | sql_get_series(sql: str, alt_db = 0) -> list |
|
| sql_get_list_buffer | sql_get_list_buffer(sql: str, alt_db = 0) -> list |
|
| sql_get_set | sql_get_set(sql: str, alt_db = 0) -> list |
|
| sql_get_array | sql_get_array(sql: str, alt_db = 0) -> list |
|
| sql_get_pandas_data_frame | sql_get_pandas_data_frame(sql: str, alt_db = 0) |
|
| sql_get_array_and_headings | sql_get_array_and_headings(sql: str, alt_db = 0) -> tuple |
|
| sql_get_headings | sql_get_headings(sql: str, alt_db = 0) -> list |
|
| sql_get_headings_full | sql_get_headings_full(sql: str, alt_db = 0) -> list |
|
| sql_get_headings_full_buffer | sql_get_headings_full_buffer(sql: str, alt_db = 0) -> list |
|
| sql_get_list | sql_get_list(sql: str, alt_db = 0) -> list |
Parses a SQL statement and returns the tables read from and written to.
Tests the SQL parsing logic against predefined queries in ObjSimulation.yaml.