This component is based on Open Integration Hub framework, allowing this to connect with other components in order to have different flow exchanging data in a specific goal of transformation for the information.
This component allows to connect to a Oracle database and execute single query or or operations in bulk.
This component validates the integrity of the information through a MD5 hash ID (using the md5-node-cg.lib), allowing to comparation the hash ID received with the hash ID generated with the information received, if the comparation between the ID is the same the process continues, if not the component throws an exception.
When this component is part of a flow will send to the next component the following properties: x_request_id, x_b3_traceid, workflowName. This properties will be useful to trace all executions of this component. And this properties are extracted from RabbitMQ headers.
- Send data to bulk operations like, INSERT, UPDATE, DELETE
- Implemented rollback, transactions and commits to secure data integrity
- Send query single to executions in the databases
For more detail of the functionality review oracle-cg-lib documentation
Docker image: cloudgenuser/oracle-component:1.0.0
Functions
- trigger:
- process_source
- action:
- process
Fields:
- database: indicates the name of the database to connect
- host: indicates the name of the host or IP to connect
- user: indicates the name of the user that has grants to connect to the database
- path_client: indicates the oracle client directory, it must be defined if oracle client dont install in the Operating System where the component will run
- password: indicates the password corresponding to the user that has grants to connect
- port: indicates the database port to connect, default is 3306
- query: indicates the SQL sentence to execute in the database
- limit: indicates the limit of the data that will be processed in the bulk operation, default is 10000
- content: the payload that can be used in the SQL operations, in the case of bulk operations this is the data to be processed in the queries