Advertisement
Guest User

Untitled

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