I want to insert splitted records from splitjson processor in database table using nifi.
For eg: Below is splitjson processor output. I want to push all the flow files in database table having same fragment.identifier.
table columns are mentioned below:
identity_id|json|person_ref
where identity_id should be auto sequence number
json would flow-file content
person_ref is the foreign key having int data type
so table will have 13 entries and identity_id column will be unique numbers in sequence, json column will have different flow file contents and person_ref column should be same for all 13 entries lets say 111.