Using OSGi datasources from inside a Talend Route.
If you are using Talend data sources as a way of managing your database connections from Jobs, you’ll be pleased to know that you can reference these same data sources from Routes with a little additional configuration. This is particularly useful if you wish to use Camel’s SQL component in Talend ESB. Here’s an example of how to reference an OSGi datasource from a Talend Route.
Inspecting the datasource
To do this, first ensure that you have a Talend data source configured in your container. The following screenshot is from the Services tab in my Karaf Web Console. I have defined a datasource bean named
jdbcIntegration, which is registered as an OSGi service with the name
jdbcIntegration (blue box):
This data source can now be used in a Route.
Referencing the data source
In Talend Studio, modify the Route’s Spring configuration. Declare the following namespace in the
<beans> element (the root element):
Add the following text to the end of the
schemaLocation attribute on the root element. This lets Spring know where to find the OSGi schema:
Then, still in the Spring configuration, add the following element to look up your datasource bean.
<osgi:reference id="dsIntegration" interface="javax.sql.DataSource" filter="(osgi.jndi.service.name=jdbcIntegration)" />
The filter option specifies the OSGi service name of the data source bean. Your Spring configuration should look something like this:
Finally, add a cConfig component to the Route canvas, and select
aopalliance-1.0.jar as a new dependency:
When the Route is deployed into Talend Runtime (not run directly in Studio), the Route will look for the data source in the OSGi registry. The data source can then be used with the Camel SQL component, once you’ve added the Spring JDBC dependencies (I’ll cover this in a future article).
You will also see some entries like this in the logs; these indicate that the datasource has been successfully found:
22:12:34,097 | INFO | xtenderThread-11 | al.aop.ServiceDynamicInterceptor 470 | 93 - org.springframework.osgi.core - 1.2.1 | Looking for mandatory OSGi service dependency for bean [myDatasource] matching filter (&(objectClass=javax.sql.DataSource)(osgi.jndi.service.name=jdbcIntegration)) 22:12:34,097 | INFO | xtenderThread-11 | al.aop.ServiceDynamicInterceptor 476 | 93 - org.springframework.osgi.core - 1.2.1 | Found mandatory OSGi service for bean [myDatasource]
Has this post helped you use a Talend data source in a Route? Please post your feedback in the comments.
Leave a Comment
You can use Markdown in your comment. To write code, indent lines by 4 spaces.