Qorus Integration Engine®  4.1.4.p2_git
com.qoretechnologies.qorus.DbRemoteRawReceive Class Reference
Inheritance diagram for com.qoretechnologies.qorus.DbRemoteRawReceive:
com.qoretechnologies.qorus.DbRemoteReceive org::qore::jni::QoreObjectWrapper

Public Member Methods

 DbRemoteRawReceive (QoreObject obj)
 
 DbRemoteRawReceive (DbRemote remote, String sql, Object[] args, Map< String, Object > options) throws Throwable
 
 DbRemoteRawReceive (DbRemote remote, String sql, Object[] args) throws Throwable
 
 DbRemoteRawReceive (String remote, String datasource, String sql, Object[] args, Map< String, Object > options) throws Throwable
 
 DbRemoteRawReceive (String remote, String datasource, String sql, Object[] args) throws Throwable
 
 DbRemoteRawReceive (QorusSystemRestHelper remote, String datasource, String sql, Object[] args, Map< String, Object > options) throws Throwable
 
 DbRemoteRawReceive (QorusSystemRestHelper remote, String datasource, String sql, Object[] args) throws Throwable
 
- Public Member Methods inherited from com.qoretechnologies.qorus.DbRemoteReceive
 DbRemoteReceive (QoreObject obj)
 
 DbRemoteReceive (DbRemote remote, String stream, String table_name, Map< String, Object > options) throws Throwable
 
 DbRemoteReceive (DbRemote remote, String stream, String table_name, HashMap< String, Object > options) throws Throwable
 
 DbRemoteReceive (DbRemote remote, String stream, String table_name) throws Throwable
 
 DbRemoteReceive (DbRemote remote, String table_name, Map< String, Object > options) throws Throwable
 
 DbRemoteReceive (DbRemote remote, String table_name) throws Throwable
 
 DbRemoteReceive (String remote, String datasource, String stream, String table_name, Map< String, Object > options) throws Throwable
 
 DbRemoteReceive (String remote, String datasource, String stream, String table_name, HashMap< String, Object > options) throws Throwable
 
 DbRemoteReceive (String remote, String datasource, String stream, String table_name) throws Throwable
 
 DbRemoteReceive (String remote, String datasource, String table_name, Map< String, Object > options) throws Throwable
 
 DbRemoteReceive (String remote, String datasource, String table_name, HashMap< String, Object > options) throws Throwable
 
 DbRemoteReceive (String remote, String datasource, String table_name) throws Throwable
 
 DbRemoteReceive (QorusSystemRestHelper remote, String datasource, String stream, String table_name, Map< String, Object > options) throws Throwable
 
 DbRemoteReceive (QorusSystemRestHelper remote, String datasource, String stream, String table_name, HashMap< String, Object > options) throws Throwable
 
 DbRemoteReceive (QorusSystemRestHelper remote, String datasource, String stream, String table_name) throws Throwable
 
 DbRemoteReceive (QorusSystemRestHelper remote, String datasource, String table_name, Map< String, Object > options) throws Throwable
 
 DbRemoteReceive (QorusSystemRestHelper remote, String datasource, String table_name) throws Throwable
 
void openStream (String stream, String table_name, Map< String, Object > options) throws Throwable
 
void openStream (String stream, String table_name) throws Throwable
 
void commit () throws Throwable
 
void rollback (boolean disconnect) throws Throwable
 
void disconnect () throws Throwable
 
void rollback () throws Throwable
 
HashMap< String, ObjectgetData (int timeout_ms) throws Throwable
 
HashMap< String, ObjectgetData () throws Throwable
 
HashMap< String, ObjectgetAllData (int timeout_ms) throws Throwable
 
HashMap< String, ObjectgetAllData () throws Throwable
 
HashMap< String, Object > [] getDataRows (int timeout_ms) throws Throwable
 
HashMap< String, Object > [] getDataRows () throws Throwable
 
HashMap< String, Object > [] getAllDataRows (int timeout_ms) throws Throwable
 
HashMap< String, Object > [] getAllDataRows () throws Throwable
 
StreamConfig config () throws Throwable
 

Detailed Description

Java wrapper for the OMQ::DbRemoteReceive class in Qorus

Constructor & Destructor Documentation

◆ DbRemoteRawReceive() [1/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( QoreObject  obj)
inline

Creates the object as a wrapper for the Qore object

◆ DbRemoteRawReceive() [2/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( DbRemote  remote,
String  sql,
Object []  args,
Map< String, Object options 
) throws Throwable
inline

Constructor taking a DbRemote object for the remote server; assumes the "select" stream

Parameters
remotea DbRemote object
sqlthe SQL for the select statement in the remote DB
argsoptional bind arguments for the SQL statement
optionsoptional Streaming API Constructor Options as follows:
  • "block": data block size; the number of rows to retrieve from the remote database and send in each block
  • "block_queue_size": the number of blocks to queue for receiving before the I/O thread will block (default: 2); the total number of rows that can be queued = block_queue_size * block
  • "timeout": an HTTP socket timeout value in milliseconds; used locally and in the remote for socket I/O and queue operations; default value: 5m
  • "loglevel": a default log level option for logging; see Log Levels for valid value
  • "no_remote_timeout": if True the "timeout" option will not be sent to the remote
  • "select": select options for the source select statement
  • "transaction": start a remote transaction; if this option is not given, the remote transaction status is left unchanged
Note
  • this class always uses the system.sqlutil service stream: "select_raw"
  • a remote transaction is only started in this object's constructor if the transaction option is set, otherwise the remote transaction status is left unchanged
  • the explicit or default timeout value here overrides any socket I/O timeout set for the remote connection object

◆ DbRemoteRawReceive() [3/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( DbRemote  remote,
String  sql,
Object []  args 
) throws Throwable
inline

Constructor taking a DbRemote object for the remote server; assumes the "select" stream

Parameters
remotea DbRemote object
Note
this class always uses the system.sqlutil service stream: "select_raw"

◆ DbRemoteRawReceive() [4/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( String  remote,
String  datasource,
String  sql,
Object []  args,
Map< String, Object options 
) throws Throwable
inline

Constructor taking a string giving the name of the remote connection for the remote server; assumes the "select" stream

Parameters
remotethe name of the remote connection for the remote server
datasourcea string with name of the remote datasource to use
sqlthe SQL for the select statement in the remote DB
argsoptional bind arguments for the SQL statement
optionsoptional Streaming API Constructor Options as follows:
  • "block": data block size; the number of rows to retrieve from the remote database and send in each block
  • "block_queue_size": the number of blocks to queue for receiving before the I/O thread will block (default: 2); the total number of rows that can be queued = block_queue_size * block
  • "timeout": an HTTP socket timeout value in milliseconds; used locally and in the remote for socket I/O and queue operations; default value: 5m
  • "loglevel": a default log level option for logging; see Log Levels for valid value
  • "no_remote_timeout": if True the "timeout" option will not be sent to the remote
  • "select": select options for the source select statement
  • "transaction": start a remote transaction; if this option is not given, the remote transaction status is left unchanged
Note
  • this class always uses the system.sqlutil service stream: "select_raw"
  • a remote transaction is only started in this object's constructor if the transaction option is set, otherwise the remote transaction status is left unchanged
  • the explicit or default timeout value here overrides any socket I/O timeout set for the remote connection object

◆ DbRemoteRawReceive() [5/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( String  remote,
String  datasource,
String  sql,
Object []  args 
) throws Throwable
inline

Constructor taking a string giving the name of the remote connection for the remote server; assumes the "select" stream

Parameters
remotethe name of the remote connection for the remote server
datasourcea string with name of the remote datasource to use
sqlthe SQL for the select statement in the remote DB
argsoptional bind arguments for the SQL statement
Note
this class always uses the system.sqlutil service stream: "select_raw"

◆ DbRemoteRawReceive() [6/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( QorusSystemRestHelper  remote,
String  datasource,
String  sql,
Object []  args,
Map< String, Object options 
) throws Throwable
inline

Constructor taking a com.qoretechnologies.qorus.QorusSystemRestHelper object for the remote server; assumes the "select" stream

Parameters
remotea com.qoretechnologies.qorus.QorusSystemRestHelper object
datasourcea string with name of the remote datasource to use
sqlthe SQL for the select statement in the remote DB
argsoptional bind arguments for the SQL statement
optionsoptional Streaming API Constructor Options as follows:
  • "block": data block size; the number of rows to retrieve from the remote database and send in each block
  • "block_queue_size": the number of blocks to queue for receiving before the I/O thread will block (default: 2); the total number of rows that can be queued = block_queue_size * block
  • "timeout": an HTTP socket timeout value in milliseconds; used locally and in the remote for socket I/O and queue operations; default value: 5m
  • "loglevel": a default log level option for logging; see Log Levels for valid value
  • "no_remote_timeout": if True the "timeout" option will not be sent to the remote
  • "select": select options for the source select statement
  • "transaction": start a remote transaction; if this option is not given, the remote transaction status is left unchanged
Note
  • this class always uses the system.sqlutil service stream: "select_raw"
  • a remote transaction is only started in this object's constructor if the transaction option is set, otherwise the remote transaction status is left unchanged
  • the explicit or default timeout value here overrides any socket I/O timeout set for the remote connection object

◆ DbRemoteRawReceive() [7/7]

com.qoretechnologies.qorus.DbRemoteRawReceive.DbRemoteRawReceive ( QorusSystemRestHelper  remote,
String  datasource,
String  sql,
Object []  args 
) throws Throwable
inline

Constructor taking a com.qoretechnologies.qorus.QorusSystemRestHelper object for the remote server; assumes the "select" stream

Parameters
remotea com.qoretechnologies.qorus.QorusSystemRestHelper object
datasourcea string with name of the remote datasource to use
sqlthe SQL for the select statement in the remote DB
argsoptional bind arguments for the SQL statement
Note
this class always uses the system.sqlutil service stream: "select_raw"

The documentation for this class was generated from the following file: