需求：

思路：

解決方案：

雖然與前一篇來說差異不大，但Nifi流程上卻有很大不同，下面會詳細描述為什么要這樣做

Processor及其設定：

• SQL1：這才是這次花招的關鍵，在這里根據STATUS自行構建SQL語句
• Status=0：構建的就是Delete From xxx Where Key1=? and Key2=? 這樣的刪除語句
• Status!=0：構建的就是Replace Into xxx (Key1,Key2,col3,col4) Values ( ?, ?, ?, ?) 這樣的Insert or Update語句
• 經此Processor處理后，資料落地所需的SQL就構建好了，后續的問題就是如何去綁定參數和執行

• Search Value：這里使用的是Default的(?s)(^.*$)，作用就是把原先的整份文件全部換掉
• Replacement Value：這里放的就是一個固定結構的JSON，可以看到里面的屬性值都是使用的Attribute (它們的值來源于前面的EvaluateJsonPath從源JSON文件中的提取)
• 細心的朋友可以發現這里是與前一篇文章的最大不同，這里沒有使用AttributeToJson去直接產生JSON文件，而使用的是更加笨拙的方式
• 前面的文章有提過，我們產生的Attribute以及AttributeToJson所生成JSON中各屬性的順序問題，結論是怎么搞它都不是我所想象到的順序。但是ConvertJsonToSQL這個東東卻很實在，它確確實實是按JSON中屬性的順序去生成的SQL以及參數名稱(還記得參數名稱sql.args.1.value中的這個順序1么)，所以問題就來了：
  
• SQL由于必須要有Delete和Replace，所以它們的參數個數一定是不同的，而Delete壓的參數又是我們的Key，所以就必須要保證ConvertJsonToSQL生成屬性的順序，這樣我們才能夠保證我們的兩個Key一定會是sql.args.1和sql.args.2
• 換句話說，如果AttributesToJson若是能夠保證JSON屬性順序的話，那就不用這么費勁

• Delete Attributes Expression：這里我根據Delete的條件(STATUS=0)去刪除多余的SQL綁定參數
• 這里的寫法比較死，我Hard-code刪除掉大與2的其它所有參數(" * "是一個通配符，" | "是一個多條件的間隔符)，感覺上還有更好的寫法
• 至此我們就可以保證綁定參數的數量與SQL語法參數個數一致 (不一致它死給你看)

• SQL Statement：前面用UpdateAttribute產生的SQL1參數，它會根據STATUS=0去判斷是使用DELETE還是REPLACE語法
• 這個屬性壓上后，無論SQL1是不是為空，這個組件都不會再去管FlowFile的內容(空屬性時是把FlowFile的內容當成SQL去執行的)