public abstract class AbstractDBUtilities
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
ARRAY |
static int |
BIGINT |
static int |
BINARY |
static int |
BIT |
static int |
BLOB |
static int |
BOOLEAN |
static int |
CHAR |
static int |
CLOB |
static int |
DATALINK |
static int |
DATE |
static int |
DECIMAL |
static int |
DISTINCT |
static int |
DOUBLE |
static int |
FLOAT |
static int |
INTEGER |
static int |
JAVA_OBJECT |
static int |
LONGNVARCHAR |
static int |
LONGVARBINARY |
static int |
LONGVARCHAR |
static int |
NCHAR |
static int |
NCLOB |
static int |
NULL |
static int |
NUMERIC |
static int |
NVARCHAR |
static int |
ORACLE_CURSOR |
static int |
OTHER |
static int |
READ_COMMITTED |
static int |
READ_UNCOMMITTED |
static int |
REAL |
static int |
REF |
static int |
REPEATABLE_READ |
static int |
ROWID |
protected static java.lang.ThreadLocal<java.text.SimpleDateFormat> |
SDF_THREAD_LOCAL |
static int |
SERIALIZABLE |
static int |
SMALLINT |
static int |
SQLXML |
static int |
STRUCT |
static int |
TIME |
static int |
TIMESTAMP |
static int |
TINYINT |
static int |
VARBINARY |
static int |
VARCHAR |
Constructor and Description |
---|
AbstractDBUtilities() |
Modifier and Type | Method and Description |
---|---|
protected abstract java.lang.String |
_beginTransaction(java.lang.String datasource,
int isolationLevel,
long timeout) |
protected abstract void |
_call(SProcCall callContext) |
protected abstract void |
_closeTransaction(java.lang.String txId) |
protected abstract void |
_commitTransaction(java.lang.String txId) |
protected abstract java.util.List<? extends DatasourceMeta> |
_findDatasources() |
protected abstract void |
_rollbackTransaction(java.lang.String txId) |
protected abstract Dataset |
_runPrepQuery(java.lang.String query,
java.lang.String datasource,
java.lang.String txId,
java.lang.Object[] args) |
protected abstract 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 abstract Dataset |
_runQuery(java.lang.String query,
java.lang.String datasource,
java.lang.String txId) |
protected abstract java.lang.Integer |
_runUpdateQuery(java.lang.String s,
java.lang.String datasource,
java.lang.String txId,
boolean getIds,
boolean skipAudit) |
java.lang.String |
beginTransaction(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
void |
closeTransaction(java.lang.String txId) |
void |
commitTransaction(java.lang.String txId) |
SProcCall |
createSProcCall(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
static java.lang.String |
dataSetToCSV(boolean headerRow,
Dataset ds)
Deprecated.
Use DatasetUtilities.toCSVJava()
|
static java.lang.String |
dateFormat(java.util.Date date,
java.lang.String pattern) |
protected org.python.core.PyException |
error(java.lang.String function,
java.lang.Exception cause,
java.lang.String... args) |
void |
execSProcCall(SProcCall callContext) |
Dataset |
getConnectionInfo(java.lang.String name) |
Dataset |
getConnections() |
protected static java.lang.String |
getDatasource(PyArgumentMap args)
Returns the datasource defined by the "database" parameter, or the default set on the ScriptContext, if
available.
|
void |
rollbackTransaction(java.lang.String txId) |
DatasetUtilities.PyDataSet |
runPrepQuery(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
java.lang.Integer |
runPrepStmt(java.lang.String query,
java.lang.Object[] args)
Deprecated.
|
java.lang.Integer |
runPrepStmt(java.lang.String query,
java.lang.String datasource,
java.lang.Object[] args)
Deprecated.
|
java.lang.Integer |
runPrepStmtGetKey(java.lang.String query,
java.lang.Object[] args)
Deprecated.
|
java.lang.Integer |
runPrepStmtGetKey(java.lang.String query,
java.lang.String datasource,
java.lang.Object[] args)
Deprecated.
|
java.lang.Integer |
runPrepUpdate(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
DatasetUtilities.PyDataSet |
runQuery(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
java.lang.Object |
runScalarPrepQuery(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
java.lang.Object |
runScalarQuery(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
java.lang.Integer |
runUpdateQuery(org.python.core.PyObject[] pyArgs,
java.lang.String[] keywords) |
java.lang.Integer |
runUpdateQueryGetKey(java.lang.String q)
Deprecated.
|
java.lang.Integer |
runUpdateQueryGetKey(java.lang.String q,
java.lang.String datasource)
Deprecated.
|
static Dataset |
toDataSet(DatasetUtilities.PyDataSet pds)
Deprecated.
use DatasetUtilities.toDataSet()
|
protected Dataset |
toDataset(java.util.List<? extends DatasourceMeta> list) |
static Dataset |
toDataSet(org.python.core.PySequence headers,
org.python.core.PySequence pyData)
Deprecated.
Use DatasetUtilities.toDataSet()
|
static DatasetUtilities.PyDataSet |
toPyDataSet(Dataset dataset)
Deprecated.
Use DatasetUtilities.toPyDataSet()
|
public static final int ORACLE_CURSOR
public static final int BIT
public static final int TINYINT
public static final int SMALLINT
public static final int INTEGER
public static final int BIGINT
public static final int FLOAT
public static final int REAL
public static final int DOUBLE
public static final int NUMERIC
public static final int DECIMAL
public static final int CHAR
public static final int VARCHAR
public static final int LONGVARCHAR
public static final int DATE
public static final int TIME
public static final int TIMESTAMP
public static final int BINARY
public static final int VARBINARY
public static final int LONGVARBINARY
public static final int NULL
public static final int OTHER
public static final int JAVA_OBJECT
public static final int DISTINCT
public static final int STRUCT
public static final int ARRAY
public static final int BLOB
public static final int CLOB
public static final int REF
public static final int DATALINK
public static final int BOOLEAN
public static final int ROWID
public static final int NCHAR
public static final int NVARCHAR
public static final int LONGNVARCHAR
public static final int NCLOB
public static final int SQLXML
public static final int READ_COMMITTED
public static final int READ_UNCOMMITTED
public static final int REPEATABLE_READ
public static final int SERIALIZABLE
protected static java.lang.ThreadLocal<java.text.SimpleDateFormat> SDF_THREAD_LOCAL
public static java.lang.String dateFormat(java.util.Date date, java.lang.String pattern)
protected static java.lang.String getDatasource(PyArgumentMap args)
@Deprecated public static DatasetUtilities.PyDataSet toPyDataSet(Dataset dataset)
@Deprecated public static Dataset toDataSet(DatasetUtilities.PyDataSet pds)
@Deprecated public static Dataset toDataSet(org.python.core.PySequence headers, org.python.core.PySequence pyData)
@Deprecated public static java.lang.String dataSetToCSV(boolean headerRow, Dataset ds)
public java.lang.Integer runUpdateQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
@Deprecated public java.lang.Integer runUpdateQueryGetKey(java.lang.String q)
@Deprecated public java.lang.Integer runUpdateQueryGetKey(java.lang.String q, java.lang.String datasource)
protected abstract java.lang.Integer _runUpdateQuery(java.lang.String s, java.lang.String datasource, java.lang.String txId, boolean getIds, boolean skipAudit) throws java.lang.Exception
java.lang.Exception
@Deprecated public java.lang.Integer runPrepStmt(java.lang.String query, java.lang.Object[] args)
@Deprecated public java.lang.Integer runPrepStmt(java.lang.String query, java.lang.String datasource, java.lang.Object[] args)
@Deprecated public java.lang.Integer runPrepStmtGetKey(java.lang.String query, java.lang.Object[] args)
@Deprecated public java.lang.Integer runPrepStmtGetKey(java.lang.String query, java.lang.String datasource, java.lang.Object[] args)
public java.lang.Integer runPrepUpdate(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
protected abstract 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
java.lang.Exception
public DatasetUtilities.PyDataSet runPrepQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
protected abstract Dataset _runPrepQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId, java.lang.Object[] args) throws java.lang.Exception
java.lang.Exception
public java.lang.Object runScalarPrepQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
public DatasetUtilities.PyDataSet runQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
public java.lang.Object runScalarQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
protected org.python.core.PyException error(java.lang.String function, java.lang.Exception cause, java.lang.String... args)
public Dataset getConnections()
public Dataset getConnectionInfo(java.lang.String name)
protected abstract Dataset _runQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId) throws java.lang.Exception
java.lang.Exception
protected abstract java.util.List<? extends DatasourceMeta> _findDatasources()
protected Dataset toDataset(java.util.List<? extends DatasourceMeta> list)
public java.lang.String beginTransaction(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords) throws java.sql.SQLException
java.sql.SQLException
public void commitTransaction(java.lang.String txId) throws java.sql.SQLException
java.sql.SQLException
public void rollbackTransaction(java.lang.String txId) throws java.sql.SQLException
java.sql.SQLException
public void closeTransaction(java.lang.String txId) throws java.sql.SQLException
java.sql.SQLException
protected abstract java.lang.String _beginTransaction(java.lang.String datasource, int isolationLevel, long timeout) throws java.lang.Exception
java.lang.Exception
protected abstract void _commitTransaction(java.lang.String txId) throws java.lang.Exception
java.lang.Exception
protected abstract void _rollbackTransaction(java.lang.String txId) throws java.lang.Exception
java.lang.Exception
protected abstract void _closeTransaction(java.lang.String txId) throws java.lang.Exception
java.lang.Exception
public SProcCall createSProcCall(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
public void execSProcCall(SProcCall callContext)
protected abstract void _call(SProcCall callContext) throws java.lang.Exception
java.lang.Exception