JarCastingNiFi Drunken Dev Bundle
This NiFi bundle serves to add enrichment support to FlowFiles by adding attributes.
Presently one process is available which will execute SQL against the FlowFile adding the values from the first record returned as properties to the FlowFile with the property names being that of the column names identified in the ResultSet.
Example
Given a table with the following
create table if not exists test_table (
id identity primary key,
some_name varchar,
some_id int
);
insert into test_table (some_name, some_id) values ('test val', 3);
We could define a processor as follows:
This would result in the following flow file attributes being applied.
