nifi：我们应该在querydatabasetable中添加哪个属性？

Question

我在 nifi-1.3 版本中使用 QueryDatabaseTable 处理器。我已成功连接 Mysql 数据库。 我使用的表是用户，其中包含 user_id、name、email、gender 等列。

TableName: User
Columns To Return: User_id, Email
Maximum Value Columns: user_id

通过上述属性，我可以成功获取包含列 (user_id,email) 的表，其中包含 user_id 的增量记录。

现在我想为查询添加一些附加条件。 假设，简单的条件“where gender='Male'”。

如文档 https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.4.0/org.apache.nifi.processors.standard.QueryDatabaseTable/index.html 中所述，我们可以添加额外的 where 子句属性。

因此，我在 QueryDatabaseTable 处理器中添加了如下属性，

property  -   value
WHERE     -   gender='Male' 

但它不起作用。

对此有任何帮助。

如何在 QueryDatabaseTable 中添加额外的条件子句，以及如何调试这个处理器运行了什么查询。

Answer 1

我认为您应该在名为“Additional Where Clause”的属性中添加性别 = 'Male'，而不是添加新属性。