airflow_jdbc_operator_dag_create_table_example.py

1import datetime
2
3from airflow import DAG
4from airflow.providers.jdbc.operators.jdbc import JdbcOperator
5
6with DAG(
7    dag_id="example_jdbc_operator",
8    schedule=None,
9    start_date=datetime.datetime(2021, 1, 1),
10    catchup=False,
11    tags=["example"],
12) as dag:
13
14    # [START howto_operator_jdbc]
15    create_table_jdbc = JdbcOperator(
16        task_id="create_table_jdbc",
17        jdbc_conn_id="jdbc_default",
18        sql="""
19            CREATE TABLE IF NOT EXISTS my_table (
20                id SERIAL PRIMARY KEY,
21                name VARCHAR(50),
22                description TEXT
23            );
24        """,
25    )
26    # [END howto_operator_jdbc]
27
28    create_table_jdbc