public class ClientDBUtilities extends AbstractDBUtilities
| Modifier and Type | Field and Description |
|---|---|
protected AbstractClientContext |
context |
ARRAY, BIGINT, BINARY, BIT, BLOB, BOOLEAN, CHAR, CLOB, DATALINK, DATE, DECIMAL, DISTINCT, DOUBLE, FLOAT, INTEGER, JAVA_OBJECT, LONGNVARCHAR, LONGVARBINARY, LONGVARCHAR, NCHAR, NCLOB, NULL, NUMERIC, NVARCHAR, ORACLE_CURSOR, OTHER, READ_COMMITTED, READ_UNCOMMITTED, REAL, REF, REPEATABLE_READ, ROWID, SDF_THREAD_LOCAL, SERIALIZABLE, SMALLINT, SQLXML, STRUCT, TIME, TIMESTAMP, TINYINT, VARBINARY, VARCHAR| Constructor and Description |
|---|
ClientDBUtilities(AbstractClientContext context) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.String |
_beginTransaction(java.lang.String datasource,
int isolationLevel,
long timeout) |
protected void |
_call(SProcCall call)
Calls a stored procedure, so safe for client use without permission check.
|
protected void |
_closeTransaction(java.lang.String txId) |
protected void |
_commitTransaction(java.lang.String txId) |
protected java.util.List<? extends DatasourceMeta> |
_findDatasources() |
protected void |
_rollbackTransaction(java.lang.String txId) |
protected Dataset |
_runPrepQuery(java.lang.String query,
java.lang.String datasource,
java.lang.String txId,
java.lang.Object[] args) |
protected java.lang.Integer |
_runPrepStmt(java.lang.String query,
java.lang.String datasource,
java.lang.String txId,
boolean getIds,
boolean skipAudit,
java.lang.Object[] args) |
protected Dataset |
_runQuery(java.lang.String query,
java.lang.String datasource,
java.lang.String txId) |
protected java.lang.Integer |
_runUpdateQuery(java.lang.String q,
java.lang.String datasource,
java.lang.String txId,
boolean getIds,
boolean skipAudit) |
void |
clearAllNamedQueryCaches()
Clears all named query caches for the current project.
|
void |
clearNamedQueryCache(java.lang.String path)
Clears the cache of the named query specified by the path parameter.
|
Dataset |
getConnectionInfo() |
java.lang.Object |
runNamedQuery(org.python.core.PyObject[] values,
java.lang.String[] keywords)
This invokes the gateway rpc, which only uses the saved query version.
|
beginTransaction, closeTransaction, commitTransaction, createSProcCall, dataSetToCSV, dateFormat, error, execSProcCall, getConnectionInfo, getConnections, getDatasource, rollbackTransaction, runPrepQuery, runPrepStmt, runPrepStmt, runPrepStmtGetKey, runPrepStmtGetKey, runPrepUpdate, runQuery, runScalarPrepQuery, runScalarQuery, runUpdateQuery, runUpdateQueryGetKey, runUpdateQueryGetKey, toDataSet, toDataset, toDataSet, toPyDataSetprotected final AbstractClientContext context
public ClientDBUtilities(AbstractClientContext context)
public Dataset getConnectionInfo()
public java.lang.Object runNamedQuery(org.python.core.PyObject[] values,
java.lang.String[] keywords)
throws java.lang.Exception
GatewayException - If path is invalid or query can't be run.java.lang.Exceptionpublic void clearNamedQueryCache(java.lang.String path)
throws GatewayException
path - The Path to the named query we want to clear the cache of in the current project.
Will use published version. May not be null.GatewayException - if the path is malformed.public void clearAllNamedQueryCaches()
throws GatewayException
GatewayException - if there is an error clearing all the named query caches.protected java.lang.String _beginTransaction(java.lang.String datasource,
int isolationLevel,
long timeout)
throws java.lang.Exception
_beginTransaction in class AbstractDBUtilitiesjava.lang.Exceptionprotected void _commitTransaction(java.lang.String txId)
throws java.lang.Exception
_commitTransaction in class AbstractDBUtilitiesjava.lang.Exceptionprotected void _rollbackTransaction(java.lang.String txId)
throws java.lang.Exception
_rollbackTransaction in class AbstractDBUtilitiesjava.lang.Exceptionprotected void _closeTransaction(java.lang.String txId)
throws java.lang.Exception
_closeTransaction in class AbstractDBUtilitiesjava.lang.Exceptionprotected java.lang.Integer _runUpdateQuery(java.lang.String q,
java.lang.String datasource,
java.lang.String txId,
boolean getIds,
boolean skipAudit)
throws java.lang.Exception
_runUpdateQuery in class AbstractDBUtilitiesjava.lang.Exceptionprotected java.lang.Integer _runPrepStmt(java.lang.String query,
java.lang.String datasource,
java.lang.String txId,
boolean getIds,
boolean skipAudit,
java.lang.Object[] args)
throws java.lang.Exception
_runPrepStmt in class AbstractDBUtilitiesjava.lang.Exceptionprotected Dataset _runPrepQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId, java.lang.Object[] args) throws java.lang.Exception
_runPrepQuery in class AbstractDBUtilitiesjava.lang.Exceptionprotected Dataset _runQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId) throws java.lang.Exception
_runQuery in class AbstractDBUtilitiesjava.lang.Exceptionprotected java.util.List<? extends DatasourceMeta> _findDatasources()
_findDatasources in class AbstractDBUtilitiesprotected void _call(SProcCall call) throws java.lang.Exception
_call in class AbstractDBUtilitiesjava.lang.Exception