MuleESB：将Salesforce数据插入到mysql数据库中

Question

我有关于将salesforce数据插入mysql数据库的问题。

我可以查询salesforce帐户，并从salesforce帐户中检索正确的数据。

如果我想将salesforce数据插入到mysql数据库中，则会出现错误。 只需将NULL值插入到数据库中。

我认为输入到mysql组件是正确的，但输出是错误的。

也许你可以帮我。

附加是我的xml代码。怎么了？

<?xml version="1.0" encoding="UTF-8"?> 

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:dw="http://www.mulesoft.org/schema/mule/ee/dw" xmlns:db="http://www.mulesoft.org/schema/mule/db" xmlns:metadata="http://www.mulesoft.org/schema/mule/metadata" xmlns:sfdc="http://www.mulesoft.org/schema/mule/sfdc" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" 
    xmlns:spring="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd 
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd 
http://www.mulesoft.org/schema/mule/sfdc http://www.mulesoft.org/schema/mule/sfdc/current/mule-sfdc.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd 
http://www.mulesoft.org/schema/mule/ee/dw http://www.mulesoft.org/schema/mule/ee/dw/current/dw.xsd 
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd"> 
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/> 
    <db:mysql-config name="MySQL_Configuration" host="localhost" port="xxx" user="xxx" password="xxx" database="salesforce" doc:name="MySQL Configuration"/> 
    <sfdc:config name="Salesforce__Basic_Authentication" username="xxxx" password="xxx" securityToken="xxxx" doc:name="Salesforce: Basic Authentication"/> 
    <flow name="salesforce_query_mysqlFlow"> 
     <http:listener config-ref="HTTP_Listener_Configuration" path="/demo" doc:name="HTTP"/> 
     <sfdc:query config-ref="Salesforce__Basic_Authentication" query="dsql:SELECT BillingCity,BillingCountry,BillingPostalCode,BillingStreet,Id,Name,Phone,Website FROM Account" doc:name="Salesforce"/> 
     <logger message="#[org.apache.commons.collections.IteratorUtils.toList(message.payload)]" level="INFO" metadata:id="d66ba8a4-9f12-4def-b4fe-ea0669d02170" doc:name="Logger"/> 
     <dw:transform-message metadata:id="72012d35-6807-484b-89bf-cab577f4f646" doc:name="Transform Message"> 
      <dw:input-payload mimeType="application/java" doc:sample="sample_data/list_Account_2.dwl"/> 
      <dw:input-variable variableName="salesforce_data"/> 
      <dw:set-payload><![CDATA[%dw 1.0    
%output application/java 
--- 

payload map { 
    BillingCountry: $.BillingCountry, 
    BillingCity: $.BillingCity, 
    BillingStreet: $.BillingStreet, 
    Phone: $.Phone, 
    Website: $.Website, 
    BillingPostalCode: $.BillingPostalCode, 
    Name: $.Name, 
    SalesforceId: $.Id 
}]]></dw:set-payload> 
     </dw:transform-message> 
     <db:insert config-ref="MySQL_Configuration" doc:name="Database" > 
      <db:parameterized-query><![CDATA[INSERT INTO salesforce.salesforce_account(
BillingCity,BillingCountry,BillingPostalCode,BillingStreet,Name,Phone,Website,Id) 
VALUES 
(#[message.payload.BillingCity],#[message.payload.BillingCountry],#[message.payload.BillingPostalCode], #[message.payload.BillingStreet], #[message.payload.Name], #[message.payload.Phone],#[message.payload.Website], 
#[message.payload.SalesforceId]);]]></db:parameterized-query> 
     </db:insert> 
     <logger message="#[message.payload]" level="INFO" doc:name="Logger"/> 
    </flow> 
</mule> 

Answer 1

你需要一个步骤，以便能够从Salesforce的插入所有记录到数据库。在当前配置中，的输出变换消息组件是记录列表。而数据库查询需要单个记录。因此，你应该选择下列选项之一：

1. 添加变换消息和数据库
2. 检查/勾选基本设置里面的批量方式选项之间的集合分配器组件节数据库属性bulkMode="true"