java - Mule中如何动态插入json数据到数据库中

Question

嗨，我有一个 json 文件，如下所示，

JSON:

[
    {
        "name": "Steve",
        "salary": "$1000",
        "age": "26"
    },
    {
        "name': "Laura",
        "salary': "$1500",
        "age": "28"
    },
    {
        "name': "Jack",
        "salary": "$2000",
        "age": "30"
    }
]

我还有一个名为Employee的数据库表，它包含三列姓名、年龄和薪水。这里我想处理Json数据并将其存储到Employee表中。那么我怎样才能在骡子中做到这一点呢？

Answer 1

首先你的json请求无效，你需要在json中放入"而不是'键。因此，有效的 json 将是:-

[
    {
        "name": "Steve",
        "salary": "$1000",
        "age": "26"
    },
    {
        "name": "Laura",
        "salary": "$1500",
        "age": "28"
    },
    {
        "name": "Jack",
        "salary": "$2000",
        "age": "30"
    }
]   

您需要传递来自POSTMAN的请求浏览器客户端:-

现在，您可以使用以下 Mule 流程插入数据库:-

<http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"></http:listener-config>

    <flow name="Flow"> 
        <http:listener config-ref="HTTP_Listener_Configuration" path="/set" doc:name="HTTP"></http:listener>  
        <json:json-to-object-transformer returnClass="java.util.List" doc:name="JSON to Object"></json:json-to-object-transformer>  
        <foreach collection="#[message.payload]" doc:name="For Each">
            <db:insert config-ref="Generic_Database_Configuration" doc:name="Database">
                <db:parameterized-query><![CDATA[INSERT into table1 (NAME, SALARY, AGE) VALUES (#[message.payload.name],#[message.payload.salary],#[message.payload.age]);]]></db:parameterized-query>
            </db:insert>
        </foreach>  
       <set-payload value="Inserted" doc:name="Set Payload"/>  
    </flow>

请记住设计数据库表，其中您的薪水和年龄将在您传递时为字符串

"salary": "$1000",
"age": "26"  

此处为字符串