PostgreSQL bulk loader

Description

The PostgreSQL bulk loader transform streams data from Hop to Postgresql using "COPY DATA FROM STDIN" into the database.

boolean stream fields are serialized as t or f, which PostgreSQL COPY accepts for boolean columns.

binary stream fields (for example a 16-byte hash key) are serialized as PostgreSQL bytea hex, \xdeadbeef.

COPY error messages rarely name the stream field and value. Put Database value validation in front of this transform to catch over-long strings, encoding problems, numeric overflow and invalid UUID/JSON before COPY runs.

The PostgreSQL bulk loader is linked to the database type. It will fetch the JDBC driver from the hop/lib/jdbc folder.

Valid locations for the JDBC driver for this transform are the database plugin lib and the main hop/lib folder. It will not work in combination with the SHARED_JDBC_FOLDER variable.

Options

Option Description

Option	Description
Transform name	Name of the transform.
Connection	Name of the database connection on which the target table resides.
Target schema	The name of the Schema for the table to write data to. This is important for data sources that allow for table names with dots '.' in it.
Target table	Name of the target table.
Load action	Insert, Truncate. Insert inserts, truncate first truncates the table.
DB Name Override	(optional) database name to override the database name used in this transform’s connection.
Enclosure	the enclosure character to use in the `QUOTE AS` part of the copy command
Delimiter	the delimiter character to use in the `DELIMITER AS` part of the copy command
Stop on error	Stop the execution of this transform when an error occurs
Fields to load	This table contains a list of fields to load data from, properties include: Table field: Table field to be loaded in the PostgreSQL table; Stream field: Field to be taken from the incoming rows; Date mask: Either "Pass through, "Date" or "DateTime", determines how date/timestamps will be loaded in PostgreSQL.

Transform name

Name of the transform.

Connection

Name of the database connection on which the target table resides.

Target schema

The name of the Schema for the table to write data to. This is important for data sources that allow for table names with dots '.' in it.

Target table

Name of the target table.

Load action

Insert, Truncate. Insert inserts, truncate first truncates the table.

DB Name Override

(optional) database name to override the database name used in this transform’s connection.

Enclosure

the enclosure character to use in the QUOTE AS part of the copy command

Delimiter

the delimiter character to use in the DELIMITER AS part of the copy command

Stop on error

Stop the execution of this transform when an error occurs

Fields to load

This table contains a list of fields to load data from, properties include:

Table field: Table field to be loaded in the PostgreSQL table;
Stream field: Field to be taken from the incoming rows;
Date mask: Either "Pass through, "Date" or "DateTime", determines how date/timestamps will be loaded in PostgreSQL.