
Queries
Queries
yaml
type: "io.kestra.plugin.jdbc.mysql.Queries"Examples
yaml
id: send_multiple_queries
namespace: test.queries
tasks:
- id: test_queries_insert
type: io.kestra.plugin.jdbc.mysql.Queries
fetchType: FETCH
url: jdbc:mysql://mysql:3306/kestra
username: "${{secret('MYSQL_USERNAME')}}"
password: "${{secret('MYSQL_PASSWORD')}}"
sql: "{{ read('populate.sql') }}"
- id: test_queries_select
type: io.kestra.plugin.jdbc.mysql.Queries
fetchType: FETCH
url: jdbc:mysql://mysql:3306/kestra
username: root
password: mysql_passwd
sql: |
SELECT firstName, lastName FROM employee;
SELECT brand FROM laptop;
Properties
sql*Requiredstring
url*Requiredstring
afterSQLstring
fetchSizeintegerstring
Default
10000fetchTypestring
Default
NONEPossible Values
STOREFETCHFETCH_ONENONEinputFilestring
parametersobject
passwordstring
timeZoneIdstring
transactionbooleanstring
Default
trueusernamestring
Outputs
outputsarray
Definitions
io.kestra.plugin.jdbc.AbstractJdbcBaseQuery-Output
rowobject
rowsarray
SubTypeobject
sizeinteger
uristring
Format
uriMetrics
fetch.sizecounter
Unit
rows