Query

id: oracle_query
namespace: company.team

tasks:
  - id: select
    type: io.kestra.plugin.jdbc.oracle.Query
    url: jdbc:oracle:thin:@localhost:49161:XE
    username: oracle_user
    password: oracle_password
    sql: select * from source
    fetchType: FETCH

  - id: generate_update
    type: io.kestra.plugin.jdbc.oracle.Queries
    url: jdbc:oracle:thin:@localhost:49161:XE
    username: oracle_user
    password: oracle_password
    sql: "{% for row in outputs.select.rows %} INSERT INTO destination (year_month, store_code, update_date) values ({{ row.year_month }}, {{ row.store_code }}, TO_DATE('{{ row.date }}', 'MONTH DD, YYYY') ); {% endfor %}"