Actian Vector (VectorWise) Queries
CertifiedExecute multiple SQL statements against Vectorwise
Actian Vector (VectorWise) Queries
Execute multiple SQL statements against Vectorwise
Runs multiple SQL statements against Actian Vector (formerly Vectorwise) columnar analytics database. Optimized for analytical workloads and high-performance queries. Supports parameterized queries, transactions (default enabled), and all fetch modes. Default fetchSize is 10,000 rows.
type: io.kestra.plugin.jdbc.vectorwise.QueriesExamples
Send SQL queries to a Vectorwise database and fetch a row as output.
id: vectorwise_queries
namespace: company.team
tasks:
- id: queries
type: io.kestra.plugin.jdbc.vectorwise.Queries
url: jdbc:vectorwise://url:port/base
username: "{{ secret('VECTORWISE_USERNAME') }}"
password: "{{ secret('VECTORWISE_PASSWORD') }}"
sql: SELECT count(*) FROM employee; SELECT count(*) FROM laptop;
fetchType: FETCH_ONE
Properties
sql *Requiredstring
SQL statement(s) to execute
Runs one or more SQL statements rendered with flow variables. Query tasks accept a single statement; Queries tasks can execute multiple statements separated by semicolons
url *Requiredstring
The JDBC URL to connect to the database
afterSQL string
SQL to execute after main query in same transaction
Optional SQL executed in the same transaction after the main statement. Useful for marking rows as processed to avoid duplicates; only a single statement is allowed. Commit covers both sql and afterSQL
fetchSize integerstring
10000Number of rows to fetch per database round trip
Controls JDBC fetch size for STORE mode. Default: 10,000 rows; use Integer.MIN_VALUE for MySQL streaming. Ignored for FETCH and FETCH_ONE
fetchType string
NONESTOREFETCHFETCH_ONENONEResult fetching mode
FETCH returns all rows, FETCH_ONE returns the first row only, STORE streams rows to internal storage (ION), NONE returns no data. Default: NONE
parameters object
Named parameter bindings for SQL query
Map of parameter names to values. Use : name placeholders rendered then bound as prepared-statement parameters; supports nulls and typed values
password string
The database user's password.
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
timeZoneId string
The time zone id to use for date/time manipulation. Default value is the worker's default time zone id.
transaction booleanstring
trueTransaction
If one query failed, rollback transactions.
username string
The database user
Outputs
outputs array
io.kestra.plugin.jdbc.AbstractJdbcBaseQuery-Output
First row of fetched data
Only populated when fetchType is FETCH_ONE
List of all fetched rows
Only populated when fetchType is FETCH
Number of rows fetched
Only populated when fetchType is FETCH or STORE
uriURI of stored results in internal storage
Only populated when fetchType is STORE; file is stored in internal storage using ION format
Metrics
fetch.size counter
rowsThe number of fetched rows.
