以下是我正在使用的处理器组合:-
GetFile + SplitText + ExtractText + UpdateAttribute + ExecuteSQL + ConvertAvroToJson + PutFile
基本上,我有一个属性文件,其中包含“DBCPConnectionPool”控制器服务建立与数据库的连接所需的 5 个逗号分隔值。这是我的属性文件的内容:-
jdbc:mysql://localhost:3306/test,com.mysql.jdbc.Driver,C:\Program Files\MySQL\mysql-connector.jar,root,root
现在,我从这个属性文件中提取值并将它们存储在手动创建的属性中。我正在使用这个正则表达式将这些值存储到使用 ExtractText 的属性中。
ExtractedData: (.*)
然后使用 updateAttribute 处理器手动添加 5 个属性并从属性文件中获取它们的值,如下所示:
connectionURL : ${ExtractedData:getDelimitedField(1)}
driverClass : ${ExtractedData:getDelimitedField(2)}
driverLocation : ${ExtractedData:getDelimitedField(3)}
user : ${ExtractedData:getDelimitedField(4)}
password : ${ExtractedData:getDelimitedField(5)}
所以,到目前为止,属性已经从属性文件中获取了它们的值,因此下面的值存储在它们中:
connectionURL : jdbc:mysql://localhost:3306/test
driverClass : com.mysql.jdbc.Driver
driverLocation : C:\Program Files\MySQL\mysql-connector.jar
user : root
password : root
最后,这是我想要实现的目标。我正在尝试在 DBCPConnectionPool 控制器服务中使用上述 5 个属性,如下所示:
Database Connection URL : ${connectionURL}
Database Driver Class : ${driverClass}
Database Driver Location(s) : ${driverLocation}
Database User : ${user}
Password : ${password}
但我无法建立连接,并且收到错误“无法创建 PoolableConnectionFactory”。控制器服务似乎无法从属性中读取值。如何将流文件属性传递给控制器服务?