camel-sql

    0熱度

    1回答

    我已經使用camel-sql編寫的代碼工作正常。現在我必須編寫相同的測試用例。我使用了內存數據庫H2。我已初始化數據庫並將數據源分配給sqlComponent。 // Setup code @Override protected JndiRegistry createRegistry() throws Exception { JndiRegistry jndi =

    0熱度

    1回答

    我使用的是駝峯2.17.0,並且必須使用SQL IN子句執行更新查詢。查詢 update MY_TABLE set STATUS = :#status where ID in (:#in:ids) AND TYPE = :#type 我已經設置的所有參數駱駝頭,參數IDS是一個List <朗>並有我的執行時,在清單四個要素。但我得到一個SQL例外 PreparedStatementCallba

    1熱度

    2回答

    我正在使用apache-camel sql-batch插入。 我對SQL批處理插入路線如下: <pipeline> <transform> <method ref="insertionMyBean" method="myBatchInsertion"></method> </transform> <choice> <when> <

    0熱度

    1回答

    我正在使用Apache Camel使用springboot,所以我的問題是我該如何編寫代碼才能使用Idempotentconsumer和使用apache駱駝的JDBC存儲庫。

    0熱度

    1回答

    我的選擇查詢 sql.selectOrder=select STID,CLLTR from GSI_DEVL.POLLUX_DATA WHERE PROCESSED='FALSE' 我的路線是 <route id="markRowsAsProcessed-Route" > <!-- <from uri="timer://markRowsAsProcessed?delay=5000"

    0熱度

    1回答

    我有一個民意調查豐富,它豐富了POJO與SQL查詢(從MySQL數據庫)的結果。它目前從POJO獲得品牌,然後從與品牌匹配的訂單中獲得名稱。我必須在$ {body.getBrand}周圍添加引號,否則查詢將查找具有品牌名稱的列而不是使用該值。目前,它看起來像這樣: <pollEnrich id="_enrich1" strategyRef="merge" timeout="5000">

    1熱度

    1回答

    我使用Spring Boot來啓動使用Camel-sql查詢MySQL數據庫並調用REST服務的駱駝路由。 application.properties中 db.driver=com.mysql.jdbc.Driver db.url=mysql://IP:PORT/abc db.username=abc db.password=pwd Application.java public st

    1熱度

    1回答

    我是駱駝新手,我嘗試處理SQL數據。如果SQL消耗(選擇)完成,我嘗試更新消費的行,但我只是得到一個「錯誤的SQL語法」異常。 我使用Apache Camel SQL-Component,其中起始端點是一個sql select語句。爲了將它們標記爲已消耗,我使用SQL-Component的onConsume參數。在選擇中,v_table是原始表t_table的視圖,在更新後使用。所以v_table

    0熱度

    1回答

    我是駱駝SQL存儲組件的新手。目前我正在使用駱駝2.17.5。我試圖從駱駝路線調用oracle存儲過程。這是我的路線: <setHeader headerName="test"> <simple>John</simple> </setHeader> <log loggingLevel="INFO" message="value: ${head

    0熱度

    1回答

    我最近加入了一個項目,其中許多autosys作業被駱駝路線替換。大部分處理流遵循相同的模式: 從某個文件夾中讀一文件 應用某種一些反序列化到Java結構 調用基於包括一些值存儲過程或另一個在java structuure 發送的處理結果一些第三方消費 執行存儲過程調用的最簡單方法是使用sql-stored組件。讓我們只說我有這樣的路線: from("file://d:/temp/in/?inclu