​Batch

id: vectorwise_batch_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.vectorwise.Query
    url: jdbc:vectorwise://dev:port/base
    username: "{{ secret('VECTORWISE_USERNAME') }}"
    password: "{{ secret('VECTORWISE_PASSWORD') }}"
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.vectorwise.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:vectorwise://prod:port/base
    username: "{{ secret('VECTORWISE_USERNAME') }}"
    password: "{{ secret('VECTORWISE_PASSWORD') }}"
    sql: insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

id: vectorwise_batch_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.vectorwise.Query
    url: jdbc:vectorwise://dev:port/base
    username: admin
    password: admin_passwd
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.vectorwise.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:vectorwise://prod:port/base
    username: admin
    password: admin_passwd
    table: xref