JdbcOperator¶

Java 数据库连接 (JDBC) 是 Java 编程语言的应用程序编程接口 (API)，它定义了客户端如何访问数据库。

警告

以前，JdbcOperator 用于执行此类操作。但目前 JdbcOperator 已被弃用，将在提供程序的未来版本中删除。请尽快考虑切换到 SQLExecuteQueryOperator。

先决条件¶

要使用此操作符，您需要

安装 python 模块 jaydebeapi: .. code-block:: bash

pip install apache-airflow[jdbc]

安装 JVM 并添加 JAVA_HOME 环境变量。

安装您的数据库的 JDBC 驱动程序。

一旦满足这些先决条件，您应该能够运行此 Python 代码片段（将变量值替换为与您的驱动程序相关的值）。

如果缺少 jaydebeapi 模块或驱动程序不可用，其他错误消息将通知您。 Connection Refused 错误表示连接字符串指向的服务器没有数据库在监听新的连接。

driver_class = "com.exasol.jdbc.EXADriver"
driver_path = "/opt/airflow/drivers/exasol/EXASolution_JDBC-7.0.2/exajdbc.jar"
connection_url = "jdbc:exa:localhost"
credentials = ["", ""]

conn = jaydebeapi.connect(
    driver_class,
    connection_url,
    credentials,
    driver_path,
)

用法¶

使用 SQLExecuteQueryOperator 对通过 JDBC 驱动程序可访问的数据库（或数据存储）执行命令。

JDBC 连接必须作为 conn_id 传递。

tests/system/jdbc/example_jdbc_queries.py[源代码]

    insert_data = SQLExecuteQueryOperator(
        task_id="insert_data",
        sql="insert into my_schema.my_table select dt, value from my_schema.source_data",
        conn_id="my_jdbc_connection",
        autocommit=True,
    )

参数 sql 可以接收字符串或字符串列表。每个字符串可以是 SQL 语句或对模板文件的引用。模板引用通过以“.sql”结尾来识别。

如果将参数 autocommit 设置为 True，则将在每个命令后执行提交（默认为 False）

模板化¶

您可以使用 Jinja 模板来参数化 sql。

tests/system/jdbc/example_jdbc_queries.py[源代码]

    delete_data = SQLExecuteQueryOperator(
        task_id="delete_data",
        sql="delete from my_schema.my_table where dt = {{ ds }}",
        conn_id="my_jdbc_connection",
        autocommit=True,
    )