airflow.providers.microsoft.mssql.hooks.mssql
Microsoft SQLServer 钩子模块。
模块内容
-
class airflow.providers.microsoft.mssql.hooks.mssql.MsSqlHook(*args, sqlalchemy_scheme=None, **kwargs)[source]
基类： airflow.providers.common.sql.hooks.sql.DbApiHook
与 Microsoft SQL Server 交互。
- 参数:
-
-
conn_name_attr = 'mssql_conn_id'[source]
-
default_conn_name = 'mssql_default'[source]
-
conn_type = 'mssql'[source]
-
hook_name = 'Microsoft SQL Server'[source]
-
supports_autocommit = True[source]
-
DEFAULT_SQLALCHEMY_SCHEME = 'mssql+pymssql'[source]
-
schema[source]
-
property sqlalchemy_scheme: str[source]
SQLAlchemy 方案可来源于构造函数、连接额外参数或默认值。
-
property dialect_name: str[source]
-
property dialect: airflow.providers.common.sql.dialects.dialect.Dialect[source]
-
get_uri()[source]
从连接中提取 URI。
- 返回:
提取的 uri。
- 返回类型:
str
-
get_sqlalchemy_connection(connect_kwargs=None, engine_kwargs=None)[source]
SQLAlchemy 连接对象。
-
get_conn()[source]
返回 pymssql 连接对象。
-
set_autocommit(conn, autocommit)[source]
在连接上设置 autocommit 标志。
-
get_autocommit(conn)[source]
获取提供的连接的自动提交设置。
- 参数:
conn (pymssql.Connection) – 用于获取自动提交设置的连接。
- 返回:
连接的自动提交设置。如果连接上将 autocommit 设置为 True，则返回 True；如果未设置、设置为 False，或连接不支持自动提交，则返回 False。
-
get_openlineage_database_info(connection)[source]
返回针对 OpenLineage 的 MSSQL 特定信息。
-
get_openlineage_database_dialect(connection)[source]
返回数据库方言。
-
get_openlineage_default_schema()[source]
返回当前 schema。