Queries
Queries
yaml
type: "io.kestra.plugin.jdbc.mariadb.Queries"Examples
yaml
id: send_multiple_queries
namespace: test.queries
tasks:
- id: test_queries_insert
type: io.kestra.plugin.jdbc.mariadb.Queries
fetchType: FETCH
url: jdbc:mariadb://mariadb:3306/kestra
username: "${{secret('MARIADB_USERNAME')}}"
password: "${{secret('MARIADB_PASSWORD')}}"
sql: "{{ read('populate.sql') }}"
- id: test_queries_select
type: io.kestra.plugin.jdbc.mariadb.Queries
fetchType: FETCH
url: jdbc:mariadb://mariadb:3306/kestra
username: root
password: mariadb_passwd
sql: |
SELECT firstName, lastName FROM employee;
SELECT brand FROM laptop;
Properties
sql *Requiredstring
url *Requiredstring
afterSQL string
fetchSize integerstring
Default
10000fetchType string
Default
NONEPossible Values
STOREFETCHFETCH_ONENONEinputFile string
parameters object
password string
timeZoneId string
transaction booleanstring
Default
trueusername string
Outputs
outputs array
Definitions
io.kestra.plugin.jdbc.AbstractJdbcBaseQuery-Output
rowobject
rowsarray
SubTypeobject
sizeinteger
uristring
Format
uriMetrics
fetch.size counter
Unit
rows