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