[NIFI-5342] CaptureChangeMySQL didn't escape database name

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.8.0
• Component/s: Core Framework
• Assignee: Uday Kale
• Reporter: Tanapol Nearunchorn
• Created: 27/Jun/18 09:38
• Updated: 30/Jul/18 23:06
• Resolved: 30/Jul/18 23:06

Description

CaptureChangeMySQL didn't escape database name as you can see:

https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java#L1003

 

And also with the line 1004, which query from a table.

It can cause problems when there is database or table name that contains a reserved keyword.

Issue Links

• links to: GitHub Pull Request #2923