在骆驼我怎么可以更新的结果集coloumn的值

我的选择查询在骆驼我怎么可以更新的结果集coloumn的值

sql.selectOrder=select STID,CLLTR from GSI_DEVL.POLLUX_DATA WHERE PROCESSED='FALSE'

我的路线是

<route id="markRowsAsProcessed-Route" > 
     <!-- <from uri="timer://markRowsAsProcessed?delay=5000"/>--> 
     <from uri="sqlComponent:{{sql.selectOrder}}?consumer.useIterator=false" /> 
     <doTry> 
       <to uri="bean:rowProcessController"/> 
      <to uri="sqlComponent:{{sql.markRows}}?batch=true"/> 
      <doCatch> 
       <exception>java.sql.SQLException</exception>  
       <exception>java.lang.IllegalStateException</exception> 
       <exception>java.sql.SQLException</exception> 
       <exception>java.lang.ClassCastException</exception> 
      </doCatch> 
     </doTry>  
    </route>

我bean是

public class RowProcessController { 
    List<Map<String, Object>> stationUnMarkedList = new ArrayList<Map<String, Object>>(); 
    List<Map<String, Object>> stationMarkedList = new ArrayList<Map<String, Object>>(); 
    Map<String,Object> stationMap = null; 

    @SuppressWarnings("unchecked") 
    @Handler 
    public List<Map<String, Object>> markRowAsProcessed(Exchange exchange) 
    { 
     stationUnMarkedList = (List<Map<String, Object>>)exchange.getIn().getBody(); 
     for(Map<String,Object> data: stationMarkedList) { 
      System.out.println(data.get("STID")); 
      stationMap=new HashMap<String,Object>(); 
      stationMap.put("stationId", ((String)data.get("STID"))); 
      stationMap.put("callLetter", ((String)data.get("CLLTR"))); 
      stationMarkedList.add(stationMap); 
     } 
     return stationMarkedList; 
    } 
}

我想要将结果集处理列更新为完成或某个值。

我试图

sql.markRows=UPDATE POLLUX_DATA SET PROCESSED='DONE' where stid=:stationId

但是，这并不在数据库中更新的任何值。为什么不？

来源

2016-01-21 Bibin Mathew

你确定身体有正确的类型？在SQL语句中使用的命名变量必须定义为标题，或者如果其为java.util.Map（请参阅[link]（http://camel.apache.org/sql-component.html）），则定义在标题中。您也可以尝试在交换机上设置header ** stationId **。 – Ewout

如果删除命名查询，同样的问题persist.if我删除选择语句，并尝试直接更新语句，然后它的working.I认为这些combinatins的一些问题。骆驼是有任何限制使用select和update together.I意思是我可以通过bean来处理结果集并更新数据库吗？ –

你可以尝试更改查询的命名参数表示法：＃而不只是：

sql.markRows = UPDATE POLLUX_DATA组处理过的= '完成'，其中STID =＃的stationID

来源

2016-01-21 15:14:10 Sundar

Sundar，Stiil它没有更新。我正在使用：#stationId当我发布这个。我错误地粘贴在这里：stationId。我需要将行标记为已处理 –

在查看您的代码时，我认为问题是一个错字，您尝试遍历bean中的空列表，您正在将列表读入列表stationUnMarkedList，但正在迭代通过stationMarkedList，所以更新查询的主体是一个空的列表。我会建议添加日志，并在处理异常时尝试处理它，不要吞下异常。 – Sundar

在骆驼我怎么可以更新的结果集coloumn的值

回答

相关问题