​Query

id: mariadb_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.mariadb.Query
    url: jdbc:mariadb://127.0.0.1:3306/
    username: mariadb_user
    password: mariadb_password
    sql: select * from mariadb_types
    fetchType: FETCH_ONE

id: mariadb_query
namespace: company.team

tasks:
  - id: http_download
    type: io.kestra.plugin.core.http.Download
    uri: https://huggingface.co/datasets/kestra/datasets/raw/main/csv/products.csv

  - id: query
    type: io.kestra.plugin.jdbc.mariadb.Query
    url: jdbc:mariadb://127.0.0.1:3306/
    username: mariadb_user
    password: mariadb_password
    inputFile: "{{ outputs.http_download.uri }}"
    sql: |
      LOAD DATA LOCAL INFILE '{{ inputFile }}'
      INTO TABLE products
      FIELDS TERMINATED BY ','
      ENCLOSED BY '"'
      LINES TERMINATED BY '\n'
      IGNORE 1 ROWS;