{"library":"apache-airflow-providers-mysql","code":"from __future__ import annotations\n\nimport pendulum\n\nfrom airflow.models.dag import DAG\nfrom airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator\n\n# Ensure you have a MySQL connection named 'mysql_default' configured in Airflow UI\n# Host: localhost, Schema: airflow_db, User: airflow, Pass: airflow\n\nwith DAG(\n    dag_id=\"mysql_quickstart_dag\",\n    start_date=pendulum.datetime(2023, 1, 1, tz=\"UTC\"),\n    catchup=False,\n    schedule=None,\n    tags=[\"mysql\", \"example\"],\n) as dag:\n    create_table = SQLExecuteQueryOperator(\n        task_id=\"create_test_table\",\n        conn_id=\"mysql_default\",\n        sql=\"\"\"\n            CREATE TABLE IF NOT EXISTS test_table (\n                id INT AUTO_INCREMENT PRIMARY KEY,\n                name VARCHAR(255)\n            );\n        \"\"\",\n    )\n\n    insert_data = SQLExecuteQueryOperator(\n        task_id=\"insert_test_data\",\n        conn_id=\"mysql_default\",\n        sql=\"INSERT INTO test_table (name) VALUES ('Airflow User 1'), ('Airflow User 2');\",\n    )\n\n    select_data = SQLExecuteQueryOperator(\n        task_id=\"select_test_data\",\n        conn_id=\"mysql_default\",\n        sql=\"SELECT * FROM test_table;\",\n    )\n\n    create_table >> insert_data >> select_data\n","lang":"python","description":"This quickstart demonstrates how to use `SQLExecuteQueryOperator` to interact with a MySQL database. It creates a table, inserts data, and then selects it. Ensure you have a MySQL connection named `mysql_default` configured in your Airflow UI.","tag":null,"tag_description":null,"last_tested":"2026-04-24","results":[{"runtime":"python:3.10-alpine","exit_code":1},{"runtime":"python:3.10-slim","exit_code":1},{"runtime":"python:3.11-alpine","exit_code":1},{"runtime":"python:3.11-slim","exit_code":1},{"runtime":"python:3.12-alpine","exit_code":1},{"runtime":"python:3.12-slim","exit_code":1},{"runtime":"python:3.13-alpine","exit_code":1},{"runtime":"python:3.13-slim","exit_code":1},{"runtime":"python:3.9-alpine","exit_code":1},{"runtime":"python:3.9-slim","exit_code":1}]}