Batch
Bulk insert rows into Oracle Database using prepared statements
Batch
Bulk insert rows into Oracle Database using prepared statements
yaml
type: io.kestra.plugin.jdbc.oracle.BatchExamples
yaml
id: oracle_batch
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.jdbc.oracle.Query
url: jdbc:oracle:thin:@dev:49161:XE
username: oracle
password: oracle_password
sql: |
SELECT *
FROM xref
FETCH FIRST 1500 ROWS ONLY;
fetchType: STORE
- id: update
type: io.kestra.plugin.jdbc.oracle.Batch
from: "{{ outputs.query.uri }}"
url: jdbc:oracle:thin:@prod:49161:XE
username: oracle
password: oracle_password
sql: |
insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )
yaml
id: oracle_batch
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.jdbc.oracle.Query
url: jdbc:oracle:thin:@dev:49161:XE
username: oracle
password: oracle_password
sql: |
SELECT *
FROM xref
FETCH FIRST 1500 ROWS ONLY;
fetchType: STORE
- id: update
type: io.kestra.plugin.jdbc.oracle.Batch
from: "{{ outputs.query.uri }}"
url: jdbc:oracle:thin:@prod:49161:XE
username: oracle
password: oracle_password
table: XREF
Properties
from *Requiredstring
url *Requiredstring
chunk integerstring
Default
1000columns array
SubTypestring
inputHandling string
Default
AUTOPossible Values
AUTOSTREAMLOCALlocalBufferMaxBytes integerstring
Default
104857600maxRetries integerstring
Default
3password string
resumeOnRetry booleanstring
Default
trueretryBackoff string
Default
PT1SretryScope string
Default
INPUTPossible Values
NONEINPUTALLsql string
table string
timeZoneId string
username string
Outputs
rowCount integer
updatedCount integer
Metrics
query counter
Unit
queriesrecords counter
Unit
recordsupdated counter
Unit
records