Hello Mark,
For some reason I have failed to achieve my goal.
I have tried every possible reading and gone through countless places to
try to find out how to do this and I have failed.
I am attached the sample

170806  0:00:14     3 Query     SET autocommit=0
>                    3 Query     INSERT INTO employee (job, name) VALUES
> ('dev', 'Jones')
>                    3 Query     INSERT INTO employee (job, name) VALUES
> ('dev1', 'Eli')
>                    3 Query     commit


No what I do, I keep on getting single inserts..
is it something I am missing or what am I doing wrong..
I have attached my flow file in mail on what i have progressed so far..

Please assist further on solving this issue.


Regards,

On 2 August 2017 at 15:39, Mark Payne <marka...@hotmail.com> wrote:

> Noel,
>
> The easiest way is probably to use PutDatabaseRecord instead of PutSQL.
> This allows you to put
> a document that contains many entries into a database with a single query.
> Unfortunately, though,
> there is no XML Reader yet, so you'd need to convert the XML to JSON or
> CSV before using that processor.
>
> I know some people have been converting XML to JSON using TransformXml. An
> XSLT template that may be
> useful there is located at [1]. The nice thing about this is that you can
> have a single FlowFile with many entries,
> so you don't need to use SplitXml, EvaluateXPath, ReplaceText,
> UpdateAttribute... you can just use TransformXml
> to convert into JSON and then PutDatabaseRecord.
>
> Does this help?
>
> Thanks
> -Mark
>
>
>
> [1] https://github.com/bramstein/xsltjson
>
>
> On Aug 2, 2017, at 5:46 AM, Noel Alex Makumuli <alexnoe...@gmail.com>
> wrote:
>
> Hello all,
> Apologies I forgot to include the images in my previous questions. But I
> have still failed to find a solution for my problem..
> I tried to create a test using dummy data which looks like follows..
>
>>
>> <employees>
>> <employee>
>> <name>James</name>
>> <job>developer</job>
>> </employee>
>> <employee>
>> <name>Tiger</name>
>> <job>designer</job>
>> </employee>
>> <employee>
>> <name>robert</name>
>> <job>engineer</job>
>> </employee>
>> </employees>
>
>
> When I run the PutSql..
> i get 3 inserts:
>
>> Insert into Employees (name,job) values ('james','developer')
>> Insert into Employees (name,job) values ('second',otherjob)
>> Insert into Employees (name,job) values ('jame', 'thirdjob')
>
>
>
> But i would like to achieve just one query like::
>
> Insert into Employees (name,job) values( ('james','developer'),
>> ('second',otherjob), ('jame', 'thirdjob'))
>
>
> How can i achieve this..?
> I have been reading about sql.args.1.type and sql.args.1.value
> unfortunately i can not get my head around.. it..
> Please assist how to achieve this..
> As i read this link but it is not clear.. Sample Example
> <https://community.hortonworks.com/articles/91849/design-nifi-flow-for-using-putsql-processor-to-per.html>
>
> When I use ExtractText as suggest in the Sample Example mentioned above, i
> get the error: sql.args.1.value is not accepted in the ExtractText..
> Same applies for the ReplaceText as show in the image.
>
> How can i achieve this..? i am not sure how to move forward please assist..
>
> Please assist would be really happy.. and hope i made my self clear
>
> Regards,
>
>
> On 31 July 2017 at 19:02, Noel Alex Makumuli <alexnoe...@gmail.com> wrote:
>
>> Hello
>> I have a bunch of XML  files which I transform then I evaluate the XPATH
>> to get the [Please refer to the NIFI flow]
>> Each file consist of a single record which needs to inserted to the
>> database.
>>
>> At the moment  flow processor is as follows::
>>
>> ListFiles > FetchFile > TransformXml > EvaluateXpath > ReplaceText >
>> PutSql..
>>
>> In short, after transformation is done, i pick data i need as in image.
>> Then create my custom insert statement for the query.
>>
>> Then i load the data into the database.
>>
>> My question is i have thousand of files which I need to transform and
>> load in the database.
>>
>> So The PutSql Processor is inserting one file at a time..
>>
>> I am not sure how to go about and load n files using sql.args.N.args and
>> sql.args.N.value.
>>
>> Please advice on how to insert a batch of hundreds of files in one insert
>> statement.
>>
>> Regards
>> --
>> NOEL ALEX MAKUMULI
>>
>
>
>
> --
> NOEL ALEX MAKUMULI
> TANZANIA
>
> Mobile: +255 755 100 700 <+255%20755%20100%20700> ( Active)
> Mobile: +358 44 3077 817 ( Active)
> <Screenshot_20170802_123802.png><Screenshot_20170802_123837.png>
> <Screenshot_20170802_124013.png>
>
>
>


-- 
NOEL ALEX MAKUMULI
TANZANIA

Mobile: +255 755 100 700 ( Active)
Mobile: +358 44 3077 817 ( Active)
<?xml version="1.0" ?>
<template encoding-version="1.1">
  <description></description>
  <groupId>634b599a-8ee7-3ea4-d951-4ce7d550ceb3</groupId>
  <name>databaseImport</name>
  <snippet>
    <connections>
      <id>99d11fcc-e6b7-312b-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>81ee9a32-449c-3b6c-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>success</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>7f71b9d4-cd0f-3152-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>9d92850d-8a0f-305f-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <bends>
        <x>1304.0</x>
        <y>421.5</y>
      </bends>
      <bends>
        <x>1304.0</x>
        <y>471.5</y>
      </bends>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>f78036bc-c3e6-3bd5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>retry</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>f78036bc-c3e6-3bd5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>be27f490-bf71-35c0-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>81ee9a32-449c-3b6c-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>success</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>f78036bc-c3e6-3bd5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>cd57d23a-aa59-315c-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>f78036bc-c3e6-3bd5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>sql</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>82b4b14f-2684-33d5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>de1270fe-f790-3b03-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <bends>
        <x>646.0</x>
        <y>443.0</y>
      </bends>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>81ee9a32-449c-3b6c-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>failure</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>f78036bc-c3e6-3bd5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>e37a382c-bdc1-3fc3-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>81ee9a32-449c-3b6c-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>failure</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>82b4b14f-2684-33d5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>e9882f3f-ae38-3771-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>7f71b9d4-cd0f-3152-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>sql</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>82b4b14f-2684-33d5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>0b8e994d-7a00-3ebc-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>82b4b14f-2684-33d5-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>success</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>6e4b743d-6ab7-32ad-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <connections>
      <id>365a827f-ce77-3ffd-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
      <backPressureObjectThreshold>10000</backPressureObjectThreshold>
      <destination>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>6e4b743d-6ab7-32ad-0000-000000000000</id>
        <type>PROCESSOR</type>
      </destination>
      <flowFileExpiration>0 sec</flowFileExpiration>
      <labelIndex>1</labelIndex>
      <name></name>
      <selectedRelationships>success</selectedRelationships>
      <source>
        <groupId>287cb95f-cedf-3924-0000-000000000000</groupId>
        <id>1b0e4447-5161-3359-0000-000000000000</id>
        <type>PROCESSOR</type>
      </source>
      <zIndex>0</zIndex>
    </connections>
    <controllerServices>
      <id>81f87730-cc81-3118-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <bundle>
        <artifact>nifi-dbcp-service-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <comments></comments>
      <descriptors>
        <entry>
          <key>Database Connection URL</key>
          <value>
            <name>Database Connection URL</name>
          </value>
        </entry>
        <entry>
          <key>Database Driver Class Name</key>
          <value>
            <name>Database Driver Class Name</name>
          </value>
        </entry>
        <entry>
          <key>database-driver-locations</key>
          <value>
            <name>database-driver-locations</name>
          </value>
        </entry>
        <entry>
          <key>Database User</key>
          <value>
            <name>Database User</name>
          </value>
        </entry>
        <entry>
          <key>Password</key>
          <value>
            <name>Password</name>
          </value>
        </entry>
        <entry>
          <key>Max Wait Time</key>
          <value>
            <name>Max Wait Time</name>
          </value>
        </entry>
        <entry>
          <key>Max Total Connections</key>
          <value>
            <name>Max Total Connections</name>
          </value>
        </entry>
        <entry>
          <key>Validation-query</key>
          <value>
            <name>Validation-query</name>
          </value>
        </entry>
      </descriptors>
      <name>DBCPConnectionPool_hjkl</name>
      <persistsState>false</persistsState>
      <properties>
        <entry>
          <key>Database Connection URL</key>
          <value>jdbc:mysql://localhost:3306/nifi</value>
        </entry>
        <entry>
          <key>Database Driver Class Name</key>
          <value>com.mysql.jdbc.Driver</value>
        </entry>
        <entry>
          <key>database-driver-locations</key>
          <value>/home/noax/apps/jars/mysql-connector-java-5.1.13.jar</value>
        </entry>
        <entry>
          <key>Database User</key>
          <value>root</value>
        </entry>
        <entry>
          <key>Password</key>
        </entry>
        <entry>
          <key>Max Wait Time</key>
        </entry>
        <entry>
          <key>Max Total Connections</key>
        </entry>
        <entry>
          <key>Validation-query</key>
        </entry>
      </properties>
      <state>ENABLED</state>
      <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
    </controllerServices>
    <controllerServices>
      <id>128fab2a-4c58-3aee-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <bundle>
        <artifact>nifi-dbcp-service-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <comments></comments>
      <descriptors>
        <entry>
          <key>Database Connection URL</key>
          <value>
            <name>Database Connection URL</name>
          </value>
        </entry>
        <entry>
          <key>Database Driver Class Name</key>
          <value>
            <name>Database Driver Class Name</name>
          </value>
        </entry>
        <entry>
          <key>database-driver-locations</key>
          <value>
            <name>database-driver-locations</name>
          </value>
        </entry>
        <entry>
          <key>Database User</key>
          <value>
            <name>Database User</name>
          </value>
        </entry>
        <entry>
          <key>Password</key>
          <value>
            <name>Password</name>
          </value>
        </entry>
        <entry>
          <key>Max Wait Time</key>
          <value>
            <name>Max Wait Time</name>
          </value>
        </entry>
        <entry>
          <key>Max Total Connections</key>
          <value>
            <name>Max Total Connections</name>
          </value>
        </entry>
        <entry>
          <key>Validation-query</key>
          <value>
            <name>Validation-query</name>
          </value>
        </entry>
      </descriptors>
      <name>DBCPConnectionPool</name>
      <persistsState>false</persistsState>
      <properties>
        <entry>
          <key>Database Connection URL</key>
          <value>jdbc:mysql://localhost:3306/nifi</value>
        </entry>
        <entry>
          <key>Database Driver Class Name</key>
          <value>com.mysql.jdbc.Driver</value>
        </entry>
        <entry>
          <key>database-driver-locations</key>
          <value>/home/noax/apps/jars/mysql-connector-java-5.1.13.jar</value>
        </entry>
        <entry>
          <key>Database User</key>
          <value>root</value>
        </entry>
        <entry>
          <key>Password</key>
        </entry>
        <entry>
          <key>Max Wait Time</key>
          <value>500 millis</value>
        </entry>
        <entry>
          <key>Max Total Connections</key>
          <value>8</value>
        </entry>
        <entry>
          <key>Validation-query</key>
        </entry>
      </properties>
      <state>ENABLED</state>
      <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
    </controllerServices>
    <controllerServices>
      <id>25a4b944-2ae3-399a-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <bundle>
        <artifact>nifi-record-serialization-services-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <descriptors>
        <entry>
          <key>schema-access-strategy</key>
          <value>
            <name>schema-access-strategy</name>
          </value>
        </entry>
        <entry>
          <key>schema-registry</key>
          <value>
            <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
            <name>schema-registry</name>
          </value>
        </entry>
        <entry>
          <key>schema-name</key>
          <value>
            <name>schema-name</name>
          </value>
        </entry>
        <entry>
          <key>schema-text</key>
          <value>
            <name>schema-text</name>
          </value>
        </entry>
        <entry>
          <key>Date Format</key>
          <value>
            <name>Date Format</name>
          </value>
        </entry>
        <entry>
          <key>Time Format</key>
          <value>
            <name>Time Format</name>
          </value>
        </entry>
        <entry>
          <key>Timestamp Format</key>
          <value>
            <name>Timestamp Format</name>
          </value>
        </entry>
        <entry>
          <key>CSV Format</key>
          <value>
            <name>CSV Format</name>
          </value>
        </entry>
        <entry>
          <key>Value Separator</key>
          <value>
            <name>Value Separator</name>
          </value>
        </entry>
        <entry>
          <key>Skip Header Line</key>
          <value>
            <name>Skip Header Line</name>
          </value>
        </entry>
        <entry>
          <key>Quote Character</key>
          <value>
            <name>Quote Character</name>
          </value>
        </entry>
        <entry>
          <key>Escape Character</key>
          <value>
            <name>Escape Character</name>
          </value>
        </entry>
        <entry>
          <key>Comment Marker</key>
          <value>
            <name>Comment Marker</name>
          </value>
        </entry>
        <entry>
          <key>Null String</key>
          <value>
            <name>Null String</name>
          </value>
        </entry>
        <entry>
          <key>Trim Fields</key>
          <value>
            <name>Trim Fields</name>
          </value>
        </entry>
      </descriptors>
      <name>CSVReader</name>
      <persistsState>false</persistsState>
      <properties>
        <entry>
          <key>schema-access-strategy</key>
        </entry>
        <entry>
          <key>schema-registry</key>
        </entry>
        <entry>
          <key>schema-name</key>
        </entry>
        <entry>
          <key>schema-text</key>
        </entry>
        <entry>
          <key>Date Format</key>
        </entry>
        <entry>
          <key>Time Format</key>
        </entry>
        <entry>
          <key>Timestamp Format</key>
        </entry>
        <entry>
          <key>CSV Format</key>
        </entry>
        <entry>
          <key>Value Separator</key>
        </entry>
        <entry>
          <key>Skip Header Line</key>
        </entry>
        <entry>
          <key>Quote Character</key>
        </entry>
        <entry>
          <key>Escape Character</key>
        </entry>
        <entry>
          <key>Comment Marker</key>
        </entry>
        <entry>
          <key>Null String</key>
        </entry>
        <entry>
          <key>Trim Fields</key>
        </entry>
      </properties>
      <state>ENABLED</state>
      <type>org.apache.nifi.csv.CSVReader</type>
    </controllerServices>
    <processors>
      <id>81ee9a32-449c-3b6c-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <position>
        <x>598.0</x>
        <y>757.5</y>
      </position>
      <bundle>
        <artifact>nifi-standard-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <config>
        <bulletinLevel>WARN</bulletinLevel>
        <comments></comments>
        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
        <descriptors>
          <entry>
            <key>Log Level</key>
            <value>
              <name>Log Level</name>
            </value>
          </entry>
          <entry>
            <key>Log Payload</key>
            <value>
              <name>Log Payload</name>
            </value>
          </entry>
          <entry>
            <key>Attributes to Log</key>
            <value>
              <name>Attributes to Log</name>
            </value>
          </entry>
          <entry>
            <key>Attributes to Ignore</key>
            <value>
              <name>Attributes to Ignore</name>
            </value>
          </entry>
          <entry>
            <key>Log prefix</key>
            <value>
              <name>Log prefix</name>
            </value>
          </entry>
        </descriptors>
        <executionNode>ALL</executionNode>
        <lossTolerant>false</lossTolerant>
        <penaltyDuration>30 sec</penaltyDuration>
        <properties>
          <entry>
            <key>Log Level</key>
            <value>info</value>
          </entry>
          <entry>
            <key>Log Payload</key>
            <value>false</value>
          </entry>
          <entry>
            <key>Attributes to Log</key>
          </entry>
          <entry>
            <key>Attributes to Ignore</key>
          </entry>
          <entry>
            <key>Log prefix</key>
          </entry>
        </properties>
        <runDurationMillis>0</runDurationMillis>
        <schedulingPeriod>0 sec</schedulingPeriod>
        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
        <yieldDuration>1 sec</yieldDuration>
      </config>
      <name>LogAttribute</name>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>success</name>
      </relationships>
      <style></style>
      <type>org.apache.nifi.processors.standard.LogAttribute</type>
    </processors>
    <processors>
      <id>82b4b14f-2684-33d5-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <position>
        <x>3.0</x>
        <y>222.0</y>
      </position>
      <bundle>
        <artifact>nifi-standard-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <config>
        <bulletinLevel>WARN</bulletinLevel>
        <comments></comments>
        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
        <descriptors>
          <entry>
            <key>JDBC Connection Pool</key>
            <value>
              <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
              <name>JDBC Connection Pool</name>
            </value>
          </entry>
          <entry>
            <key>Statement Type</key>
            <value>
              <name>Statement Type</name>
            </value>
          </entry>
          <entry>
            <key>Table Name</key>
            <value>
              <name>Table Name</name>
            </value>
          </entry>
          <entry>
            <key>Catalog Name</key>
            <value>
              <name>Catalog Name</name>
            </value>
          </entry>
          <entry>
            <key>Schema Name</key>
            <value>
              <name>Schema Name</name>
            </value>
          </entry>
          <entry>
            <key>Translate Field Names</key>
            <value>
              <name>Translate Field Names</name>
            </value>
          </entry>
          <entry>
            <key>Unmatched Field Behavior</key>
            <value>
              <name>Unmatched Field Behavior</name>
            </value>
          </entry>
          <entry>
            <key>Unmatched Column Behavior</key>
            <value>
              <name>Unmatched Column Behavior</name>
            </value>
          </entry>
          <entry>
            <key>Update Keys</key>
            <value>
              <name>Update Keys</name>
            </value>
          </entry>
          <entry>
            <key>jts-quoted-identifiers</key>
            <value>
              <name>jts-quoted-identifiers</name>
            </value>
          </entry>
          <entry>
            <key>jts-quoted-table-identifiers</key>
            <value>
              <name>jts-quoted-table-identifiers</name>
            </value>
          </entry>
        </descriptors>
        <executionNode>ALL</executionNode>
        <lossTolerant>false</lossTolerant>
        <penaltyDuration>30 sec</penaltyDuration>
        <properties>
          <entry>
            <key>JDBC Connection Pool</key>
            <value>128fab2a-4c58-3aee-0000-000000000000</value>
          </entry>
          <entry>
            <key>Statement Type</key>
            <value>INSERT</value>
          </entry>
          <entry>
            <key>Table Name</key>
            <value>employee</value>
          </entry>
          <entry>
            <key>Catalog Name</key>
          </entry>
          <entry>
            <key>Schema Name</key>
          </entry>
          <entry>
            <key>Translate Field Names</key>
            <value>true</value>
          </entry>
          <entry>
            <key>Unmatched Field Behavior</key>
            <value>Ignore Unmatched Fields</value>
          </entry>
          <entry>
            <key>Unmatched Column Behavior</key>
            <value>Fail on Unmatched Columns</value>
          </entry>
          <entry>
            <key>Update Keys</key>
          </entry>
          <entry>
            <key>jts-quoted-identifiers</key>
            <value>false</value>
          </entry>
          <entry>
            <key>jts-quoted-table-identifiers</key>
            <value>false</value>
          </entry>
        </properties>
        <runDurationMillis>0</runDurationMillis>
        <schedulingPeriod>0 sec</schedulingPeriod>
        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
        <yieldDuration>1 sec</yieldDuration>
      </config>
      <name>ConvertJSONToSQL</name>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>failure</name>
      </relationships>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>original</name>
      </relationships>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>sql</name>
      </relationships>
      <style></style>
      <type>org.apache.nifi.processors.standard.ConvertJSONToSQL</type>
    </processors>
    <processors>
      <id>f78036bc-c3e6-3bd5-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <position>
        <x>849.0</x>
        <y>381.5</y>
      </position>
      <bundle>
        <artifact>nifi-standard-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <config>
        <bulletinLevel>WARN</bulletinLevel>
        <comments></comments>
        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
        <descriptors>
          <entry>
            <key>put-db-record-record-reader</key>
            <value>
              <identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService>
              <name>put-db-record-record-reader</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-statement-type</key>
            <value>
              <name>put-db-record-statement-type</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-dcbp-service</key>
            <value>
              <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
              <name>put-db-record-dcbp-service</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-catalog-name</key>
            <value>
              <name>put-db-record-catalog-name</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-schema-name</key>
            <value>
              <name>put-db-record-schema-name</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-table-name</key>
            <value>
              <name>put-db-record-table-name</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-translate-field-names</key>
            <value>
              <name>put-db-record-translate-field-names</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-unmatched-field-behavior</key>
            <value>
              <name>put-db-record-unmatched-field-behavior</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-unmatched-column-behavior</key>
            <value>
              <name>put-db-record-unmatched-column-behavior</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-update-keys</key>
            <value>
              <name>put-db-record-update-keys</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-field-containing-sql</key>
            <value>
              <name>put-db-record-field-containing-sql</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-quoted-identifiers</key>
            <value>
              <name>put-db-record-quoted-identifiers</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-quoted-table-identifiers</key>
            <value>
              <name>put-db-record-quoted-table-identifiers</name>
            </value>
          </entry>
          <entry>
            <key>put-db-record-query-timeout</key>
            <value>
              <name>put-db-record-query-timeout</name>
            </value>
          </entry>
          <entry>
            <key>rollback-on-failure</key>
            <value>
              <name>rollback-on-failure</name>
            </value>
          </entry>
        </descriptors>
        <executionNode>ALL</executionNode>
        <lossTolerant>false</lossTolerant>
        <penaltyDuration>30 sec</penaltyDuration>
        <properties>
          <entry>
            <key>put-db-record-record-reader</key>
            <value>25a4b944-2ae3-399a-0000-000000000000</value>
          </entry>
          <entry>
            <key>put-db-record-statement-type</key>
            <value>INSERT</value>
          </entry>
          <entry>
            <key>put-db-record-dcbp-service</key>
            <value>81f87730-cc81-3118-0000-000000000000</value>
          </entry>
          <entry>
            <key>put-db-record-catalog-name</key>
          </entry>
          <entry>
            <key>put-db-record-schema-name</key>
          </entry>
          <entry>
            <key>put-db-record-table-name</key>
            <value>employee</value>
          </entry>
          <entry>
            <key>put-db-record-translate-field-names</key>
            <value>true</value>
          </entry>
          <entry>
            <key>put-db-record-unmatched-field-behavior</key>
            <value>Ignore Unmatched Fields</value>
          </entry>
          <entry>
            <key>put-db-record-unmatched-column-behavior</key>
            <value>Fail on Unmatched Columns</value>
          </entry>
          <entry>
            <key>put-db-record-update-keys</key>
          </entry>
          <entry>
            <key>put-db-record-field-containing-sql</key>
          </entry>
          <entry>
            <key>put-db-record-quoted-identifiers</key>
            <value>false</value>
          </entry>
          <entry>
            <key>put-db-record-quoted-table-identifiers</key>
            <value>false</value>
          </entry>
          <entry>
            <key>put-db-record-query-timeout</key>
            <value>0 seconds</value>
          </entry>
          <entry>
            <key>rollback-on-failure</key>
            <value>false</value>
          </entry>
        </properties>
        <runDurationMillis>0</runDurationMillis>
        <schedulingPeriod>0 sec</schedulingPeriod>
        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
        <yieldDuration>1 sec</yieldDuration>
      </config>
      <name>PutDatabaseRecord</name>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>failure</name>
      </relationships>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>retry</name>
      </relationships>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>success</name>
      </relationships>
      <style></style>
      <type>org.apache.nifi.processors.standard.PutDatabaseRecord</type>
    </processors>
    <processors>
      <id>1b0e4447-5161-3359-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <position>
        <x>584.0</x>
        <y>0.0</y>
      </position>
      <bundle>
        <artifact>nifi-standard-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <config>
        <bulletinLevel>WARN</bulletinLevel>
        <comments></comments>
        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
        <descriptors>
          <entry>
            <key>Input Directory</key>
            <value>
              <name>Input Directory</name>
            </value>
          </entry>
          <entry>
            <key>Recurse Subdirectories</key>
            <value>
              <name>Recurse Subdirectories</name>
            </value>
          </entry>
          <entry>
            <key>Input Directory Location</key>
            <value>
              <name>Input Directory Location</name>
            </value>
          </entry>
          <entry>
            <key>File Filter</key>
            <value>
              <name>File Filter</name>
            </value>
          </entry>
          <entry>
            <key>Path Filter</key>
            <value>
              <name>Path Filter</name>
            </value>
          </entry>
          <entry>
            <key>Minimum File Age</key>
            <value>
              <name>Minimum File Age</name>
            </value>
          </entry>
          <entry>
            <key>Maximum File Age</key>
            <value>
              <name>Maximum File Age</name>
            </value>
          </entry>
          <entry>
            <key>Minimum File Size</key>
            <value>
              <name>Minimum File Size</name>
            </value>
          </entry>
          <entry>
            <key>Maximum File Size</key>
            <value>
              <name>Maximum File Size</name>
            </value>
          </entry>
          <entry>
            <key>Ignore Hidden Files</key>
            <value>
              <name>Ignore Hidden Files</name>
            </value>
          </entry>
        </descriptors>
        <executionNode>ALL</executionNode>
        <lossTolerant>false</lossTolerant>
        <penaltyDuration>30 sec</penaltyDuration>
        <properties>
          <entry>
            <key>Input Directory</key>
            <value>/home/noax/nifi/mi/csv</value>
          </entry>
          <entry>
            <key>Recurse Subdirectories</key>
            <value>true</value>
          </entry>
          <entry>
            <key>Input Directory Location</key>
            <value>Local</value>
          </entry>
          <entry>
            <key>File Filter</key>
            <value>[^\.].*</value>
          </entry>
          <entry>
            <key>Path Filter</key>
          </entry>
          <entry>
            <key>Minimum File Age</key>
            <value>0 sec</value>
          </entry>
          <entry>
            <key>Maximum File Age</key>
          </entry>
          <entry>
            <key>Minimum File Size</key>
            <value>0 B</value>
          </entry>
          <entry>
            <key>Maximum File Size</key>
          </entry>
          <entry>
            <key>Ignore Hidden Files</key>
            <value>true</value>
          </entry>
        </properties>
        <runDurationMillis>0</runDurationMillis>
        <schedulingPeriod>0 sec</schedulingPeriod>
        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
        <yieldDuration>1 sec</yieldDuration>
      </config>
      <name>ListFile</name>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>success</name>
      </relationships>
      <style></style>
      <type>org.apache.nifi.processors.standard.ListFile</type>
    </processors>
    <processors>
      <id>6e4b743d-6ab7-32ad-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <position>
        <x>583.0</x>
        <y>181.0</y>
      </position>
      <bundle>
        <artifact>nifi-standard-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <config>
        <bulletinLevel>WARN</bulletinLevel>
        <comments></comments>
        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
        <descriptors>
          <entry>
            <key>File to Fetch</key>
            <value>
              <name>File to Fetch</name>
            </value>
          </entry>
          <entry>
            <key>Completion Strategy</key>
            <value>
              <name>Completion Strategy</name>
            </value>
          </entry>
          <entry>
            <key>Move Destination Directory</key>
            <value>
              <name>Move Destination Directory</name>
            </value>
          </entry>
          <entry>
            <key>Move Conflict Strategy</key>
            <value>
              <name>Move Conflict Strategy</name>
            </value>
          </entry>
          <entry>
            <key>Log level when file not found</key>
            <value>
              <name>Log level when file not found</name>
            </value>
          </entry>
          <entry>
            <key>Log level when permission denied</key>
            <value>
              <name>Log level when permission denied</name>
            </value>
          </entry>
        </descriptors>
        <executionNode>ALL</executionNode>
        <lossTolerant>false</lossTolerant>
        <penaltyDuration>30 sec</penaltyDuration>
        <properties>
          <entry>
            <key>File to Fetch</key>
            <value>${absolute.path}/${filename}</value>
          </entry>
          <entry>
            <key>Completion Strategy</key>
            <value>None</value>
          </entry>
          <entry>
            <key>Move Destination Directory</key>
          </entry>
          <entry>
            <key>Move Conflict Strategy</key>
            <value>Rename</value>
          </entry>
          <entry>
            <key>Log level when file not found</key>
            <value>ERROR</value>
          </entry>
          <entry>
            <key>Log level when permission denied</key>
            <value>ERROR</value>
          </entry>
        </properties>
        <runDurationMillis>0</runDurationMillis>
        <schedulingPeriod>0 sec</schedulingPeriod>
        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
        <yieldDuration>1 sec</yieldDuration>
      </config>
      <name>FetchFile</name>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>failure</name>
      </relationships>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>not.found</name>
      </relationships>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>permission.denied</name>
      </relationships>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>success</name>
      </relationships>
      <style></style>
      <type>org.apache.nifi.processors.standard.FetchFile</type>
    </processors>
    <processors>
      <id>7f71b9d4-cd0f-3152-0000-000000000000</id>
      <parentGroupId>287cb95f-cedf-3924-0000-000000000000</parentGroupId>
      <position>
        <x>0.0</x>
        <y>533.0</y>
      </position>
      <bundle>
        <artifact>nifi-standard-nar</artifact>
        <group>org.apache.nifi</group>
        <version>1.3.0</version>
      </bundle>
      <config>
        <bulletinLevel>WARN</bulletinLevel>
        <comments></comments>
        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
        <descriptors>
          <entry>
            <key>JDBC Connection Pool</key>
            <value>
              <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
              <name>JDBC Connection Pool</name>
            </value>
          </entry>
          <entry>
            <key>Support Fragmented Transactions</key>
            <value>
              <name>Support Fragmented Transactions</name>
            </value>
          </entry>
          <entry>
            <key>Transaction Timeout</key>
            <value>
              <name>Transaction Timeout</name>
            </value>
          </entry>
          <entry>
            <key>Batch Size</key>
            <value>
              <name>Batch Size</name>
            </value>
          </entry>
          <entry>
            <key>Obtain Generated Keys</key>
            <value>
              <name>Obtain Generated Keys</name>
            </value>
          </entry>
          <entry>
            <key>rollback-on-failure</key>
            <value>
              <name>rollback-on-failure</name>
            </value>
          </entry>
        </descriptors>
        <executionNode>ALL</executionNode>
        <lossTolerant>false</lossTolerant>
        <penaltyDuration>30 sec</penaltyDuration>
        <properties>
          <entry>
            <key>JDBC Connection Pool</key>
            <value>128fab2a-4c58-3aee-0000-000000000000</value>
          </entry>
          <entry>
            <key>Support Fragmented Transactions</key>
            <value>true</value>
          </entry>
          <entry>
            <key>Transaction Timeout</key>
          </entry>
          <entry>
            <key>Batch Size</key>
            <value>100</value>
          </entry>
          <entry>
            <key>Obtain Generated Keys</key>
            <value>false</value>
          </entry>
          <entry>
            <key>rollback-on-failure</key>
            <value>false</value>
          </entry>
        </properties>
        <runDurationMillis>0</runDurationMillis>
        <schedulingPeriod>0 sec</schedulingPeriod>
        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
        <yieldDuration>1 sec</yieldDuration>
      </config>
      <name>PutSQL</name>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>failure</name>
      </relationships>
      <relationships>
        <autoTerminate>true</autoTerminate>
        <name>retry</name>
      </relationships>
      <relationships>
        <autoTerminate>false</autoTerminate>
        <name>success</name>
      </relationships>
      <style></style>
      <type>org.apache.nifi.processors.standard.PutSQL</type>
    </processors>
  </snippet>
  <timestamp>08/06/2017 00:12:07 EAT</timestamp>
</template>

Reply via email to