2017-11-10 14 views
1

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に追加の条件節を追加する方法と、このプロセッサをどのように実行してクエリを実行するかをデバッグする方法。

答えて

0

新しいプロパティを追加するのではなく、「Additional Where Clause」というプロパティにgender = 'Male'を入れるべきだと思います。

+0

QueryDatabaseTableプロセッサでは、「Additional Where Clause」という名前のプロパティはありません –

+0

バージョン1.4.0で追加されましたhttps://issues.apache.org/jira/browse/NIFI-4257 –

関連する問題