...
- The table below lists all the parameters of Mqtt protocol handler and their description
Parameter Name | Parameter Description ConnectionParameters | |
The list of jdbc properties that are required to create javax.sql.DataSource object for the given database. | Query QueryString | Select query to retrieve records from the database. |
Usage of JDBC protocol handler:
...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
<Query> <Create> <User> <userId>userid123</userId> <password>pwd123</password> </User> </Create> </Query> |
JDBC Result Output Format: The output message of jdbc handler is an xml structure that has fields of database columns which are retrieved using SELECT query.
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
<Result StatusCode="200" Description="Successful.">
<Records>
<Record>
<EMPNO>7839</EMPNO>
<ENAME>King</ENAME>
<JOB>President</JOB>
<MGR/>
<HIREDATE>1981-11-17</HIREDATE>
<SAL>7698</SAL>
<COMM/>
<DEPTNO>10</DEPTNO>
</Record>
<Record>
<EMPNO>7698</EMPNO>
<ENAME>Blake</ENAME>
<JOB>Manager</JOB>
<MGR>7839</MGR>
<HIREDATE>1981-05-01</HIREDATE>
<SAL>7782</SAL>
<COMM/>
<DEPTNO>20</DEPTNO>
</Record>
<Record>
<EMPNO>7782</EMPNO>
<ENAME>Clerk</ENAME>
<JOB>Manager</JOB>
<MGR>7839</MGR>
<HIREDATE>1981-06-09</HIREDATE>
<SAL>7566</SAL>
<COMM/>
<DEPTNO>30</DEPTNO>
</Record>
<Record>
<EMPNO>7566</EMPNO>
<ENAME>Jones</ENAME>
<JOB>Manager</JOB>
<MGR>7839</MGR>
<HIREDATE>1981-04-02</HIREDATE>
<SAL>7839</SAL>
<COMM/>
<DEPTNO>40</DEPTNO>
</Record>
</Records>
</Result> |
...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
<Result StatusCode="502" Description="Exception occured during JDBC Invocation.">
<Error>Error while executing the jdbc query org.h2.jdbc.JdbcSQLException: Connection is broken: "java.net.ConnectException: Connection refused: connect: localhost" [90067-197]
at org.h2.message.DbException.getJdbcSQLException(DbException.java:357)
at org.h2.message.DbException.get(DbException.java:168)
at org.h2.engine.SessionRemote.connectServer(SessionRemote.java:451)
at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:332)
at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:124)
at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:103)
at org.h2.Driver.connect(Driver.java:69)
at org.h2.jdbcx.JdbcDataSource.getJdbcConnection(JdbcDataSource.java:189)
at org.h2.jdbcx.JdbcDataSource.getConnection(JdbcDataSource.java:178)
at com.atomiton.sff.imp.jdbc.QueryExecutor.executeSelectStatment(QueryExecutor.java:80)
at com.atomiton.sff.imp.netty.jdbc.DatabaseInvocationHandler.messageReceived(DatabaseInvocationHandler.java:59)
at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
at org.jboss.netty.handler.execution.ChannelUpstreamEventRunnable.doRun(ChannelUpstreamEventRunnable.java:43)
at org.jboss.netty.handler.execution.ChannelEventRunnable.run(ChannelEventRunnable.java:67)
at org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor$ChildExecutor.run(OrderedMemoryAwareThreadPoolExecutor.java:314)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
at java.net.PlainSocketImpl.connect(Unknown Source)
at java.net.SocksSocketImpl.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at org.h2.util.NetUtils.createSocket(NetUtils.java:103)
at org.h2.util.NetUtils.createSocket(NetUtils.java:83)
at org.h2.engine.SessionRemote.initTransfer(SessionRemote.java:114)
at org.h2.engine.SessionRemote.connectServer(SessionRemote.java:447)
... 17 more
</Error>
</Result>
|
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
<Result StatusCode="200" Description="Successful.">
<Records>
<RowsAffected>1</RowsAffected>
</Records>
</Result>
|
| Page Properties | ||
|---|---|---|
| ||
|