Batch | Kestra

Batch

Bulk insert rows into MySQL using prepared statements

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

Examples

yaml
id: mysql_batch
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.mysql.Query
    url: jdbc:mysql://127.0.0.1:3306/
    username: mysql_user
    password: mysql_password
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.mysql.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:mysql://127.0.0.1:3306/
    username: mysql_user
    password: mysql_password
    sql: |
      insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

yaml
id: mysql_batch
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.mysql.Query
    url: jdbc:mysql://127.0.0.1:3306/
    username: mysql_user
    password: mysql_password
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.mysql.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:mysql://127.0.0.1:3306/
    username: mysql_user
    password: mysql_password
    table: xref

Properties

from *string

url *string

chunk integerstring

Default1000

columns array

SubTypestring

password string

sql string

table string

timeZoneId string

username string

Outputs

rowCount integer

updatedCount integer

Metrics

query counter

Unitqueries

records counter

Unitrecords

updated counter

Unitrecords

Apache Cassandra

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Data

MongoDB

Tasks that query and manipulate MongoDB collections.

Data

Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

Batch

Bulk insert rows into MySQL using prepared statements

More Plugins in this Category

Apache Cassandra

MongoDB

Weaviate

1.8.1

Batch Bulk insert rows into MySQL using prepared statements

More Plugins in this Category

Apache Cassandra

MongoDB

Weaviate

1.8.1

Batch

Bulk insert rows into MySQL using prepared statements