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, toPyDataSet
protected 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.Exception
public 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 AbstractDBUtilities
java.lang.Exception
protected void _commitTransaction(java.lang.String txId) throws java.lang.Exception
_commitTransaction
in class AbstractDBUtilities
java.lang.Exception
protected void _rollbackTransaction(java.lang.String txId) throws java.lang.Exception
_rollbackTransaction
in class AbstractDBUtilities
java.lang.Exception
protected void _closeTransaction(java.lang.String txId) throws java.lang.Exception
_closeTransaction
in class AbstractDBUtilities
java.lang.Exception
protected 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 AbstractDBUtilities
java.lang.Exception
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) throws java.lang.Exception
_runPrepStmt
in class AbstractDBUtilities
java.lang.Exception
protected 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 AbstractDBUtilities
java.lang.Exception
protected Dataset _runQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId) throws java.lang.Exception
_runQuery
in class AbstractDBUtilities
java.lang.Exception
protected java.util.List<? extends DatasourceMeta> _findDatasources()
_findDatasources
in class AbstractDBUtilities
protected void _call(SProcCall call) throws java.lang.Exception
_call
in class AbstractDBUtilities
java.lang.Exception