Qorus Integration Engine®
4.0.3.p2_git
|
Java wrapper for the OMQ::DbRemoteSend class in Qorus. More...
Public Member Methods | |
DbRemoteSend (QoreObject obj) | |
creates the object as a wrapper for the Qore object | |
DbRemoteSend (DbRemote remote, String stream, String table_name, HashMap< String, Object > options) throws Throwable | |
constructor taking a DbRemote object for the remote server More... | |
DbRemoteSend (DbRemote remote, String stream, String table_name) throws Throwable | |
constructor taking a DbRemote object for the remote server More... | |
DbRemoteSend (String remote, String datasource, String stream, String table_name, HashMap< String, Object > options) throws Throwable | |
constructor taking a string giving the name of the remote connection for the remote server More... | |
DbRemoteSend (String remote, String datasource, String stream, String table_name) throws Throwable | |
constructor taking a string giving the name of the remote connection for the remote server More... | |
DbRemoteSend (QorusSystemRestHelper remote, String datasource, String stream, String table_name, HashMap< String, Object > options) throws Throwable | |
constructor taking a com.qoretechnologies.qorus.QorusSystemRestHelper object for the remote server More... | |
DbRemoteSend (QorusSystemRestHelper remote, String datasource, String stream, String table_name) throws Throwable | |
constructor taking a com.qoretechnologies.qorus.QorusSystemRestHelper object for the remote server More... | |
void | openStream (String stream, String table_name, HashMap< String, Object > options) throws Throwable |
flushes the current stream and reopens a new stream with the same remote connection and in the same datasources More... | |
void | openStream (String stream, String table_name) throws Throwable |
flushes the current stream and reopens a new stream with the same remote connection and in the same datasources More... | |
void | commit () throws Throwable |
Commit the remote transaction. It also sends any pending data in the data queue before the commit. | |
void | rollback (boolean disconnect) throws Throwable |
Rollback remote transaction. More... | |
void | rollback () throws Throwable |
Rollback remote transaction and disconnect the connection. More... | |
void | append (HashMap< String, Object >[] data) throws Throwable |
Append data to the ready queue: list. More... | |
void | append (HashMap< String, Object > data) throws Throwable |
Append data to the ready queue: hash. More... | |
StreamConfig | config () throws Throwable |
returns the configuration object | |
Java wrapper for the OMQ::DbRemoteSend class in Qorus.
|
inline |
constructor taking a DbRemote object for the remote server
remote | a DbRemote object |
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
options | optional Streaming API Constructor Options as follows:
|
|
inline |
constructor taking a DbRemote object for the remote server
remote | a DbRemote object |
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
|
inline |
constructor taking a string giving the name of the remote connection for the remote server
remote | the name of the remote connection for the remote server |
datasource | a string with name of the remote datasource to use |
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
options | optional Streaming API Constructor Options as follows:
|
|
inline |
constructor taking a string giving the name of the remote connection for the remote server
remote | the name of the remote connection for the remote server |
datasource | a string with name of the remote datasource to use |
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
|
inline |
constructor taking a com.qoretechnologies.qorus.QorusSystemRestHelper object for the remote server
remote | a com.qoretechnologies.qorus.QorusSystemRestHelper object |
datasource | a string with name of the remote datasource to use |
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
options | optional Streaming API Constructor Options as follows:
|
|
inline |
constructor taking a com.qoretechnologies.qorus.QorusSystemRestHelper object for the remote server
remote | a com.qoretechnologies.qorus.QorusSystemRestHelper object |
datasource | a string with name of the remote datasource to use |
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
|
inline |
Append data to the ready queue: list.
data | a list with row data to be added. It should follow the expected target format (list of hashes, each list element represents a row and each has the row data). |
Data are sent whenever their count reaches the block
size.
The DB transaction is left open.
|
inline |
Append data to the ready queue: hash.
data | a hash with data to be added; can be a single row or multiple rows in column format |
Data are sent whenever the row count reaches the block
size.
The DB transaction is left open.
|
inline |
flushes the current stream and reopens a new stream with the same remote connection and in the same datasources
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
options | optional Streaming API Constructor Options as follows:
|
|
inline |
flushes the current stream and reopens a new stream with the same remote connection and in the same datasources
stream | the system.sqlutil service stream to be used |
table_name | a string with remote table name located in the remote datasource |
|
inline |
Rollback remote transaction.
disconnect | a boolean value to keep connection open or close the connection. Connection closing is the default |
|
inline |
Rollback remote transaction and disconnect the connection.