nifi-1.3版でQueryDatabaseTableプロセッサを使用しています。私はMysqlデータベースとの接続に成功しました。 私が使用しているテーブルは、user_id、name、email、genderなどの列を持つUserです。nifi:どのプロパティをquerydatabasetableにSQL条件を追加する必要がありますか?
上記のプロパティで、私は正常にuser_idの増分レコードで列(user_id、電子メール)を持つテーブルをフェッチできました。
これで、クエリに条件を追加したいと思います。 シンプルな条件 "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に追加の条件節を追加する方法と、このプロセッサをどのように実行してクエリを実行するかをデバッグする方法。
QueryDatabaseTableプロセッサでは、「Additional Where Clause」という名前のプロパティはありません –
バージョン1.4.0で追加されましたhttps://issues.apache.org/jira/browse/NIFI-4257 –