Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Image Added

The Database Query (DB Query), a processor function, helps the user request data from a database and enrich the data in your stream. The data retrieved from the database can be from multiple tables.

...

The information required to access the external database.

FieldDescription
Database Type

 This selects the database type. The supported options are:

  • MySQL
  • PostgreSQL
  • Microsoft SQL
Database NameSpecify the name of the database you want to retrieve the data.
Hostname or IP AddressSpecify the hostname or the IP Address of the database
Port

Specify the port used by the database. When a Database Type is selected, the default port number is specified for each type of database.

The default port numbers are:

  • MySQL: 3306
  • PostgreSQL: 5432
  • Microsoft SQL: 1433

Authentication

The authentication information to log in to the external database.

FieldDescription
UsernameSpecify the username for the authentication.
PasswordSpecify the password for the authentication.

SQL Select Statement

In this input field, you specify the statement that you can use to query data from the selected database. For example, SELECT, AS and OR, and so on.

...

Enter a suitable number for Maximum items in cache (0 = no limit). The default value is 100. There is no upper limit to this value.

Note
titleNote!

A high value can result in an error due to memory outage. If so, the stream fails with the following error message in the log:
“Stream failed to complete due to reaching resource limits”

However, this error is received for memory issues in general and can have other causes than a high value for the maximum number of items in the cache.

Enter a suitable number of seconds for Items are removed from cache after. The default value is 300. The minimum value is 1 and there is no upper limit to this value. 

...

Note
titleNote!

The Database Query function supports Variable Insertion when writing SQL statements. 

Code Block
titleExample for Interpolation
SELECT dep FROM emp WHERE id = ${id} AND name = ${name}; 


...