Как ответить на пользовательский JSON-запрос HTTP в MULE ESB

я использую студию мулов, я подключаюсь к postgressql для выбора данных, у меня все хорошо, я только что попал в середину.

 curl -H "Content-Type: application/json" -d '{"id":"1"}' http://localhost:8081/selectdb

я получаю ответ от базы данных, но не могу отформатировать данные в соответствии с требованиями клиента. мой конфиг такой

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

<mule xmlns:cxf="http://www.mulesoft.org/schema/mule/cxf" xmlns:scripting="http://www.mulesoft.org/schema/mule/scripting" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:jdbc-ee="http://www.mulesoft.org/schema/mule/ee/jdbc" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" 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" version="EE-3.4.1" 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/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/xml http://www.mulesoft.org/schema/mule/xml/current/mule-xml.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/ee/jdbc http://www.mulesoft.org/schema/mule/ee/jdbc/current/mule-jdbc-ee.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd
http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/current/mule-scripting.xsd
http://www.mulesoft.org/schema/mule/cxf http://www.mulesoft.org/schema/mule/cxf/current/mule-cxf.xsd">
    <jdbc-ee:postgresql-data-source name="PostgreSQL_Data_Source" user="youtilitydba" password="Youtility11" url="jdbc:postgresql://localhost:5432/sample" transactionIsolation="UNSPECIFIED" doc:name="PostgreSQL Data Source"/>
    <jdbc-ee:connector name="Database" dataSource-ref="PostgreSQL_Data_Source" validateConnections="true" queryTimeout="-1" pollingFrequency="0" doc:name="Database"/>
    <flow name="selectfromdbFlow1" doc:name="selectfromdbFlow1">
        <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" path="selectdb" doc:name="HTTP"/>
        <json:json-to-object-transformer returnClass="java.util.Map" doc:name="JSON to Object"/>

        <jdbc-ee:outbound-endpoint exchange-pattern="request-response" queryKey="SELECT" queryTimeout="-1" connector-ref="Database" doc:name="Database">
            <jdbc-ee:query key="SELECT" value="select  firstname,lastname,id  from users where id =#[message.payload.id]"/>
        </jdbc-ee:outbound-endpoint>
        <response>
            <http:response-builder status="200" contentType="application/json" doc:name="HTTP Response Builder"/>
        </response>
        <logger message="#[payload]" level="INFO" doc:name="Logger"/>
        <response>
            <set-payload value="#[payload]" doc:name="Set Payload"/>
        </response>

                <echo-component doc:name="Echo"/>
            </flow>
</mule>

в соответствии с приведенной выше конфигурацией я получаю ответ от базы данных, но не могу отформатировать свой журнал, как это

org.mule.api.processor.LoggerMessageProcessor: [{lastname=sk, firstname=naryanan, id=1}]

но не могу отправить клиент curl, я хочу отправить ответ в этом формате клиенту

{"ResponseJSON": {"Body":{"Datalist": [{lastname=sk, firstname=naryanan, id=1}]},"Status":"200"}}

Как я получаю этот формат в muleesb


person faisal shaik    schedule 28.11.2013    source источник
comment
Удалите echo-component: это бесполезно. Если вам нужно ведение журнала, используйте logger.   -  person David Dossot    schedule 28.11.2013


Ответы (2)


Используйте expression-transformer для создания Карты Карта Карты, чтобы обернуть вашу полезную нагрузку в {"ResponseJSON": {"Body":{"Datalist". Сериализуйте эту карту в JSON, и все готово.

person David Dossot    schedule 28.11.2013
comment
��srjava.util.ArrayListx����a�Isizexpw sr$org.mule.util.CaseInsensitiveHashMap����gE�xpw ?@lastnametfft firstnametfftidt5xxy предоставляет такой формат клиенту - person faisal shaik; 29.11.2013
comment
Вы, вероятно, пропустили object-to-json-transformer. Также верхний объект должен быть картой, а не списком, поскольку вы собираетесь создать объект JSON. - person David Dossot; 29.11.2013
comment
но я не могу получить правильный набор результатов - person faisal shaik; 03.12.2013

Составление потока: [DATABASE] -> [Object-to-JSON] -> [Set Payload]

Установите значение [Set Payload] следующим образом

{"ResponseJSON": {"Body":{"Datalist": #[payload]},"Status":"200"}}

Весь поток:

<flow name="mulemuleFlow1" doc:name="mulemuleFlow1">
    <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" doc:name="HTTP"/>
    <jdbc:outbound-endpoint exchange-pattern="request-response" queryKey="SELECT" queryTimeout="-1" connector-ref="JDBC1" doc:name="Database">
        <jdbc:query key="SELECT" value="SELECT * FROM something;"/>
    </jdbc:outbound-endpoint>
    <json:object-to-json-transformer doc:name="Object to JSON"/>
    <set-payload value="{&quot;ResponseJSON&quot;: {&quot;Body&quot;:{&quot;Datalist&quot;: #[payload]},&quot;Status&quot;:&quot;200&quot;}}" doc:name="Set Payload"/>
</flow>
person Dongho Yoo    schedule 24.01.2014