docs/apache-airflow-providers-common-sql/1.10.0/searchindex.js

Search.setIndex({"docnames": ["_api/airflow/providers/common/sql/hooks/index", "_api/airflow/providers/common/sql/hooks/sql/index", "_api/airflow/providers/common/sql/index", "_api/airflow/providers/common/sql/operators/index", "_api/airflow/providers/common/sql/operators/sql/index", "_api/airflow/providers/common/sql/sensors/index", "_api/airflow/providers/common/sql/sensors/sql/index", "_api/tests/system/providers/common/sql/example_sql_column_table_check/index", "_api/tests/system/providers/common/sql/example_sql_execute_query/index", "_api/tests/system/providers/common/sql/index", "changelog", "commits", "connections", "index", "installing-providers-from-sources", "operators", "security"], "filenames": ["_api/airflow/providers/common/sql/hooks/index.rst", "_api/airflow/providers/common/sql/hooks/sql/index.rst", "_api/airflow/providers/common/sql/index.rst", "_api/airflow/providers/common/sql/operators/index.rst", "_api/airflow/providers/common/sql/operators/sql/index.rst", "_api/airflow/providers/common/sql/sensors/index.rst", "_api/airflow/providers/common/sql/sensors/sql/index.rst", "_api/tests/system/providers/common/sql/example_sql_column_table_check/index.rst", "_api/tests/system/providers/common/sql/example_sql_execute_query/index.rst", "_api/tests/system/providers/common/sql/index.rst", "changelog.rst", "commits.rst", "connections.rst", "index.rst", "installing-providers-from-sources.rst", "operators.rst", "security.rst"], "titles": ["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql.hooks</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql.hooks.sql</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql.operators</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql.operators.sql</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql.sensors</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.common.sql.sensors.sql</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.common.sql.example_sql_column_table_check</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.common.sql.example_sql_execute_query</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.common.sql</span></code>", "Changelog", "Package apache-airflow-providers-common-sql", "Connecting to a SQL DB", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-common-sql</span></code>", "Installing from sources", "SQL Operators", "Releasing security patches"], "terms": {"1": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16], "10": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 12, 13, 14, 15, 16], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16], "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16], "9": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16], "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 12, 13, 14, 15, 16], "t": [1, 10, 11, 15], "sourc": [1, 2, 4, 6, 7, 8, 15], "return_single_query_result": 1, "return_last": [1, 4, 15], "split_stat": [1, 4, 10, 11, 15], "determin": 1, "when": [1, 4, 6, 10, 11, 13, 15, 16], "result": [1, 4, 10, 15], "singl": [1, 4, 10, 15], "queri": [1, 4, 6, 10, 11], "onli": [1, 4, 6, 10, 15, 16], "should": [1, 4, 6, 10, 14, 16], "return": [1, 4, 6, 10, 11, 15], "For": [1, 4, 11, 12, 13, 14], "compat": [1, 15], "reason": [1, 16], "behaviour": [1, 10, 11], "dbapihook": [1, 4, 10, 11], "somewhat": 1, "confus": 1, "In": 1, "some": 1, "case": [1, 4, 6, 16], "multipl": 1, "ar": [1, 4, 6, 10, 13, 14, 15, 16], "run": [1, 4, 6, 10, 11, 14, 15], "valu": [1, 4, 6, 10, 11], "iter": [1, 4], "list": [1, 4, 11, 15], "one": [1, 4, 6, 14], "each": [1, 4, 15], "howev": 1, "other": [1, 4, 10, 11, 12, 15], "just": [1, 15], "without": [1, 4], "wrap": 1, "The": [1, 4, 6, 12, 13, 14, 15, 16], "them": [1, 13], "follow": [1, 4, 11, 14, 16], "string": [1, 4, 6, 10, 11, 15], "true": [1, 4, 15], "regardless": 1, "what": 1, "fals": [1, 4, 6, 10, 11, 15], "all": [1, 10, 11, 13, 15, 16], "even": 1, "statement": [1, 4, 6, 10, 11, 15], "process": [1, 4, 10, 11], "particular": 1, "circumst": 1, "paramet": [1, 4, 6, 10, 11, 12, 15], "str": [1, 4, 6, 11], "either": [1, 6, 15], "bool": [1, 4], "whether": [1, 4, 10], "last": [1, 4, 10, 15], "output": [1, 4, 10, 11], "split": [1, 4, 10, 11, 15], "fetch_all_handl": [1, 4, 10, 11, 15], "cursor": [1, 4, 10, 11, 15], "fetch_one_handl": 1, "first": [1, 4, 6, 15], "connectorprotocol": [1, 10], "base": [1, 4, 6], "protocol": 1, "databas": [1, 4, 12, 15], "connect": [1, 4, 6, 15], "host": 1, "port": [1, 10, 11], "usernam": 1, "schema": [1, 10, 11], "int": [1, 4, 15], "us": [1, 4, 10, 11, 13, 14, 15, 16], "authent": 1, "author": [1, 10, 11], "object": [1, 4], "type": [1, 4, 10, 11], "ani": [1, 4, 10, 11, 12, 14, 15], "arg": [1, 12], "none": [1, 4, 6, 14, 15], "log_sql": 1, "kwarg": [1, 4, 6], "basehook": 1, "abstract": 1, "subclass": 1, "maintain": 1, "can": [1, 4, 6, 10, 12, 13, 14, 15, 16], "overrid": [1, 4, 6, 10, 11], "_make_common_data_structur": 1, "method": [1, 4, 10, 11], "transform": 1, "handler": [1, 4, 15], "typic": 1, "fetchal": 1, "across": [1, 15], "deriv": [1, 4, 6, 10, 11], "from": [1, 4, 10, 11, 13, 15, 16], "tupl": 1, "most": [1, 14], "time": 1, "underli": [1, 6], "librari": 1, "alreadi": [1, 14], "its": [1, 11, 15], "ignor": [1, 4], "option": [1, 4, 6, 10, 11, 15], "db": [1, 4, 10, 11], "specifi": [1, 4, 10, 11, 13, 15], "make": [1, 10, 11], "sure": 1, "you": [1, 4, 10, 13, 14, 16], "chang": [1, 11, 16], "constructor": [1, 6], "done": [1, 16], "befor": [1, 4, 6], "call": [1, 6], "__init__": 1, "log": [1, 4, 10, 11], "": [1, 4, 11, 14, 15], "execut": [1, 4, 10, 11], "default": [1, 4, 10, 11, 15, 16], "properti": [1, 10], "placehold": [1, 10, 11], "last_descript": [1, 10], "sequenc": [1, 4, 6], "conn_name_attr": 1, "default_conn_nam": 1, "default_conn_id": [1, 4], "supports_autocommit": 1, "connector": 1, "get_conn": 1, "get_uri": 1, "extract": 1, "uri": 1, "get_sqlalchemy_engin": 1, "engine_kwarg": 1, "get": [1, 4, 10, 11, 14, 16], "sqlalchemy_engin": 1, "create_engin": 1, "creat": [1, 4, 14], "engin": [1, 10, 11], "get_pandas_df": 1, "panda": [1, 10, 11], "datafram": 1, "map": [1, 4, 15], "render": [1, 4, 6, 10, 11, 15], "pass": [1, 4, 6, 10, 11, 12], "io": 1, "read_sql": 1, "get_pandas_df_by_chunk": 1, "chunksiz": 1, "gener": [1, 4, 11], "number": [1, 4, 15], "row": [1, 4, 6, 11, 15], "includ": [1, 10, 11, 15, 16], "chunk": 1, "get_record": [1, 10, 11], "set": [1, 4, 10, 11, 15], "record": [1, 4, 10, 11], "get_first": [1, 10, 11], "static": [1, 11], "strip_sql_str": 1, "split_sql_str": 1, "express": [1, 4], "potenti": 1, "consist": [1, 10, 11], "individu": 1, "autocommit": [1, 4, 15], "callabl": [1, 4, 6], "command": [1, 4, 15], "sequenti": 1, "those": [1, 13, 14], "where": [1, 4, 15, 16], "element": 1, "d": [1, 4, 14], "after": 1, "mai": [1, 4, 11, 15], "access": [1, 12], "descript": [1, 4, 10], "arrai": 1, "If": [1, 4, 6, 14, 15], "contain": [1, 4, 6, 11, 14], "otherwis": [1, 4], "note": [1, 4], "actual": 1, "wai": 1, "suitabl": 1, "xcom": [1, 10], "fit": 1, "memori": 1, "pre": [1, 10, 11], "defin": [1, 4, 6], "handl": [1, 10, 11], "implement": [1, 4], "your": [1, 4], "own": 1, "which": [1, 4, 6, 10, 11, 15, 16], "separ": [1, 15, 16], "depend": [1, 4, 15, 16], "param": [1, 6], "set_autocommit": 1, "conn": [1, 10, 11], "flag": 1, "get_autocommit": 1, "doe": 1, "support": [1, 10, 11, 13], "auto": 1, "commit": [1, 4, 11, 15], "get_cursor": 1, "insert_row": [1, 10, 11], "tabl": [1, 4, 10, 11], "target_field": 1, "commit_everi": 1, "1000": [1, 4, 15], "replac": 1, "insert": 1, "collect": 1, "size": 1, "new": [1, 10, 11, 16], "transact": 1, "name": [1, 4, 15], "target": 1, "column": [1, 4], "fill": 1, "maximum": [1, 4, 15], "instead": 1, "bulk_dump": 1, "tmp_file": 1, "dump": [1, 4], "tab": 1, "delimit": 1, "file": [1, 4, 11, 14, 15], "path": [1, 4], "bulk_load": 1, "load": 1, "test_connect": 1, "test": [1, 10, 11, 15, 16], "specif": [1, 4], "get_openlineage_database_info": 1, "inform": [1, 4, 10, 11, 16], "need": [1, 6, 13], "pars": [1, 4], "lineag": 1, "metadata": [1, 4], "help": 1, "construct": [1, 10, 11], "correct": [1, 14], "namespac": 1, "reduc": 1, "get_connect": 1, "get_openlineage_database_dialect": 1, "dialect": 1, "check": [1, 4, 10, 11, 14], "http": [1, 14], "openlineag": [1, 10, 11, 13], "doc": [1, 10, 11], "develop": [1, 16], "get_openlineage_default_schema": 1, "sqlparser": 1, "get_openlineage_database_specific_lineag": 1, "task_inst": [1, 4], "addit": [1, 4, 12], "e": [1, 4], "g": [1, 4], "complet": 1, "task": [1, 4, 15], "retriev": [1, 4], "dure": 1, "runtim": 1, "get_openlineage_authority_part": 1, "default_port": 1, "part": [1, 10], "repres": 1, "hostnam": 1, "conform": 1, "convent": 1, "mysql": 1, "postgr": 1, "trino": 1, "hook": [2, 4, 6, 10, 11, 12], "oper": [2, 10, 11, 12], "sensor": 2, "__version__": [2, 11], "basesqloper": 4, "conn_id": [4, 6], "hook_param": [4, 6], "retry_on_failur": 4, "model": [4, 16], "baseoper": 4, "get_db_hook": 4, "behavior": 4, "try": [4, 6], "custom": 4, "refer": 4, "conn_id_field": 4, "sqlexecutequeryoper": [4, 10, 11, 15], "show_return_value_in_log": 4, "code": [4, 10, 11, 14], "also": [4, 6, 10, 14, 15], "_process_output": [4, 10], "perform": [4, 15], "exampl": [4, 11, 13, 14, 15], "join": 4, "save": 4, "point": [4, 15], "templat": [4, 10, 11, 15], "must": [4, 15], "have": [4, 6, 10, 16], "extens": 4, "automat": [4, 15], "function": [4, 10, 11, 15], "appli": [4, 11, 15], "By": [4, 14], "defer": [4, 10, 11], "configur": [4, 10, 11], "id": [4, 10, 11, 14, 15], "overwrit": 4, "print": 4, "caution": 4, "It": [4, 14], "recommend": [4, 14], "larg": 4, "dataset": 4, "more": [4, 10, 11, 12], "how": [4, 14, 15], "take": [4, 6], "look": [4, 15], "guid": [4, 14], "template_field": [4, 6], "template_ext": [4, 6], "json": [4, 10, 11], "template_fields_render": 4, "ui_color": [4, 6], "cdaa": 4, "context": [4, 6], "same": [4, 15], "dictionari": [4, 15], "jinja": 4, "get_template_context": 4, "prepare_templ": 4, "attribut": 4, "get_openlineage_facets_on_start": 4, "get_openlineage_facets_on_complet": 4, "sqlcolumncheckoper": [4, 10, 15], "column_map": [4, 15], "partition_claus": [4, 15], "accept_non": [4, 15], "column_check": [4, 7, 15], "per": 4, "basi": 4, "equal_to": [4, 15], "exact": 4, "equal": 4, "cannot": 4, "comparison": 4, "greater_than": [4, 15], "strictli": 4, "greater": 4, "than": 4, "less_than": [4, 15], "less": [4, 10, 11], "geq_to": [4, 15], "leq_to": [4, 15], "toler": [4, 15], "percentag": [4, 10, 11, 15], "off": 4, "expect": 4, "extra": [4, 6, 13], "claus": [4, 15], "partit": [4, 15], "data": [4, 10, 11, 15], "dict": [4, 10, 11], "associ": 4, "col_nam": [4, 15], "null_check": [4, 15], "foreign_kei": 4, "NOT": [4, 15], "null": [4, 15], "min": [4, 10, 11, 15], "5": [4, 15], "max": [4, 15], "01": [4, 11, 15], "partial": 4, "ad": 4, "built": 4, "date": 4, "1970": 4, "accept": 4, "convert": [4, 15], "sql_check_templ": 4, "multilin": 4, "show": [4, 10, 11, 15], "select": [4, 14, 15], "AS": 4, "check_typ": 4, "_": 4, "check_result": 4, "check_stat": [4, 15], "sq": 4, "sqltablecheckoper": [4, 10, 11, 15], "written": 4, "boolean": [4, 6, 15], "least": [4, 6], "row_count_check": [4, 15], "count": [4, 15], "column_sum_check": [4, 15], "col_a": [4, 15], "col_b": [4, 15], "col_c": [4, 15], "third_check": 4, "col": 4, "check_nam": 4, "THEN": 4, "els": 4, "end": 4, "sqlcheckoper": [4, 10, 11], "against": [4, 6, 15], "evalu": [4, 6, 11], "python": [4, 10, 11, 13, 14], "cast": 4, "fail": [4, 6, 10, 11], "error": [4, 10, 11], "out": [4, 11, 15, 16], "eval": 4, "empti": [4, 6, 15], "duplicate_id_check": 4, "given": [4, 15], "like": [4, 12, 15], "foo": 4, "craft": 4, "much": 4, "complex": 4, "could": 4, "instanc": 4, "ha": [4, 10], "upstream": 4, "todai": 4, "yesterdai": 4, "metric": 4, "3": 4, "standard": 4, "deviat": 4, "7": 4, "dai": 4, "averag": 4, "qualiti": [4, 15], "pipelin": 4, "put": 4, "dag": 4, "choic": 4, "stop": 4, "critic": [4, 16], "prevent": [4, 11], "publish": [4, 16], "dubiou": 4, "side": 4, "receiv": [4, 16], "email": 4, "alert": 4, "progress": 4, "hql": [4, 6, 10, 11], "fff7e6": 4, "sqlvaluecheckoper": 4, "pass_valu": 4, "simpl": 4, "__mapper_args__": 4, "check_valu": 4, "sqlintervalcheckoper": 4, "metrics_threshold": 4, "date_filter_column": 4, "days_back": 4, "ratio_formula": 4, "max_over_min": 4, "ignore_zero": 4, "within": 4, "ones": 4, "supportsab": 4, "between": [4, 15], "we": [4, 16], "want": [4, 14, 16], "filter": [4, 15], "formula": 4, "comput": 4, "ratio": 4, "two": [4, 15], "assum": 4, "cur": 4, "ref": 4, "relative_diff": 4, "ab": 4, "zero": [4, 6], "index": 4, "sql1": 4, "sql2": 4, "sqlthresholdcheckoper": 4, "min_threshold": 4, "max_threshold": 4, "minimum": [4, 10, 11, 13, 15], "threshold": 4, "form": 4, "numer": [4, 10, 11], "OR": 4, "push": 4, "meta_data": 4, "send": 4, "info": 4, "extern": 4, "branchsqloper": 4, "follow_task_ids_if_tru": 4, "follow_task_ids_if_fals": 4, "skipmixin": 4, "allow": [4, 10, 11, 12, 15], "branch": [4, 16], "recogn": 4, "integ": [4, 15], "y": 4, "ye": 4, "n": 4, "a22034": 4, "ui_fgcolor": 4, "f7f7f7": 4, "sqlsensor": [6, 10, 11], "success": [6, 15], "failur": 6, "fail_on_empti": 6, "basesensoroper": 6, "repeatedli": 6, "until": 6, "criteria": 6, "met": 6, "keep": 6, "cell": 6, "argument": [6, 10, 11, 15], "retri": 6, "rais": [6, 10, 11], "airflowexcept": [6, 10, 11], "A": [6, 11, 15], "been": 6, "To": [6, 14], "non": [6, 10, 11], "first_cel": 6, "explicitli": 6, "config": 6, "match": [6, 14], "desir": 6, "7c7287": 6, "poke": 6, "airflow_db_metadata_t": [7, 8, 15], "ab_rol": [7, 8], "connection_arg": [7, 8], "test_run": [7, 8], "execute_queri": [8, 15], "example_sql_column_table_check": [9, 15], "example_sql_execute_queri": [9, 15], "apach": [10, 14], "airflow": [10, 14, 15, 16], "provid": [10, 12, 14, 15, 16], "common": [10, 14, 15], "sql": [10, 14], "odbc": [10, 11], "ui": [10, 11], "36000": [10, 11], "structur": [10, 11], "dbapi": [10, 11, 12], "class": [10, 11, 13], "36273": [10, 11], "releas": [10, 11, 13], "avail": [10, 14], "explain": 10, "polici": [10, 16], "bump": [10, 11], "version": [10, 11, 13, 14, 16], "36017": [10, 11], "add": [10, 11], "architectur": [10, 11], "decis": [10, 11], "introduct": [10, 11], "36015": [10, 11], "_make_serializ": 10, "serializ": [10, 11], "32319": [10, 11], "remov": [10, 11, 14], "backcompat": [10, 11], "inherit": [10, 11], "35754": [10, 11], "respect": [10, 11], "soft_fail": [10, 11], "except": [10, 11, 16], "34199": [10, 11], "34728": [10, 11], "34511": [10, 11], "bigqueryvaluecheckoper": [10, 11], "deferr": [10, 11], "mode": [10, 11], "optimis": [10, 11], "34018": [10, 11], "refactor": [10, 11], "regex": [10, 11], "33898": [10, 11], "better": [10, 11], "format": [10, 11], "33595": [10, 11], "simplifi": [10, 11], "smaller": [10, 11], "33234": [10, 11], "field": [10, 11], "30784": [10, 11], "sqlexecut": [10, 11], "signatur": [10, 11, 13, 14], "32974": [10, 11], "rid": [10, 11], "python2": [10, 11], "relic": [10, 11], "33050": [10, 11], "local": [10, 11, 14], "import": [10, 11, 14], "32400": [10, 11], "32828": [10, 11], "accur": [10, 11], "31846": [10, 11], "ol": [10, 11], "parser": [10, 11], "intern": [10, 11], "api": [10, 11], "31398": [10, 11], "sqlalchemi": [10, 11], "32371": [10, 11], "30963": [10, 11], "bring": [10, 11], "back": [10, 11], "preinstal": [10, 11], "31469": [10, 11], "condit": [10, 11, 15], "31136": [10, 11], "noisi": [10, 11], "31037": [10, 11], "29954": [10, 11], "29863": [10, 11], "do": [10, 11, 12, 14], "do_xcom_push": [10, 11], "29599": [10, 11], "compliant": [10, 11], "exasol": [10, 11], "28744": [10, 11], "isort": [10, 11], "problem": [10, 11], "introduc": [10, 11], "recent": [10, 11], "28434": [10, 11], "28202": [10, 11], "28635": [10, 11], "clarifi": [10, 11], "docstr": [10, 11], "updat": [10, 11], "27966": [10, 11], "few": 10, "were": 10, "while": 10, "now": 10, "semant": 10, "modifi": 10, "store": 10, "expos": 10, "via": [10, 11, 13, 14], "lack": 10, "caus": [10, 11], "yank": 10, "instal": [10, 16], "upgrad": [10, 11, 16], "restor": [10, 11], "27843": [10, 11], "databrick": [10, 11], "27854": [10, 11], "27888": [10, 11], "final": [10, 11], "27912": [10, 11], "move": [10, 11], "27196": [10, 11], "25717": [10, 11], "26944": [10, 11], "26758": [10, 11], "bugfix": [10, 11, 16], "improv": [10, 11], "26761": [10, 11], "unus": [10, 11], "27599": [10, 11], "style": [10, 11], "25939": [10, 11], "messag": 10, "26051": [10, 11], "postgresql": [10, 11], "25821": [10, 11], "don": [10, 11], "25822": [10, 11], "discard": [10, 11], "semicolon": [10, 11], "strip": [10, 11], "25855": [10, 11], "taskflow": 10, "hint": 10, "paramspec": 10, "25173": 10, "old": [10, 11], "25350": [10, 11], "deprec": [10, 11], "synchron": [10, 11], "25299": [10, 11], "unifi": [10, 11], "23971": [10, 11], "variou": [10, 11, 12, 15], "25164": [10, 11], "legaci": [10, 11], "25293": [10, 11], "25430": [10, 11], "align": [10, 11], "logo": [10, 11], "locat": [10, 11], "25538": [10, 11], "25713": [10, 11], "initi": 10, "detail": [11, 14], "high": 11, "level": [11, 15], "changelog": 11, "see": [11, 13], "latest": [11, 16], "2023": 11, "12": [11, 14], "22": 11, "subject": 11, "5fe5d31a46": 11, "f84eb2ab6f": 11, "21": 11, "5c1d8f40a1": 11, "20": 11, "08": 11, "999b70178a": 11, "prepar": [11, 16], "1st": 11, "wave": 11, "decemb": 11, "36112": 11, "d0918d77ee": 11, "07": 11, "3bb5978e63": 11, "06": 11, "11": [11, 14], "24": 11, "0b23d5601c": 11, "2nd": 11, "novemb": 11, "35836": 11, "2a469b3713": 11, "99534e47f3": 11, "19": 11, "reproduc": 11, "build": [11, 14, 15], "35693": 11, "064fc2b775": 11, "17": 11, "pyodbc": 11, "make_serializ": 11, "99df205f42": 11, "16": 11, "fix": [11, 16], "reappli": 11, "document": 11, "35686": 11, "1b059c57d6": 11, "35537": 11, "11bdfe4c12": 11, "work": 11, "around": 11, "issu": 11, "35494": 11, "d1c58d86de": 11, "28": 11, "3rd": 11, "octob": 11, "35233": 11, "3592ff4046": 11, "35187": 11, "dd7ba3cae1": 11, "ruff": 11, "292": 11, "35053": 11, "b75f9e8806": 11, "18": 11, "35033": 11, "f23170c9dd": 11, "d401": 11, "thru": 11, "inclus": 11, "34934": 11, "13": 11, "e9987d5059": 11, "34916": 11, "128f6b9e40": 11, "miss": 11, "header": 11, "34910": 11, "0c8e30e43b": 11, "05": 11, "7ebf4220c9": 11, "09": 11, "usag": 11, "34320": 11, "659d94f0ae": 11, "f5c2748c33": 11, "21990ed894": 11, "34201": 11, "a7310f9c91": 11, "d757f6a3af": 11, "03": 11, "26": 11, "c077d19060": 11, "aug": 11, "33730": 11, "92474db6a5": 11, "23": 11, "a54c2424df": 11, "typo": 11, "doubl": 11, "word": [11, 12], "33623": 11, "a91ee7ac2f": 11, "b5a4d36383": 11, "33291": 11, "9736143468": 11, "60677b0ba3": 11, "33128": 11, "cfac7d379f": 11, "04": 11, "e3d82c6be0": 11, "29": 11, "d06b7af69a": 11, "juli": 11, "32875": 11, "ce2841bf6a": 11, "25": 11, "60c49ab2df": 11, "ef0ed1aacc": 11, "225e3041d2": 11, "rc2": 11, "32381": 11, "3878fe6fab": 11, "spuriou": 11, "32373": 11, "ee4a838d49": 11, "cb4927a018": 11, "32298": 11, "f2e2125b07": 11, "8c37b74a20": 11, "d205": 11, "32226": 11, "09d4718d3a": 11, "27": 11, "readm": 11, "32125": 11, "79bcc2e668": 11, "rc1": 11, "june": 11, "32001": 11, "9276310a43": 11, "31681": 11, "a59076eae": 11, "02": 11, "d400": 11, "pydocstyl": 11, "31427": 11, "9fa75aaf7a": 11, "d745cee3db": 11, "adhoc": 11, "31478": 11, "547e352578": 11, "45548b9451": 11, "31416": 11, "abea189022": 11, "31393": 11, "f5aed58d9f": 11, "circular": 11, "31379": 11, "d9ff55cf6d": 11, "31252": 11, "edd7133a13": 11, "00a527f671": 11, "eef5bc7f16": 11, "full": 11, "autom": 11, "30994": 11, "d23a3bbed8": 11, "mechan": 11, "suspend": 11, "30422": 11, "55dbf1ff1f": 11, "april": 11, "30378": 11, "a9b79a27b2": 11, "95710e0cdd": 11, "fcd3c0149f": 11, "29878": 11, "19f1e7c27b": 11, "0af6f20c5f": 11, "30": 11, "s3": 11, "system": [11, 15], "self": [11, 14], "29204": 11, "129f0820cd": 11, "stabl": 11, "accross": 11, "board": 11, "29080": 11, "14": 11, "911b708ffd": 11, "jan": 11, "mid": 11, "month": 11, "28929": 11, "9a7f07491": 11, "5246c009c5": 11, "28651": 11, "2e7b9f5504": 11, "2022": 11, "f115b207bc": 11, "a6cda7cd23": 11, "6852f3fbea": 11, "accident": 11, "27962": 11, "a158fbb6bd": 11, "25bdbc8e67": 11, "rc3": 11, "27937": 11, "db5375bea7": 11, "2e20e9f7eb": 11, "up": 11, "relas": 11, "27774": 11, "80c327bd3b": 11, "ea306c9462": 11, "dbb4b59dcb": 11, "15": 11, "12c3c39d1a": 11, "27613": 11, "3ae98b824d": 11, "5c37b503f1": 11, "31": 11, "9ab1a6a3e7": 11, "26872": 11, "87eb46bbc6": 11, "78b8ea2f22": 11, "2a34dc9e84": 11, "enabl": 11, "normal": 11, "27205": 11, "ecd4d6654f": 11, "76014609c0": 11, "f8db64c35c": 11, "septemb": 11, "26731": 11, "06acf40a43": 11, "pep": 11, "563": 11, "postpon": 11, "annot": 11, "core": 11, "26289": 11, "25d0baa4e": 11, "bug": [11, 16], "band": [11, 16], "26109": 11, "27e2101f6": 11, "messsag": 11, "a74d934991": 11, "trinohook": 11, "prestohook": 11, "sqlitehook": 11, "874a95cc17": 11, "dd72e67524": 11, "5b3d579a42": 11, "7d0525a55b": 11, "rc4": 11, "25720": 11, "7a19651369": 11, "5923788143": 11, "amazon": 11, "25636": 11, "d82436b382": 11, "348a28957a": 11, "acab8f52dd": 11, "b0fd105f4a": 11, "5d4abbd58c": 11, "df00436569": 11, "be7cb1e837": 11, "46bbfdade0": 11, "24836": 11, "packag": 12, "directli": 12, "simpli": 12, "suffici": 12, "complic": 12, "kei": [12, 14, 15], "under": [12, 15], "top": [13, 14], "exist": 13, "below": [13, 14, 15], "pip": [13, 14], "6": 13, "sqlpars": 13, "4": 13, "might": [13, 16], "order": 13, "pypi": [13, 16], "verifi": 13, "checksum": [13, 14], "site": 13, "sdist": [13, 14], "asc": [13, 14], "sha512": [13, 14], "wheel": 13, "page": 14, "describ": [14, 15], "download": 14, "offici": 14, "choos": 14, "differ": [14, 15], "drop": 14, "down": 14, "left": 14, "whl": 14, "origin": 14, "softwar": 14, "foundat": 14, "link": 14, "abov": 14, "pgp": 14, "essenti": 14, "sha": 14, "gpg": 14, "pleas": 14, "well": [14, 15], "relev": 14, "distribut": 14, "main": [14, 16], "directori": 14, "mirror": 14, "pgpk": 14, "ka": 14, "binari": 14, "pgpv": 14, "tar": 14, "gz": 14, "made": 14, "sat": 14, "sep": 14, "49": 14, "54": 14, "2021": 14, "bst": 14, "rsa": 14, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 14, "issuer": 14, "kaxilnaik": 14, "org": 14, "good": [14, 16], "kaxil": 14, "naik": 14, "unknown": 14, "aka": 14, "gmail": 14, "com": 14, "warn": 14, "user": 14, "certifi": 14, "trust": 14, "There": 14, "indic": 14, "belong": 14, "owner": 14, "primari": 14, "fingerprint": 14, "cde1": 14, "5c6e": 14, "4d3a": 14, "8ec4": 14, "ecf4": 14, "ba4b": 14, "6674": 14, "e08a": 14, "d7de": 14, "406f": 14, "worri": 14, "about": [14, 16], "certif": 14, "manag": 14, "sign": 14, "why": 14, "server": 14, "previou": 14, "step": 14, "know": 14, "valid": [14, 15], "sum": 14, "shasum": 14, "512": 14, "diff": 14, "script": 14, "bin": 14, "bash": 14, "package_vers": 14, "package_nam": 14, "provider_download_dir": 14, "mktemp": 14, "dep": 14, "dest": 14, "curl": 14, "apache_airflow_providers_common_sql": 14, "py3": 14, "l": 14, "o": 14, "echo": 14, "la": 14, "onc": 14, "instruct": [14, 16], "chapter": 14, "temporari": 14, "folder": 14, "These": 15, "won": 15, "instanti": 15, "py": 15, "task_id": 15, "f": 15, "limit": 15, "As": 15, "relationship": 15, "suppli": 15, "three": 15, "nest": 15, "other_col": 15, "entri": 15, "distinct_check": 15, "distinct": 15, "unique_check": 15, "both": 15, "lower": 15, "upper": 15, "bound": 15, "still": 15, "consid": 15, "demonstr": 15, "referenc": 15, "resolv": 15, "parse_boolean": 15, "possibl": 15, "latter": 15, "independ": 16, "itself": 16, "vulner": 16, "found": 16, "alwai": 16, "next": 16, "strict": 16, "semver": 16, "scope": 16, "major": 16, "break": 16, "minor": 16, "patchlevel": 16, "so": 16, "rule": 16, "stakehold": 16, "decid": 16, "cherri": 16, "pick": 16, "older": 16, "mix": 16, "govern": 16, "requir": 16, "interest": 16, "parti": 16}, "objects": {"airflow.providers.common": [[2, 0, 0, "-", "sql"]], "airflow.providers.common.sql": [[2, 1, 1, "", "__version__"], [0, 0, 0, "-", "hooks"], [3, 0, 0, "-", "operators"], [5, 0, 0, "-", "sensors"]], "airflow.providers.common.sql.hooks": [[1, 0, 0, "-", "sql"]], "airflow.providers.common.sql.hooks.sql": [[1, 2, 1, "", "ConnectorProtocol"], [1, 2, 1, "", "DbApiHook"], [1, 1, 1, "", "T"], [1, 6, 1, "", "fetch_all_handler"], [1, 6, 1, "", "fetch_one_handler"], [1, 6, 1, "", "return_single_query_results"]], "airflow.providers.common.sql.hooks.sql.ConnectorProtocol": [[1, 3, 1, "", "connect"]], "airflow.providers.common.sql.hooks.sql.DbApiHook": [[1, 3, 1, "", "bulk_dump"], [1, 3, 1, "", "bulk_load"], [1, 4, 1, "", "conn_name_attr"], [1, 4, 1, "", "connector"], [1, 4, 1, "", "default_conn_name"], [1, 3, 1, "", "get_autocommit"], [1, 3, 1, "", "get_conn"], [1, 3, 1, "", "get_cursor"], [1, 3, 1, "", "get_first"], [1, 3, 1, "", "get_openlineage_authority_part"], [1, 3, 1, "", "get_openlineage_database_dialect"], [1, 3, 1, "", "get_openlineage_database_info"], [1, 3, 1, "", "get_openlineage_database_specific_lineage"], [1, 3, 1, "", "get_openlineage_default_schema"], [1, 3, 1, "", "get_pandas_df"], [1, 3, 1, "", "get_pandas_df_by_chunks"], [1, 3, 1, "", "get_records"], [1, 3, 1, "", "get_sqlalchemy_engine"], [1, 3, 1, "", "get_uri"], [1, 3, 1, "", "insert_rows"], [1, 5, 1, "", "last_description"], [1, 5, 1, "", "placeholder"], [1, 3, 1, "", "run"], [1, 3, 1, "", "set_autocommit"], [1, 3, 1, "", "split_sql_string"], [1, 3, 1, "", "strip_sql_string"], [1, 4, 1, "", "supports_autocommit"], [1, 3, 1, "", "test_connection"]], "airflow.providers.common.sql.operators": [[4, 0, 0, "-", "sql"]], "airflow.providers.common.sql.operators.sql": [[4, 2, 1, "", "BaseSQLOperator"], [4, 2, 1, "", "BranchSQLOperator"], [4, 2, 1, "", "SQLCheckOperator"], [4, 2, 1, "", "SQLColumnCheckOperator"], [4, 2, 1, "", "SQLExecuteQueryOperator"], [4, 2, 1, "", "SQLIntervalCheckOperator"], [4, 2, 1, "", "SQLTableCheckOperator"], [4, 2, 1, "", "SQLThresholdCheckOperator"], [4, 2, 1, "", "SQLValueCheckOperator"]], "airflow.providers.common.sql.operators.sql.BaseSQLOperator": [[4, 4, 1, "", "conn_id_field"], [4, 3, 1, "", "get_db_hook"]], "airflow.providers.common.sql.operators.sql.BranchSQLOperator": [[4, 3, 1, "", "execute"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"], [4, 4, 1, "", "ui_color"], [4, 4, 1, "", "ui_fgcolor"]], "airflow.providers.common.sql.operators.sql.SQLCheckOperator": [[4, 3, 1, "", "execute"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"], [4, 4, 1, "", "ui_color"]], "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator": [[4, 4, 1, "", "column_checks"], [4, 3, 1, "", "execute"], [4, 4, 1, "", "sql_check_template"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"]], "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator": [[4, 3, 1, "", "execute"], [4, 3, 1, "", "get_openlineage_facets_on_complete"], [4, 3, 1, "", "get_openlineage_facets_on_start"], [4, 3, 1, "", "prepare_template"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"], [4, 4, 1, "", "ui_color"]], "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator": [[4, 4, 1, "", "__mapper_args__"], [4, 3, 1, "", "execute"], [4, 4, 1, "", "ratio_formulas"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"], [4, 4, 1, "", "ui_color"]], "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator": [[4, 3, 1, "", "execute"], [4, 4, 1, "", "sql_check_template"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"]], "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator": [[4, 3, 1, "", "execute"], [4, 3, 1, "", "push"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"]], "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator": [[4, 4, 1, "", "__mapper_args__"], [4, 3, 1, "", "check_value"], [4, 3, 1, "", "execute"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"], [4, 4, 1, "", "ui_color"]], "airflow.providers.common.sql.sensors": [[6, 0, 0, "-", "sql"]], "airflow.providers.common.sql.sensors.sql": [[6, 2, 1, "", "SqlSensor"]], "airflow.providers.common.sql.sensors.sql.SqlSensor": [[6, 3, 1, "", "poke"], [6, 4, 1, "", "template_ext"], [6, 4, 1, "", "template_fields"], [6, 4, 1, "", "ui_color"]], "tests.system.providers.common": [[9, 0, 0, "-", "sql"]], "tests.system.providers.common.sql": [[7, 0, 0, "-", "example_sql_column_table_check"], [8, 0, 0, "-", "example_sql_execute_query"]], "tests.system.providers.common.sql.example_sql_column_table_check": [[7, 1, 1, "", "AIRFLOW_DB_METADATA_TABLE"], [7, 1, 1, "", "column_check"], [7, 1, 1, "", "connection_args"], [7, 1, 1, "", "test_run"]], "tests.system.providers.common.sql.example_sql_execute_query": [[8, 1, 1, "", "AIRFLOW_DB_METADATA_TABLE"], [8, 1, 1, "", "connection_args"], [8, 1, 1, "", "execute_query"], [8, 1, 1, "", "test_run"]]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:class", "3": "py:method", "4": "py:attribute", "5": "py:property", "6": "py:function"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "class", "Python class"], "3": ["py", "method", "Python method"], "4": ["py", "attribute", "Python attribute"], "5": ["py", "property", "Python property"], "6": ["py", "function", "Python function"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 11, 13], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 13], "common": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 13], "sql": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 12, 13, 15], "hook": [0, 1], "submodul": [0, 3, 5, 9], "modul": [1, 4, 6, 7, 8], "content": [1, 2, 4, 6, 7, 8], "class": [1, 4, 6], "function": 1, "attribut": 1, "subpackag": 2, "packag": [2, 11, 13, 14], "oper": [3, 4, 15], "sensor": [5, 6], "test": [7, 8, 9], "system": [7, 8, 9], "example_sql_column_table_check": 7, "example_sql_execute_queri": 8, "changelog": 10, "1": [10, 11], "10": 10, "0": [10, 11], "bug": 10, "fix": 10, "9": [10, 11], "misc": 10, "8": [10, 11], "7": [10, 11], "2": [10, 11], "featur": 10, "6": [10, 11], "5": [10, 11], "4": [10, 11], "3": [10, 11], "apach": [11, 13], "connect": 12, "db": 12, "default": 12, "id": 12, "instal": [13, 14], "requir": 13, "cross": 13, "depend": 13, "download": 13, "offici": 13, "from": 14, "sourc": 14, "releas": [14, 16], "integr": 14, "verifi": 14, "pypi": 14, "execut": 15, "queri": 15, "check": 15, "tabl": 15, "column": 15, "valu": 15, "secur": 16, "patch": 16}, "envversion": {"sphinx.domains.c": 2, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 8, "sphinx.domains.index": 1, "sphinx.domains.javascript": 2, "sphinx.domains.math": 2, "sphinx.domains.python": 3, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx.ext.viewcode": 1, "sphinx.ext.intersphinx": 1, "sphinx": 57}, "alltitles": {"airflow.providers.common.sql.hooks": [[0, "module-airflow.providers.common.sql.hooks"]], "Submodules": [[0, "submodules"], [3, "submodules"], [5, "submodules"], [9, "submodules"]], "airflow.providers.common.sql.hooks.sql": [[1, "module-airflow.providers.common.sql.hooks.sql"]], "Module Contents": [[1, "module-contents"], [4, "module-contents"], [6, "module-contents"], [7, "module-contents"], [8, "module-contents"]], "Classes": [[1, "classes"], [4, "classes"], [6, "classes"]], "Functions": [[1, "functions"]], "Attributes": [[1, "attributes"]], "airflow.providers.common.sql": [[2, "module-airflow.providers.common.sql"]], "Subpackages": [[2, "subpackages"]], "Package Contents": [[2, "package-contents"]], "airflow.providers.common.sql.operators": [[3, "module-airflow.providers.common.sql.operators"]], "airflow.providers.common.sql.operators.sql": [[4, "module-airflow.providers.common.sql.operators.sql"]], "airflow.providers.common.sql.sensors": [[5, "module-airflow.providers.common.sql.sensors"]], "airflow.providers.common.sql.sensors.sql": [[6, "module-airflow.providers.common.sql.sensors.sql"]], "tests.system.providers.common.sql.example_sql_column_table_check": [[7, "module-tests.system.providers.common.sql.example_sql_column_table_check"]], "tests.system.providers.common.sql.example_sql_execute_query": [[8, "module-tests.system.providers.common.sql.example_sql_execute_query"]], "tests.system.providers.common.sql": [[9, "module-tests.system.providers.common.sql"]], "Changelog": [[10, "changelog"]], "1.10.0": [[10, "id1"]], "Bug Fixes": [[10, "bug-fixes"], [10, "id7"], [10, "id10"], [10, "id18"], [10, "id35"], [10, "id37"], [10, "id39"], [10, "id42"], [10, "id47"], [10, "id50"], [10, "id53"]], "1.9.0": [[10, "id2"], [11, "id2"]], "Misc": [[10, "misc"], [10, "id4"], [10, "id8"], [10, "id11"], [10, "id13"], [10, "id16"], [10, "id19"], [10, "id22"], [10, "id24"], [10, "id26"], [10, "id30"], [10, "id33"], [10, "id40"], [10, "id45"]], "1.8.1": [[10, "id3"], [11, "id3"]], "1.8.0": [[10, "id5"], [11, "id4"]], "1.7.2": [[10, "id9"], [11, "id5"]], "1.7.1": [[10, "id12"], [11, "id6"]], "1.7.0": [[10, "id14"], [11, "id7"]], "Features": [[10, "features"], [10, "id21"], [10, "id29"], [10, "id32"], [10, "id46"], [10, "id49"], [10, "id52"]], "1.6.2": [[10, "id15"], [11, "id9"]], "1.6.1": [[10, "id17"], [11, "id10"]], "1.6.0": [[10, "id20"], [11, "id11"]], "1.5.2": [[10, "id23"], [11, "id12"]], "1.5.1": [[10, "id25"], [11, "id13"]], "1.5.0": [[10, "id27"], [11, "id14"]], "1.4.0": [[10, "id31"], [11, "id15"]], "1.3.4": [[10, "id34"], [11, "id16"]], "1.3.3": [[10, "id36"], [11, "id17"]], "1.3.2": [[10, "id38"], [11, "id18"]], "1.3.1": [[10, "id41"], [11, "id19"]], "1.3.0": [[10, "id43"], [11, "id20"]], "1.2.0": [[10, "id48"], [11, "id21"]], "1.1.0": [[10, "id51"], [11, "id22"]], "1.0.0": [[10, "id54"], [11, "id24"]], "Package apache-airflow-providers-common-sql": [[11, "package-apache-airflow-providers-common-sql"], [13, "package-apache-airflow-providers-common-sql"]], "1.9.1": [[11, "id1"]], "Connecting to a SQL DB": [[12, "connecting-to-a-sql-db"]], "Default Connection ID": [[12, "default-connection-id"]], "apache-airflow-providers-common-sql": [[13, "apache-airflow-providers-common-sql"]], "Provider package": [[13, "provider-package"]], "Installation": [[13, "installation"]], "Requirements": [[13, "requirements"]], "Cross provider package dependencies": [[13, "cross-provider-package-dependencies"]], "Downloading official packages": [[13, "downloading-official-packages"]], "Installing from sources": [[14, "installing-from-sources"]], "Released packages": [[14, "released-packages"]], "Release integrity": [[14, "release-integrity"]], "Verifying PyPI releases": [[14, "verifying-pypi-releases"]], "SQL Operators": [[15, "sql-operators"]], "Execute SQL query": [[15, "execute-sql-query"]], "Check SQL Table Columns": [[15, "check-sql-table-columns"]], "Check SQL Table Values": [[15, "check-sql-table-values"]], "Releasing security patches": [[16, "releasing-security-patches"]]}, "indexentries": {"airflow.providers.common.sql.hooks": [[0, "module-airflow.providers.common.sql.hooks"]], "module": [[0, "module-airflow.providers.common.sql.hooks"], [1, "module-airflow.providers.common.sql.hooks.sql"], [2, "module-airflow.providers.common.sql"], [3, "module-airflow.providers.common.sql.operators"], [4, "module-airflow.providers.common.sql.operators.sql"], [5, "module-airflow.providers.common.sql.sensors"], [6, "module-airflow.providers.common.sql.sensors.sql"], [7, "module-tests.system.providers.common.sql.example_sql_column_table_check"], [8, "module-tests.system.providers.common.sql.example_sql_execute_query"], [9, "module-tests.system.providers.common.sql"]], "connectorprotocol (class in airflow.providers.common.sql.hooks.sql)": [[1, "airflow.providers.common.sql.hooks.sql.ConnectorProtocol"]], "dbapihook (class in airflow.providers.common.sql.hooks.sql)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook"]], "t (in module airflow.providers.common.sql.hooks.sql)": [[1, "airflow.providers.common.sql.hooks.sql.T"]], "airflow.providers.common.sql.hooks.sql": [[1, "module-airflow.providers.common.sql.hooks.sql"]], "bulk_dump() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.bulk_dump"]], "bulk_load() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.bulk_load"]], "conn_name_attr (airflow.providers.common.sql.hooks.sql.dbapihook attribute)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.conn_name_attr"]], "connect() (airflow.providers.common.sql.hooks.sql.connectorprotocol method)": [[1, "airflow.providers.common.sql.hooks.sql.ConnectorProtocol.connect"]], "connector (airflow.providers.common.sql.hooks.sql.dbapihook attribute)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.connector"]], "default_conn_name (airflow.providers.common.sql.hooks.sql.dbapihook attribute)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.default_conn_name"]], "fetch_all_handler() (in module airflow.providers.common.sql.hooks.sql)": [[1, "airflow.providers.common.sql.hooks.sql.fetch_all_handler"]], "fetch_one_handler() (in module airflow.providers.common.sql.hooks.sql)": [[1, "airflow.providers.common.sql.hooks.sql.fetch_one_handler"]], "get_autocommit() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_autocommit"]], "get_conn() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_conn"]], "get_cursor() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_cursor"]], "get_first() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_first"]], "get_openlineage_authority_part() (airflow.providers.common.sql.hooks.sql.dbapihook static method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_openlineage_authority_part"]], "get_openlineage_database_dialect() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_openlineage_database_dialect"]], "get_openlineage_database_info() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_openlineage_database_info"]], "get_openlineage_database_specific_lineage() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_openlineage_database_specific_lineage"]], "get_openlineage_default_schema() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_openlineage_default_schema"]], "get_pandas_df() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_pandas_df"]], "get_pandas_df_by_chunks() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_pandas_df_by_chunks"]], "get_records() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_records"]], "get_sqlalchemy_engine() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_sqlalchemy_engine"]], "get_uri() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.get_uri"]], "insert_rows() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.insert_rows"]], "last_description (airflow.providers.common.sql.hooks.sql.dbapihook property)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.last_description"]], "placeholder (airflow.providers.common.sql.hooks.sql.dbapihook property)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.placeholder"]], "return_single_query_results() (in module airflow.providers.common.sql.hooks.sql)": [[1, "airflow.providers.common.sql.hooks.sql.return_single_query_results"]], "run() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.run"]], "set_autocommit() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.set_autocommit"]], "split_sql_string() (airflow.providers.common.sql.hooks.sql.dbapihook static method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.split_sql_string"]], "strip_sql_string() (airflow.providers.common.sql.hooks.sql.dbapihook static method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.strip_sql_string"]], "supports_autocommit (airflow.providers.common.sql.hooks.sql.dbapihook attribute)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.supports_autocommit"]], "test_connection() (airflow.providers.common.sql.hooks.sql.dbapihook method)": [[1, "airflow.providers.common.sql.hooks.sql.DbApiHook.test_connection"]], "__version__ (in module airflow.providers.common.sql)": [[2, "airflow.providers.common.sql.__version__"]], "airflow.providers.common.sql": [[2, "module-airflow.providers.common.sql"]], "airflow.providers.common.sql.operators": [[3, "module-airflow.providers.common.sql.operators"]], "basesqloperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.BaseSQLOperator"]], "branchsqloperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator"]], "sqlcheckoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLCheckOperator"]], "sqlcolumncheckoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator"]], "sqlexecutequeryoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator"]], "sqlintervalcheckoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator"]], "sqltablecheckoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator"]], "sqlthresholdcheckoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator"]], "sqlvaluecheckoperator (class in airflow.providers.common.sql.operators.sql)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator"]], "__mapper_args__ (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.__mapper_args__"]], "__mapper_args__ (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.__mapper_args__"]], "airflow.providers.common.sql.operators.sql": [[4, "module-airflow.providers.common.sql.operators.sql"]], "check_value() (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.check_value"]], "column_checks (airflow.providers.common.sql.operators.sql.sqlcolumncheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator.column_checks"]], "conn_id_field (airflow.providers.common.sql.operators.sql.basesqloperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.BaseSQLOperator.conn_id_field"]], "execute() (airflow.providers.common.sql.operators.sql.branchsqloperator method)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqlcheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLCheckOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqlcolumncheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqltablecheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqlthresholdcheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator.execute"]], "execute() (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.execute"]], "get_db_hook() (airflow.providers.common.sql.operators.sql.basesqloperator method)": [[4, "airflow.providers.common.sql.operators.sql.BaseSQLOperator.get_db_hook"]], "get_openlineage_facets_on_complete() (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.get_openlineage_facets_on_complete"]], "get_openlineage_facets_on_start() (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.get_openlineage_facets_on_start"]], "prepare_template() (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.prepare_template"]], "push() (airflow.providers.common.sql.operators.sql.sqlthresholdcheckoperator method)": [[4, "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator.push"]], "ratio_formulas (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.ratio_formulas"]], "sql_check_template (airflow.providers.common.sql.operators.sql.sqlcolumncheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator.sql_check_template"]], "sql_check_template (airflow.providers.common.sql.operators.sql.sqltablecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator.sql_check_template"]], "template_ext (airflow.providers.common.sql.operators.sql.branchsqloperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator.template_ext"]], "template_ext (airflow.providers.common.sql.operators.sql.sqlcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLCheckOperator.template_ext"]], "template_ext (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.template_ext"]], "template_ext (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.template_ext"]], "template_ext (airflow.providers.common.sql.operators.sql.sqlthresholdcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator.template_ext"]], "template_ext (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.template_ext"]], "template_fields (airflow.providers.common.sql.operators.sql.branchsqloperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqlcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLCheckOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqlcolumncheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqltablecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqlthresholdcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator.template_fields"]], "template_fields (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.template_fields"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.branchsqloperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqlcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLCheckOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqlcolumncheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqltablecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqlthresholdcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.template_fields_renderers"]], "ui_color (airflow.providers.common.sql.operators.sql.branchsqloperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator.ui_color"]], "ui_color (airflow.providers.common.sql.operators.sql.sqlcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLCheckOperator.ui_color"]], "ui_color (airflow.providers.common.sql.operators.sql.sqlexecutequeryoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator.ui_color"]], "ui_color (airflow.providers.common.sql.operators.sql.sqlintervalcheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator.ui_color"]], "ui_color (airflow.providers.common.sql.operators.sql.sqlvaluecheckoperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator.ui_color"]], "ui_fgcolor (airflow.providers.common.sql.operators.sql.branchsqloperator attribute)": [[4, "airflow.providers.common.sql.operators.sql.BranchSQLOperator.ui_fgcolor"]], "airflow.providers.common.sql.sensors": [[5, "module-airflow.providers.common.sql.sensors"]], "sqlsensor (class in airflow.providers.common.sql.sensors.sql)": [[6, "airflow.providers.common.sql.sensors.sql.SqlSensor"]], "airflow.providers.common.sql.sensors.sql": [[6, "module-airflow.providers.common.sql.sensors.sql"]], "poke() (airflow.providers.common.sql.sensors.sql.sqlsensor method)": [[6, "airflow.providers.common.sql.sensors.sql.SqlSensor.poke"]], "template_ext (airflow.providers.common.sql.sensors.sql.sqlsensor attribute)": [[6, "airflow.providers.common.sql.sensors.sql.SqlSensor.template_ext"]], "template_fields (airflow.providers.common.sql.sensors.sql.sqlsensor attribute)": [[6, "airflow.providers.common.sql.sensors.sql.SqlSensor.template_fields"]], "ui_color (airflow.providers.common.sql.sensors.sql.sqlsensor attribute)": [[6, "airflow.providers.common.sql.sensors.sql.SqlSensor.ui_color"]], "airflow_db_metadata_table (in module tests.system.providers.common.sql.example_sql_column_table_check)": [[7, "tests.system.providers.common.sql.example_sql_column_table_check.AIRFLOW_DB_METADATA_TABLE"]], "column_check (in module tests.system.providers.common.sql.example_sql_column_table_check)": [[7, "tests.system.providers.common.sql.example_sql_column_table_check.column_check"]], "connection_args (in module tests.system.providers.common.sql.example_sql_column_table_check)": [[7, "tests.system.providers.common.sql.example_sql_column_table_check.connection_args"]], "test_run (in module tests.system.providers.common.sql.example_sql_column_table_check)": [[7, "tests.system.providers.common.sql.example_sql_column_table_check.test_run"]], "tests.system.providers.common.sql.example_sql_column_table_check": [[7, "module-tests.system.providers.common.sql.example_sql_column_table_check"]], "airflow_db_metadata_table (in module tests.system.providers.common.sql.example_sql_execute_query)": [[8, "tests.system.providers.common.sql.example_sql_execute_query.AIRFLOW_DB_METADATA_TABLE"]], "connection_args (in module tests.system.providers.common.sql.example_sql_execute_query)": [[8, "tests.system.providers.common.sql.example_sql_execute_query.connection_args"]], "execute_query (in module tests.system.providers.common.sql.example_sql_execute_query)": [[8, "tests.system.providers.common.sql.example_sql_execute_query.execute_query"]], "test_run (in module tests.system.providers.common.sql.example_sql_execute_query)": [[8, "tests.system.providers.common.sql.example_sql_execute_query.test_run"]], "tests.system.providers.common.sql.example_sql_execute_query": [[8, "module-tests.system.providers.common.sql.example_sql_execute_query"]], "tests.system.providers.common.sql": [[9, "module-tests.system.providers.common.sql"]]}})