SQL 方言¶

Dialect 在 DbApiHook 實現和資料庫之間提供了一個抽象層。對於某些資料庫，可以使用多種連線型別，例如原生、ODBC 或 JDBC。由於 OdbcHook 和 JdbcHook 是通用 Hook，允許您與任何具有相應驅動程式的資料庫進行互動，因此需要一個抽象層來根據連線的資料庫執行專門的查詢，這就是引入方言的原因。

預設的 Dialect 類提供了以下操作，這些操作底層使用 SQLAlchemy 執行，但可以針對每個資料庫進行專門實現進行過載

placeholder 指定預處理語句中使用的資料庫特定佔位符（預設：%s）；
inspector 返回 SQLAlchemy 的 inspector，它允許我們檢索資料庫元資料；
extract_schema_from_table 允許我們從字串中提取 schema 名稱。
get_column_names 使用 SQLAlchemy inspector 返回給定表和 schema（可選）的列名。
get_primary_keys 使用 SQLAlchemy inspector 返回給定表和 schema（可選）的主鍵。
get_target_fields 返回非 identity 或非自增列的列名，如果未指定 target_fields 引數且 Airflow 屬性 core.dbapihook_resolve_target_fields 設定為 True（預設：False），DbApiHook 的 insert_rows 方法將使用此方法。
reserved_words 使用 SQLAlchemy inspector 返回目標資料庫中 SQL 的保留字。
generate_insert_sql 為目標資料庫生成 insert SQL 語句。
generate_replace_sql 為目標資料庫生成 upsert SQL 語句。

目前只有 3 種方言可用

default Dialect 重用 DbApiHook 中已有的通用功能；
mssql MsSqlDialect 專門用於 Microsoft SQL Server；
postgresql PostgresDialect 專門用於 PostgreSQL；

使用的方言將從連線字串中派生，但這有時是不可能的。始終可以透過連線的 extra 選項來指定方言名稱

dialect_name: 'mssql'

如果某個資料庫沒有特定的方言可用，將使用預設方言；指定不存在的方言名稱時也是如此。