Batch

Run a Microsoft SQL Server batch-query.

yaml
type: "io.kestra.plugin.jdbc.sqlserver.Batch"

Fetch rows from a table and bulk insert to another one.

yaml
id: sqlserver_batch_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.sqlserver.Query
    url: jdbc:sqlserver://dev:41433;trustServerCertificate=true
    username: "{{ secret('SQL_USERNAME') }}"
    password: "{{ secret('SQL_PASSWORD') }}"
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.sqlserver.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:sqlserver://prod:41433;trustServerCertificate=true
    username: "{{ secret('SQL_USERNAME') }}"
    password: "{{ secret('SQL_PASSWORD') }}"
    sql: |
      insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

Fetch rows from a table and bulk insert to another one, without using sql query.

yaml
  id: sqlserver_batch_query
  namespace: company.team

  tasks:
    - id: query
      type: io.kestra.plugin.jdbc.sqlserver.Query
      url: jdbc:sqlserver://dev:41433;trustServerCertificate=true
      username: sql_server_user
      password: sql_server_passwd
      sql: |
        SELECT *
        FROM xref
        LIMIT 1500;
      fetchType: STORE

    - id: update",
      type: io.kestra.plugin.jdbc.sqlserver.Batch
      from: "{{ outputs.query.uri }}"
      url: jdbc:sqlserver://prod:41433;trustServerCertificate=true
      username: "{{ secret('SQL_USERNAME') }}"
      password: "{{ secret('SQL_PASSWORD') }}"
      table: xref

Insert query to be executed.

The query must have as many question marks as the number of columns in the table. Example: 'insert into <table_name> values( ? , ? , ? )' for 3 columns. In case you do not want all columns, you need to specify it in the query in the columns property Example: 'insert into <table_name> (id, name) values( ? , ? )' for inserting data into 2 columns: 'id' and 'name'.

The JDBC URL to connect to the database.

Default 1000

The size of chunk for every bulk request.

SubType string

The columns to be inserted.

If not provided, ? count need to match the from number of columns.

Source file URI

Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.

The database user's password.

The table from which column names will be retrieved.

This property specifies the table name which will be used to retrieve the columns for the inserted values. You can use it instead of specifying manually the columns in the columns property. In this case, the sql property can also be omitted, an INSERT statement would be generated automatically.

The time zone id to use for date/time manipulation. Default value is the worker's default time zone id.

The database user.

The rows count.

The updated rows count.

​Batch

Batch