如何在mule中使用java映射？

Question

我得到有效载荷在下面的java格式：

[ 
     {emai:'xyz@gmail.com',id:a1}, 
     {emai:'xyz@gmail.com',id:a2}, 
     {emai:'abc@gmail.com',id:a3}, 
     .... 
] 

上述输入i被发送到Java组件，其它需要给输出在下面格式

[ 
     {emai:'xyz@gmail.com',id:[a1,a2]}, 
     {emai:'abc@gmail.com',id:a3}, 
     .... 
] 

即我需要所有的ID结合将电子邮件转换为单个数组。

任何人都可以共享链接来编写java代码吗？或任何示例代码？

谢谢..，

Answer 1

无关，与骡子可能。假设你有一个类Input和Output代表您相应列表元素，你可以这样写：

public static class Output { 
    private String email; 
    private List<String> id; 

    public Output(String email, List<String> id) { 
     this.email = email; 
     this.id = id; 
    } 
    // .. getters 
} 

public static class Input { 
    private String email; 
    private String id; 

    public Input(String email, String id) { 
     this.email = email; 
     this.id = id; 
    } 
    // .. getters 
} 

@Test 
public void test() { 
    List<Input> inputs = Arrays.asList(
      new Input("xyz@gmail.com", "a1"), 
      new Input("xyz@gmail.com", "a2"), 
      new Input("abc@gmail.com", "a3") 
    ); 

    List<Output> results = inputs.stream() 
      .collect(Collectors.groupingBy(Input::getEmail)) 
      .entrySet().stream().map(e-> 
        new Output(e.getKey(), 
          e.getValue().stream().map(Input::getId).collect(Collectors.toList()) 
        ) 
      ).collect(Collectors.toList()); 

    System.out.println(results); 
} 

而且你的输入列表将被转换为所需的格式。我假设你可以想出如何将你发送和接收的任何格式转换为Mule中的POJO。

Answer 2

import org.json.simple.JSONObject; 
import org.json.simple.JSONArray; 
import org.json.simple.parser.ParseException; 
import org.json.simple.parser.JSONParser; 

private final static String s = "[{emai:'xyz@gmail.com',id:a1},{emai:'xyz@gmail.com',id:a2},{emai:'abc@gmail.com',id:a3},....]"; 

public static void main(final String[] argv) throws JSONException { 
Object obj = parser.parse(s); 
JSONArray array = (JSONArray)obj; 
//Turn the payload into a JSONArray 
JSONArray new_arry=new JSONArray(); 
int payload_length = array.length(); 
ArrayList<String> emails = new ArrayList(); 
for(int i=0;i<payload_length;i++){ 
//For every email, use combine to add ids into a JSONArray and attach it to 
//a single email 
String email = array.getJSONObject(i).get("email").toString(); 
//If email has been already considered, skip the check for it 
if(array.contains(email)) 
continue; 
else{ 
emails.add(email); 
JSONArray combine = new JSONArray(); 
for(j=i;j<payload_length;j++){ 
if(array.get(j).get("email").toString()==email) 
combine.put(array.get(j).get("id").toString(); 
    } 
new_array.put(new JSONObject().(email,combine); 
    } 
} 

Answer 3

你可以试试下面的代码dataweave

%dw 1.0 
%output application/java 
--- 
payload groupBy $.emai map { 
    emai : $.emai[0], 
    id : $.id 
} 

希望这有助于。