Skip to main content
saminathancs17
saminathancs17
Silver ⭐️⭐️⭐️
January 30, 2017
Solved

Executing Multiple SQL Statements in Apache NiFi Database Workflows

How to execute multiple SQL queries in PutSql processor at a time

Ex: insert into table_a values('test_1'); insert into table_b values('test_2');

Flow:GetFile -> ReplaceText -> PutSQL -> PutFile

In the above flow ReplaceText processor will replace the flow file with above example query.

With this SQL flow file PutSql processor getting triggered and failed with error.

MattWho
MattWhoAnswer
Titanium ⭐️⭐️⭐️
January 30, 2017
@Saminathan A

The PutSQL processor expects that each FlowFile contains a single SQL statement and does not support multiple insert statements as you have tried above. You can have the GetFile Processor route its success relationship twice with each success going to its own ReplaceText processor. Each ReplaceText processor is then configured to create either the "table_a" or "table_b" insert statement. The success from both ReplaceText processors could then be routed to the same PutSQL processor.

Thanks,

Matt

View in thread

2 replies

MattWho
Titanium ⭐️⭐️⭐️
MattWhoAnswer
Titanium ⭐️⭐️⭐️
January 30, 2017
@Saminathan A

The PutSQL processor expects that each FlowFile contains a single SQL statement and does not support multiple insert statements as you have tried above. You can have the GetFile Processor route its success relationship twice with each success going to its own ReplaceText processor. Each ReplaceText processor is then configured to create either the "table_a" or "table_b" insert statement. The success from both ReplaceText processors could then be routed to the same PutSQL processor.

Thanks,

Matt

Translate
    saminathancs17
    saminathancs17Author
    Silver ⭐️⭐️⭐️
    January 30, 2017

    @Matt

    Thank you for your clarification.

    Translate
    Terms & ConditionsAccessibility statement