2017-06-23 2 views
2

私はそれを使用してSQL形式に自分のjsonファイルを変換しようとすると、postgresqlにpostgresqlにインジェクションjsonファイルを変換しようとします。 ConvertJSONToSQLプロセッサは、その後、私はreplacetextプロセッサにフローを渡し、その後、私はputsqlプロセッサにフローを作成します。 enter image description hereNifi putsqlプロセッサエラー:org.postgresql.util.PSQLExceptionのために:列のインデックスが範囲外です:1

PutSQLエラー: はenter image description here

置換値:
INSERT INTO public.detail (id,name, salary) VALUES (${id},${name},${salary})

答えて

2

putSQLする前に、あなたがflowfileコンテンツを有していてもよくputsqlプロセッサでは、私は問題

Due to org.postgresql.util.PSQLException: The column index is out of range: 1

NIFIフローを得ました下記のようになります。

id-->1 
name->stack 
salary->12k 

INSERT INTO public.detail (id,name, salary) VALUES (1,stack,12k) 

値のインデックスが見つからない場合は、値1が見つかりません。

たとえば、着信フローファイルに 'id'属性が存在しない場合、そのエラーが表示されることがあります。

したがって、着信フローファイルのすべての属性が存在し、正しく挿入クエリを形成していることを確認する必要があります。 [Or] putSQL着信キューにキューイングした後に挿入クエリを作成し、PostgresSQLで実行します。

実行すると、putSQLも実行されます。

関連する問題