Greetings Community,

1.I'm developing a nifi flow which reads mysql bin_log(Capture Change Mysql)
form source db and executing the queries in destination db using PutSql
processor. In my source db tables some columns have datatype datetime(like
*2017-10-09 18:08:55*). Capture Chnage Mysql is giving me data in json
format in that columns with datetime are converted to "*Mon Sep 11 19:56:13
IST 2017*".

2.After that I'm using JoltTransformJson Processor to convert flat Json.
3.Next Converting to sql statement using ConvertJsonToSql Processor after
converting the format is like "*Mon Sep 11 19:56:13*" chopping to 19 char.
4.With this flowfile I'm trying to execute sql statement using PutSql
Processor.
5.PutSql Processor is giving "*flow file attribute value of sql.args.27.type
is 93 and sql.args.27.value is Mon Oct 09 23:38:55.*".
<http://apache-nifi-users-list.2361937.n4.nabble.com/file/t310/Capture.png> 


6.I tried Update attribute Processor with Property:"sql.args.4.value"
Value:${sql.args.4.original:format("yyyy-MM-dd HH:mm:ss")} but no luck.

Any suggestions are welcome and appreciated.
Thanks
Rakesh



--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/

Reply via email to