1

我正在尝试强制 Mule ESB Studio 执行一些简单的插入到 jdbc 中。我的目标是在我的网络浏览器中打开一个页面，假设它是http://localhost:8081/，然后 Mule ESB 将“foobar”值插入数据库。

这是我的代码：

<jdbc-ee:mssql-data-source name="MS_SQL_Data_Source" user="esbtest" password="Test123" transactionIsolation="NONE" doc:name="MS SQL Data Source"  loginTimeout="10000" 
url="jdbc:sqlserver://10.1.212.42:1433;databaseName=test"></jdbc-ee:mssql-data-source>

<jdbc-ee:connector name="Database" dataSource-ref="MS_SQL_Data_Source" validateConnections="true" queryTimeout="-1" pollingFrequency="0" doc:name="Database"/>

<flow name="Test_PierwszyFlow1" doc:name="Test_PierwszyFlow1"> 
    <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" doc:name="HTTP" mimeType="text/plain"></http:inbound-endpoint>
    <object-to-string-transformer doc:name="Object to String"/>
    <jdbc-ee:outbound-endpoint exchange-pattern="one-way"  queryTimeout="-1" doc:name="Database" connector-ref="Database" queryKey="insertQuery">
        <jdbc-ee:query key="insertQuery" value="INSERT INTO t_Login (login) VALUES ('foo bar')"/>
    </jdbc-ee:outbound-endpoint>

</flow>

我没有指定任何豆类或类似的东西。在日志中，我看到这些行：

    INFO  2013-07-02 11:20:37,550 [[test_pierwszy].connector.http.mule.default.receiver.02] org.mule.lifecycle.AbstractLifecycleManager: Initialising: 'Database.dispatcher.1938839184'. Object is: EEJdbcMessageDispatcher
INFO  2013-07-02 11:20:37,550 [[test_pierwszy].connector.http.mule.default.receiver.02] org.mule.lifecycle.AbstractLifecycleManager: Starting: 'Database.dispatcher.1938839184'. Object is: EEJdbcMessageDispatcher
INFO  2013-07-02 11:20:37,670 [[test_pierwszy].connector.http.mule.default.receiver.02] com.mulesoft.mule.transport.jdbc.sqlstrategy.UpdateSqlStatementStrategy: Executing SQL statement: 1 row(s) updated
INFO  2013-07-02 11:20:37,730 [[test_pierwszy].connector.http.mule.default.receiver.02] com.mulesoft.mule.transport.jdbc.sqlstrategy.UpdateSqlStatementStrategy: Executing SQL statement: 1 row(s) updated

...但我的数据库是空的！我必须说，我是 Mule ESB 领域的新手，不知道哪里出了问题。请帮忙。

编辑：有趣的是，当我将 talbe 或列名更改为不存在的东西时，我得到与该问题相对应的 JDBC 错误。

第二个问题是，如何注入我在 URL 中指定的数据库值？例如，当我输入 browserhttp://localhost:8081/foo时，值 foo 被传递给 jdbc 结果连接器，并插入 'foo' 值。

提前致谢。

4

2 回答 2

2

我猜这里有未提交的交易。尝试添加transactionPerMessage="true"到您的<jdbc-ee:connector...

于 2013-07-02T09:54:04.063 回答
0

我在 Mule-EE 中注意到类似的问题，Mule-CE 工作正常......

当您使用 ArrayList 有效负载调用 jdbc:outbound-endpoint 但在 SQL 查询中使用 SESSION/INVOCATION 变量作为参数时，我注意到它对相关表没有影响（无插入/更新），但记录器记录“记录已更新”。将此 jdbc 调用的有效负载更改为其他类型的对象解决了该问题。为了保持开放的心态，请考虑： - 通过有效负载传递 SQL 查询参数 - 考虑消息丰富器

于 2016-02-26T08:37:21.377 回答