Member since
06-04-2025
1
Post
0
Kudos Received
0
Solutions
06-04-2025
09:21 AM
Does anyone have experience using SQL value in statement.type for PutDatabaseRecord processor in Nifi? It is undocumented as to how to format/parameterize this query correctly. Use of ? or record path values both fail e.g. INSERT INTO radius.sim_usage(id,sim_id,"ICCID",sim_month,sim_usage,"updatedAt",supplier_id) VALUES(/id,/sim_id,/iccid,/sim_month,/sim_usage,/updatedAt,/supplier_id) ON CONFLICT(id) DO UPDATE SET sim_usage = CASE WHEN sim_month <> '${nowDate}' THEN sim_usage = sim_usage - /sim_usage ELSE sim_usage = /sim_usage END INSERT INTO radius.sim_usage(id,sim_id,"ICCID",sim_month,sim_usage,"updatedAt",supplier_id) VALUES(?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET sim_usage = CASE WHEN sim_month <> '${nowDate}' THEN sim_usage = sim_usage - ? ELSE sim_usage = ? END
... View more
Labels:
- Labels:
-
Apache NiFi