Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <db:mysql-config name="MySQL_Configuration" host="${crm.db.host}" port="${crm.db.port}" user="${crm.db.user}" password="${crm.db.password}" database="${crm.db.instance}" doc:name="MySQL Configuration"/>
- <flow name="levius-contatoFlow" processingStrategy="synchronous">
- <poll doc:name="Poll">
- <fixed-frequency-scheduler frequency="10000"/>
- <watermark variable="carimboTempo" default-expression="2016-03-24 00:00:00" update-expression="#[flowVars.date_modified]"/>
- <db:select config-ref="MySQL_Configuration" doc:name="Database">
- <db:parameterized-query><![CDATA[select
- ac.id,
- c.first_name,
- c.last_name,
- greatest(ac.date_modified, c.date_modified) date_modified
- from accounts_contacts ac
- join contacts c on c.id = ac.contact_id
- where greatest(ac.date_modified, c.date_modified) > #[carimboTempo]
- order by greatest(ac.date_modified, c.date_modified)]]></db:parameterized-query>
- </db:select>
- </poll>
- <foreach doc:name="For Each">
- <set-variable variableName="date_modified" value="#[payload.date_modified]" doc:name="Variable"/>
- </foreach>
- </flow>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement