Batch

yaml

type: "io.kestra.plugin.jdbc.vectorwise.Batch"

Execute a batch query on a Vectorwise server.

Examples

Fetch rows from a table and bulk insert to another one.

yaml

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;
    store: true
  - id: update
    type: io.kestra.plugin.jdbc.vectorwise.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:vectorwise://prod:port/base
    username: admin
    password: admin_passwd
    sql: insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

Properties

`chunk`

Type: integer
Dynamic: ✔️
Required: ✔️
Default: 1000

The size of chunk for every bulk request.

`from`

Type: string
Dynamic: ✔️
Required: ✔️

Source file URI

`sql`

Type: string
Dynamic: ✔️
Required: ✔️

Insert query to be executed.

The query must have as many question marks as the number of columns in the table. Example: 'insert into <table_name> values( ? , ? , ? )' for 3 columns. In case you do not want all columns, you need to specify it in the query in the columns property Example: 'insert into <table_name> (id, name) values( ? , ? )' for inserting data into 2 columns: 'id' and 'name'.