Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <flow name="syncDBAccountsWithPostalCode" doc:id="69c19332-2ce2-4781-a7d6-a4ad92e107f7" >
- <scheduler doc:name="Scheduler" doc:id="33251da7-b1aa-4f3a-8b5f-735da06bb3e4" >
- <scheduling-strategy >
- <fixed-frequency frequency="10" timeUnit="SECONDS"/>
- </scheduling-strategy>
- </scheduler>
- <os:retrieve doc:name="lastAccountID" doc:id="64e061f7-f2dd-4a4e-bad4-fd223e1112c4" key="lastAccountID" target="osAccountID">
- <os:default-value ><![CDATA[#[0]]]></os:default-value>
- </os:retrieve>
- <db:select doc:name="Select" doc:id="f239b8e8-63c3-49c4-a72c-9ebe53a946e4" config-ref="Database_Config">
- <db:sql >select * from accounts where postal = :postal and accountID > :lastAccountID</db:sql>
- <db:input-parameters ><![CDATA[#[{'postal' : '32210', 'lastAccountID' : vars.osAccountID}]]]></db:input-parameters>
- </db:select>
- <os:store doc:name="lastAccountID" doc:id="8c8e7f87-6474-4418-9afd-1a9b4fd040dc" key="lastAccountID">
- <os:value ><![CDATA[#[max(payload..accountID)]]]></os:value>
- </os:store>
- <file:write doc:name="Copy_of_Write" doc:id="07cb0d37-bbde-4000-976c-24c77bbbf17c" config-ref="File_Config" path="output/DBAccountsWithPostal.csv" mode="APPEND" >
- <file:content ><![CDATA[#[output application/csv header=false --- payload]]]></file:content>
- </file:write>
- <logger level="INFO" doc:name="Logger" doc:id="cd1f0db1-aea3-4151-bf12-0f821458f7b9" message="#[output application/csv --- payload]"/>
- </flow>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement