Batch

id: access_batch
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.access.Query
    url: jdbc:ucanaccess:///myfile.accdb
    outputDbFile: true
    sql: |
      SELECT product_id, product_name, price
      FROM products
      LIMIT 1500
    fetchType: STORE

  - id: insert
    type: io.kestra.plugin.jdbc.access.Batch
    from: "{{ outputs.query.uri }}"
    accessFile: "{{ outputs.query.databaseUri }}"
    sql: INSERT INTO products_copy VALUES (?, ?, ?)