Apache Camel如何將DB響應轉換爲XML

Question

親愛的社區！ 我沒有在StackOverFlow上找到類似的主題，我描述了序列 我使用ServiceMix（Apache Camel） 對於使用數據的工作，我需要將SQL結果集轉換爲XML。 回答以下

Answer 1

對於轉換數據庫結果到XML我下一步：

數據庫連接的bean：

<bean 
    class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="dataSource"> 
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/> 
    <property name="url" value="jdbc:mysql://localhost:3306/intertest"/> 
    <property name="username" value="test"/> 
    <property name="password" value="pass"/> 
</bean> 

駱駝航線：

豆

<camelContext xmlns="http://camel.apache.org/schema/spring"> 
    <route id="_route1"> 
     <from id="_from1" uri="activemq:dev.input"/> 
     <to id="_to1" uri="sql:SELECT * FROM h4_rs4?dataSource=dataSource"/> 
     <bean id="_bean1" method="transform" ref="myTransform"/> 
     <to id="_to2" uri="activemq:queue:dev.output"/> 
    </route> 
</camelContext> 

守則，轉換數據庫響應XML

try { 
    DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance(); 
    DocumentBuilder docBuilder = docFactory.newDocumentBuilder(); 

    // root elements 
    Document doc = docBuilder.newDocument(); 
    Element rootElement = doc.createElement("DBResult"); 
    doc.appendChild(rootElement); 

    ArrayList rsRowsArray = (ArrayList) body; // Responce 
    Iterator<LinkedHashMap> rsRowsIterator = rsRowsArray.iterator(); 
    while (rsRowsIterator.hasNext()) { 

     Element row = doc.createElement("row"); 
     rootElement.appendChild(row); 

     Attr attr = doc.createAttribute("id"); 
     attr.setValue("1"); 
     row.setAttributeNode(attr); 

     LinkedHashMap rsRow = rsRowsIterator.next(); 
     // LOGGER.info("Полей в строке = " + rsRow.size()); 
     Set fieldsNames = rsRow.keySet(); // Get fields name 
     Iterator<String> fieldsIterator = fieldsNames.iterator(); 
     while (fieldsIterator.hasNext()) { 
      String fieldName = fieldsIterator.next(); 
      Element field = doc.createElement(fieldName); 
      field.appendChild(doc.createTextNode(rsRow.get(fieldName).toString())); 
      row.appendChild(field); 
     } 
    } 
    return doc; 
} catch (ParserConfigurationException pce) { 
    pce.printStackTrace(); 
}