使用头值作为参数时的Camel-SQL路由ServiceUnavailableException

Question

在ApacheServiceMix7.0.0中，我使用Blueprint定义了以下路由：

 <reference id="dataSource" interface="javax.sql.DataSource" filter="(dataSourceName=connectuserdata)" />

<bean id="sql" class="org.apache.camel.component.sql.SqlComponent">
    <property name="dataSource" ref="dataSource" />
</bean>

<camelContext xmlns="http://camel.apache.org/schema/blueprint">

    <package>com.focuscura</package>

    <dataFormats>
        <!-- here we define a Json data format with the id jack and that it should use the TestPojo as the class type when
             doing unmarshal. The unmarshalTypeName is optional, if not provided Camel will use a Map as the type -->
        <json id="userdata" library="Jackson" />
    </dataFormats>

    <route id="connect.userdata_create">
        <from uri="jetty:http://localhost:8881/userdata?httpMethodRestrict=POST"/>
        <unmarshal ref="userdata"/>
        <!--<process ref="scalaUserDataProcessor"/>-->
        <log message="Received new userdata" />
        <to uri="sql:INSERT INTO public.&quot;UserData&quot; (lastname, firstname) VALUES (:#lastname , :#firstname)"/>
    </route>

    <route id="connect.userdata_get2">
        <from uri="jetty:http://localhost:8881/userdata2?httpMethodRestrict=GET"/>
        <to uri="sql:SELECT * FROM public.&quot;UserData&quot; WHERE id = :#id"/>

        <!--<process ref="scalaUserDataProcessor"/>-->
        <marshal ref="userdata"/>
    </route>
</camelContext>

按照本文所述的说明将数据源安装为独立的服务：如何安装postgresqljdbc以在Karaf OSGi中工作？

这很好用！我可以将JSON发布到Jetty URL并将其插入到数据库中。但是，当我试图从该endpoint获取数据时，我得到以下错误

org.osgi.service.blueprint.container.ServiceUnavailableException: The Blueprint container is being or has been destroyed: (&(dataSourceName=connectuserdata)(objectClass=javax.sql.DataSource))
at org.apache.aries.blueprint.container.ReferenceRecipe.getService(ReferenceRecipe.java:241)
at org.apache.aries.blueprint.container.ReferenceRecipe.access$000(ReferenceRecipe.java:56)
at org.apache.aries.blueprint.container.ReferenceRecipe$ServiceDispatcher.call(ReferenceRecipe.java:306)
at Proxyb6abdd30_6f59_4e89_a419_c4ff0558aa62.equals(Unknown Source)
at java.util.WeakHashMap.eq(WeakHashMap.java:287)
at java.util.WeakHashMap.get(WeakHashMap.java:401)
at org.springframework.jdbc.support.SQLErrorCodesFactory.getErrorCodes(SQLErrorCodesFactory.java:204)
at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.setDataSource(SQLErrorCodeSQLExceptionTranslator.java:140)
at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.

奇怪的是，当我将 替换为 时，它再次运行良好，并且返回了一个用户nr2的小JSON。

对于如何解决这个问题有什么提示吗？

Answer 1

问题不是真的在我的路线或骆驼。它是由PostgreSQL引起的。通过在路由中使用一个参数，我需要提供一个显式的类型转换。

要使其工作，我需要将：：bigint添加到路由中的参数:sql:select lastname FROM public。“userdata”；其中id=:#id::bigint？datasource=datasource&allowNamedParameters=true

由于某种原因，来自Postgres的错误被Camel-sql吞噬了，我得到了关于Datasource被破坏的奇怪消息。