airflow.providers.microsoft.mssql.hooks.mssql¶

Microsoft SQLServer hook module.

Classes¶

Interact with Microsoft SQL Server.

class airflow.providers.microsoft.mssql.hooks.mssql.MsSqlHook(*args, sqlalchemy_scheme=None, **kwargs)[source]¶

Interact with Microsoft SQL Server.

Parameters:

args – passed to DBApiHook
sqlalchemy_scheme (str | None) – Scheme sqlalchemy connection. Default is mssql+pymssql Only used for get_sqlalchemy_engine and get_sqlalchemy_connection methods.
kwargs – passed to DbApiHook

property sqlalchemy_scheme: str[source]¶

Sqlalchemy scheme either from constructor, connection extras or default.

property dialect_name: str[source]¶

Extract the URI from the connection.

get_sqlalchemy_connection(connect_kwargs=None, engine_kwargs=None)[source]¶

Sqlalchemy connection object.

Return pymssql connection object.

set_autocommit(conn, autocommit)[source]¶

Set the autocommit flag on the connection.

get_autocommit(conn)[source]¶

Get autocommit setting for the provided connection.

Parameters:: conn (pymssql.Connection) – Connection to get autocommit setting from.
Returns:: connection autocommit setting. True if autocommit is set to True on the connection. False if it is either not set, set to False, or the connection does not support auto-commit.

get_openlineage_database_info(connection)[source]¶

Return MSSQL specific information for OpenLineage.

get_openlineage_database_dialect(connection)[source]¶

Return database dialect.

get_openlineage_default_schema()[source]¶

Return current schema.