如何将Salesforce查询结果保存到MySql数据库

Question

我想查询Salesforce并将结果保存在数据库中。第一个问题是我发现我的有效负载是一个ConsumerIterator。如何处理这些结果并将其存储在数据库中？

<flow name="process.accounts" processingStrategy="synchronous">
  <sfdc:select config-ref="MySQLDB" doc:name="Select Contact by Email">
    <sfdc:parameterized-query><![CDATA[SELECT first_name,last_name,email 
   FROM      Contact WHERE  email=#[payload.email]]]></db:parameterized-
   query>
   </sfdc:select>
  </flow>

   <flow name="insert.contacts.to.audit" >
     <vm:inbound-endpoint exchange-pattern="one-way" path="contact-audit"/>                                   
     <db:insert config-ref="Generic_Database_Configuration" doc:name="Save 
         Contact">
     <db:parameterized-query><![CDATA[insert into user_audit v 
               values(?,?,?)]]></db:parameterized-query>
     </db:insert>
   </flow>

Answer 1

mulesoft exchange提供了许多常见的集成模式，例如您所寻求的模式。

https://www.mulesoft.com/exchange/org.mule.templates/template-sfdc2db-account-bidirectional-sync/

使用该模板快速了解如何