Batch
Bulk insert rows into Vertica using prepared statements
Batch
Bulk insert rows into Vertica using prepared statements
yaml
type: "io.kestra.plugin.jdbc.vertica.Batch"Examples
yaml
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: 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( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )
yaml
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: 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
Properties
from *Requiredstring
url *Requiredstring
chunk integerstring
Default
1000columns array
SubTypestring
password string
sql string
table string
timeZoneId string
username string
Outputs
rowCount integer
updatedCount integer
Metrics
query counter
Unit
queriesrecords counter
Unit
recordsupdated counter
Unit
records