在 Mule JDBC 流中使用两个不同的数据库时遇到问题

Question

我在 Mule 3.2.0 中有两个 JDBC 流，一个使用 MySQL 数据库，另一个使用 SQLServer 数据库。

<mule ...
    <spring:bean id="MySQL-jdbcDataSource"
        class="org.enhydra.jdbc.standard.StandardDataSource" destroy-method="shutdown">
        <spring:property name="driverName"
            value="com.mysql.jdbc.Driver" />
        <spring:property name="url"
            value="jdbc:mysql://host:port/schema" />
    </spring:bean>

    <jdbc:connector name="MySQL-jdbcConnector"
        dataSource-ref="MySQL-jdbcDataSource" pollingFrequency="${MySQL.db.poll}"
        transactionPerMessage="false">
        <jdbc:query key="read" value="${MySQL.db.jdbc_query}" />
    </jdbc:connector>

    <flow name="MySQL-flow">

        <jdbc:inbound-endpoint queryKey="read"
            connector-ref="MySQL-jdbcConnector">
            <jdbc:transaction action="ALWAYS_BEGIN"/>
            <property key="receiveMessageInTransaction" value="true"/>
        </jdbc:inbound-endpoint>

        <vm:outbound-endpoint path="path" connector-ref="first-level">
            <message-properties-transformer scope="outbound">
                <add-message-property key="identifier" value="MySQL"/>
            </message-properties-transformer>
            <vm:transaction action="NONE"/>
        </vm:outbound-endpoint>
    </flow>
</mule>

和

<mule ... 
    <spring:bean id="SQLServer-jdbcDataSource"
        class="org.enhydra.jdbc.standard.StandardDataSource" destroy-method="shutdown">
        <spring:property name="driverName"
            value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />
        <spring:property name="url"
            value="jdbc:sqlserver://host:port;databaseName=schema" />
    </spring:bean>

    <jdbc:connector name="SQLServer-jdbcConnector"
        dataSource-ref="SQLServer-jdbcDataSource" pollingFrequency="${SQLServer.db.poll}"
    transactionPerMessage="false">
        <jdbc:query key="read" value="${SQLServer.db.jdbc_query}" />
    </jdbc:connector>

    <flow name="SQLServer-flow">
        <jdbc:inbound-endpoint queryKey="read"
        connector-ref="SQLServer-jdbcConnector">
            <jdbc:transaction action="ALWAYS_BEGIN"/>
            <property key="receiveMessageInTransaction" value="true"/>
        </jdbc:inbound-endpoint>

       <vm:outbound-endpoint path="${sv.vm.queue.name}" connector-ref="first-level-xform">
           <message-properties-transformer scope="outbound">
                <add-message-property key="${sv.vm.msg.identifier}" value="SQLServer"/>
           </message-properties-transformer>
           <vm:transaction action="NONE"/>
       </vm:outbound-endpoint>
    </flow>
</mule>

当我在 mule-deploy.properties 中部署这些 floes 中的任何一个时，它运行正常。但是当我同时部署这两个流时，它们都不起作用。我没有收到任何错误或异常，但似乎这些流程都没有运行。

有什么想法可能是错的吗？可能与 JDBC 事务有关？

Answer 1

如果您在同一个应用程序中有 2 个不同的流程.. 然后删除：-

<spring:bean id="SQLServer-jdbcDataSource"
        class="org.enhydra.jdbc.standard.StandardDataSource" destroy-method="shutdown">
        <spring:property name="driverName"
            value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />
        <spring:property name="url"
            value="jdbc:sqlserver://host:port;databaseName=schema" />
    </spring:bean>

    <jdbc:connector name="SQLServer-jdbcConnector"
        dataSource-ref="SQLServer-jdbcDataSource" pollingFrequency="${SQLServer.db.poll}"
    transactionPerMessage="false">
        <jdbc:query key="read" value="${SQLServer.db.jdbc_query}" />
    </jdbc:connector>

来自任何流程...由于它被声明为全局...它可以从应用程序中的任何流程中使用..我的意思是..只需从其中一个中删除上面的代码行流程...因为您已经在两个流程中声明了我猜它是重复的，不需要放置在每个流程中...是的，只需提及参考 connector-ref="SQLServer-jdbcConnector" 在骡子流中...例如：-

<jdbc:inbound-endpoint queryKey="read"
        connector-ref="SQLServer-jdbcConnector">