nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mark Payne <>
Subject Re: PutSQL question
Date Wed, 13 Jan 2016 20:25:26 GMT

Hello. An easy way to do this is to use ReplaceText to set the content of the FlowFile.
You can set the Replacement Strategy to "Always Replace" and set the Replacement Value
to something like: INSERT INTO MY_TABLE (ID) VALUES ('${id}')

You could also use SQL parameters (though it's slightly more involved), and use ReplaceText,
setting the Replacement

This would then require you to use UpdateAttribute to create the necessary parameters. You
need to add the following attributes:

sql.args.1.value    => This is the value to insert, so ${id}
sql.args.1.type      => This will be the JDBC Type, which for a VARCHAR is 12.

So you would add two user-defined properties with UpdateAttribute:

Property Name         Property Value
--------------------         ----------------------
sql.args.1.value        ${id}
sql.args.1.type          12

Does this all make sense?


> On Jan 13, 2016, at 3:16 PM, Perko, Ralph J <> wrote:
> Hi 
> I want to use the PutSQL processor to execute an insert statement. The use case is straightforward.
 I need to pull an id attribute from a JSON message and write it to a database.  I am using
EvaluateJSONPath to grab the id but I’m hung up on how to then pass the SQL statement as
the content.  I could put the SQL statement in a file to be loaded as content but I am wondering
if there is a way to do this inline with the flow? Ideally I would have the content of the
FlowFile be the SQL and pass in the id as a SQL parameter as mentioned in the documentation.
> Thanks for your help,
> Ralph

View raw message