使用Camel在運行時配置數據源

Question

我在Apache Camel中設置了一個非常簡單的路由，其中​​查詢發送到JDBC組件執行。我將駱駝項目啓動並運行。 我試圖完成的是發送dataSource1的數據庫連接參數在RabbitMQ消息的標題。通過連接參數，我的意思是driverClassName，url，用戶名，密碼。我的應用程序的客戶端將輸入所有這些參數來決定要連接的數據庫。我可能會根據driverClassName用戶指定的路徑使用路由傳票，但這是另一回事。

請注意，在這個例子中，我把SQL語句放在一個文件中使其更簡單。我怎麼能做到這一點？

這裏是我的駱駝語境：

<?xml version="1.0" encoding="UTF-8"?> 

<beans xmlns="http://www.springframework.org/schema/beans" 
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
     xmlns:camel="http://camel.apache.org/schema/spring" 
     xmlns:jdbc="http://www.springframework.org/schema/jdbc" 
     xsi:schemaLocation=" 
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd 
     http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd"> 

    <camel:camelContext xmlns="http://camel.apache.org/schema/spring"> 
    <camel:route> 
     <camel:from uri="file:src/data?noop=true"/> 
     <camel:to uri="jdbc:dataSource1"/> 
     <camel:convertBodyTo type="java.lang.String"/> 
     <camel:log message="${body}"/> 
    </camel:route> 
    </camel:camelContext> 

    <bean id="dataSource1" 
     class="org.springframework.jdbc.datasource.DriverManagerDataSource"> 
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/> 
    <property name="url" value="jdbc:mysql://localhost:3306/employees"/> 
    <property name="username" value="root"/> 
    <property name="password" value=""/> 
    </bean> 
</beans> 

和Maven項目：

<?xml version="1.0" encoding="UTF-8"?> 
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> 

    <modelVersion>4.0.0</modelVersion> 

    <groupId>group1</groupId> 
    <artifactId>com.mycompany</artifactId> 
    <packaging>jar</packaging> 
    <version>1.0-SNAPSHOT</version> 

    <name>A Camel Spring Route</name> 
    <url>http://www.myorganization.org</url> 

    <properties> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> 
    </properties> 

    <dependencies> 
    <dependency> 
     <groupId>org.apache.camel</groupId> 
     <artifactId>camel-core</artifactId> 
     <version>2.12.2</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.camel</groupId> 
     <artifactId>camel-spring</artifactId> 
     <version>2.12.2</version> 
    </dependency> 

    <!-- logging --> 
    <dependency> 
     <groupId>org.slf4j</groupId> 
     <artifactId>slf4j-api</artifactId> 
     <version>1.7.5</version> 
    </dependency> 
    <dependency> 
     <groupId>org.slf4j</groupId> 
     <artifactId>slf4j-log4j12</artifactId> 
     <version>1.7.5</version> 
    </dependency> 
    <dependency> 
     <groupId>log4j</groupId> 
     <artifactId>log4j</artifactId> 
     <version>1.2.17</version> 
    </dependency> 

    <!-- testing --> 
    <dependency> 
     <groupId>org.apache.camel</groupId> 
     <artifactId>camel-test-spring</artifactId> 
     <version>2.12.2</version> 
     <scope>test</scope> 
    </dependency> 

     <dependency> 
      <groupId>mysql</groupId> 
      <artifactId>mysql-connector-java</artifactId> 
      <version>5.1.26</version> 
     </dependency> 

     <!-- Jdbc --> 
     <dependency> 
      <groupId>org.apache.camel</groupId> 
      <artifactId>camel-jdbc</artifactId> 
      <version>2.12.2</version> 
     </dependency> 

     <dependency> 
      <groupId>org.springframework</groupId> 
      <artifactId>spring-jdbc</artifactId> 
      <version>4.0.0.RELEASE</version> 
     </dependency> 
    </dependencies> 

    <build> 
    <defaultGoal>install</defaultGoal> 

    <plugins> 
     <plugin> 
     <groupId>org.apache.maven.plugins</groupId> 
     <artifactId>maven-compiler-plugin</artifactId> 
     <version>2.5.1</version> 
     <configuration> 
      <source>1.6</source> 
      <target>1.6</target> 
     </configuration> 
     </plugin> 
     <plugin> 
     <groupId>org.apache.maven.plugins</groupId> 
     <artifactId>maven-resources-plugin</artifactId> 
     <version>2.6</version> 
     <configuration> 
      <encoding>UTF-8</encoding> 
     </configuration> 
     </plugin> 

     <!-- allows the route to be ran via 'mvn camel:run' --> 
     <plugin> 
     <groupId>org.apache.camel</groupId> 
     <artifactId>camel-maven-plugin</artifactId> 
     <version>2.12.2</version> 
     </plugin> 
    </plugins> 
    </build> 
</project> 

Answer 1

的數據源是一個Spring bean。創建一個你自己的bean，讓Spring注入數據源。然後，您可以在JDBC步驟之前將plug這些bean加入到您的路由中，並使用包含JMS頭的交換頭來更新數據源的屬性。

不過，我認爲這種設計方法是自找麻煩：

• 如果你想使用一個集中的數據源（你應該），那麼你需要重新連接池這是昂貴的
• 您需要同步（單例）數據源的狀態修改，因爲它在這方面不是線程安全的並且與您在多線程框架中工作的Camel
• 您正在爲您的DB發送用戶名和密碼在這個地方，你應該保護這些信息，當它在運輸

有可能是更多...