airflow.providers.informatica.lineage.sql_parser¶

Attributes¶

log

Classes¶

TableRef

Represents a parsed table reference with optional schema and database qualifiers.

Functions¶

parse_sql_tables(sql[, dialect])

Parse SQL and return (source_tables, target_tables).

Module Contents¶

airflow.providers.informatica.lineage.sql_parser.log[source]¶

class airflow.providers.informatica.lineage.sql_parser.TableRef[source]¶

Represents a parsed table reference with optional schema and database qualifiers.

table: str[source]¶

schema: str | None = None[source]¶

database: str | None = None[source]¶

airflow.providers.informatica.lineage.sql_parser.parse_sql_tables(sql, dialect=None)[source]¶

Parse SQL and return (source_tables, target_tables).

Source tables are those read by FROM/JOIN clauses. Target tables are those written by INSERT INTO, CREATE TABLE AS, or MERGE INTO. Returns empty lists when SQL cannot be parsed instead of raising.