Batch

Batch
Certified
Bulk insert rows into Oracle Database using prepared statements

yaml
type: io.kestra.plugin.jdbc.oracle.Batch

Examples

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: "{{ secret('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: "{{ secret('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: "{{ secret('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: "{{ secret('ORACLE_PASSWORD') }}"
    table: XREF

Properties

from *string

url *string

chunk integerstring

Default1000

columns array

SubTypestring

connectionPoolSize integerstring

Default10

connectionPooling booleanstring

Defaulttrue

inputHandling string

DefaultAUTO

Possible Values

AUTOSTREAMLOCAL

localBufferMaxBytes integerstring

Default104857600

maxRetries integerstring

Default3

password string

pluginDefaultsRef string

resumeOnRetry booleanstring

Defaulttrue

retryBackoff string

DefaultPT1S

retryScope string

DefaultINPUT

Possible Values

NONEINPUTALL

sql string

table string

timeZoneId string

username string

Outputs

rowCount integer

updatedCount integer

Metrics

query counter

Unitqueries

records counter

Unitrecords

updated counter

Unitrecords

Clickhouse

Tasks that connect to ClickHouse via JDBC to run queries and loads.

Data

Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

BatchCertifiedBulk insert rows into Oracle Database using prepared statements

More Plugins in this Category

Clickhouse

Weaviate

Batch
Certified
Bulk insert rows into Oracle Database using prepared statements