Queries

id: access_queries
namespace: company.team

tasks:
  - id: init_db
    type: io.kestra.plugin.jdbc.access.Queries
    url: jdbc:ucanaccess:///myfile.accdb
    outputDbFile: true
    sql: |
      CREATE TABLE IF NOT EXISTS products (
        product_id INTEGER,
        product_name TEXT
      );
      INSERT INTO products (product_id, product_name) VALUES (1, 'Widget');
    fetchType: NONE

  - id: select
    type: io.kestra.plugin.jdbc.access.Queries
    url: jdbc:ucanaccess:///myfile.accdb
    accessFile: "{{ outputs.init_db.databaseUri }}"
    sql: SELECT * FROM products
    fetchType: FETCH