​Batch

id: vertica_batch_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.vertica.Query
    url: jdbc:vertica://dev:56982/db
    username: "{{ secret('VERTICA_USERNAME') }}"
    password: "{{ secret('VERTICA_PASSWORD') }}"
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: FETCH
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.vertica.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:vertica://prod:56982/db
    username: "{{ secret('VERTICA_USERNAME') }}"
    password: "{{ secret('VERTICA_PASSWORD') }}"
    sql: insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

id: vertica_batch_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.vertica.Query
    url: jdbc:vertica://dev:56982/db
    username: vertica_user
    password: vertica_passwd
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: FETCH
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.vertica.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:vertica://prod:56982/db
    username: vertica_user
    password: vertica_passwd
    table: xref