【发布时间】:2013-06-29 14:31:21
【问题描述】:
我正在尝试强制 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 中指定的 DB 值?例如,当我在浏览器中输入http://localhost:8081/foo 时,会将值 foo 传递给 jdbc 结果连接器,并插入 'foo' 值。
提前致谢。
【问题讨论】:
-
查看页面 roytuts.com/mule-jdbc-insert-example/