Class AbstractDBUtilities
- java.lang.Object
-
- com.inductiveautomation.ignition.common.script.builtin.AbstractDBUtilities
-
- Direct Known Subclasses:
ClientDBUtilities
public abstract class AbstractDBUtilities extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field 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 Summary
Constructors Constructor Description AbstractDBUtilities()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method 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.protected Dataset
toDataset(java.util.List<? extends DatasourceMeta> list)
static Dataset
toDataSet(DatasetUtilities.PyDataSet pds)
Deprecated.use DatasetUtilities.toDataSet()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()
-
-
-
Field Detail
-
ORACLE_CURSOR
public static final int ORACLE_CURSOR
- See Also:
- Constant Field Values
-
BIT
public static final int BIT
- See Also:
- Constant Field Values
-
TINYINT
public static final int TINYINT
- See Also:
- Constant Field Values
-
SMALLINT
public static final int SMALLINT
- See Also:
- Constant Field Values
-
INTEGER
public static final int INTEGER
- See Also:
- Constant Field Values
-
BIGINT
public static final int BIGINT
- See Also:
- Constant Field Values
-
FLOAT
public static final int FLOAT
- See Also:
- Constant Field Values
-
REAL
public static final int REAL
- See Also:
- Constant Field Values
-
DOUBLE
public static final int DOUBLE
- See Also:
- Constant Field Values
-
NUMERIC
public static final int NUMERIC
- See Also:
- Constant Field Values
-
DECIMAL
public static final int DECIMAL
- See Also:
- Constant Field Values
-
CHAR
public static final int CHAR
- See Also:
- Constant Field Values
-
VARCHAR
public static final int VARCHAR
- See Also:
- Constant Field Values
-
LONGVARCHAR
public static final int LONGVARCHAR
- See Also:
- Constant Field Values
-
DATE
public static final int DATE
- See Also:
- Constant Field Values
-
TIME
public static final int TIME
- See Also:
- Constant Field Values
-
TIMESTAMP
public static final int TIMESTAMP
- See Also:
- Constant Field Values
-
BINARY
public static final int BINARY
- See Also:
- Constant Field Values
-
VARBINARY
public static final int VARBINARY
- See Also:
- Constant Field Values
-
LONGVARBINARY
public static final int LONGVARBINARY
- See Also:
- Constant Field Values
-
NULL
public static final int NULL
- See Also:
- Constant Field Values
-
OTHER
public static final int OTHER
- See Also:
- Constant Field Values
-
JAVA_OBJECT
public static final int JAVA_OBJECT
- See Also:
- Constant Field Values
-
DISTINCT
public static final int DISTINCT
- See Also:
- Constant Field Values
-
STRUCT
public static final int STRUCT
- See Also:
- Constant Field Values
-
ARRAY
public static final int ARRAY
- See Also:
- Constant Field Values
-
BLOB
public static final int BLOB
- See Also:
- Constant Field Values
-
CLOB
public static final int CLOB
- See Also:
- Constant Field Values
-
REF
public static final int REF
- See Also:
- Constant Field Values
-
DATALINK
public static final int DATALINK
- See Also:
- Constant Field Values
-
BOOLEAN
public static final int BOOLEAN
- See Also:
- Constant Field Values
-
ROWID
public static final int ROWID
- See Also:
- Constant Field Values
-
NCHAR
public static final int NCHAR
- See Also:
- Constant Field Values
-
NVARCHAR
public static final int NVARCHAR
- See Also:
- Constant Field Values
-
LONGNVARCHAR
public static final int LONGNVARCHAR
- See Also:
- Constant Field Values
-
NCLOB
public static final int NCLOB
- See Also:
- Constant Field Values
-
SQLXML
public static final int SQLXML
- See Also:
- Constant Field Values
-
READ_COMMITTED
public static final int READ_COMMITTED
- See Also:
- Constant Field Values
-
READ_UNCOMMITTED
public static final int READ_UNCOMMITTED
- See Also:
- Constant Field Values
-
REPEATABLE_READ
public static final int REPEATABLE_READ
- See Also:
- Constant Field Values
-
SERIALIZABLE
public static final int SERIALIZABLE
- See Also:
- Constant Field Values
-
SDF_THREAD_LOCAL
protected static java.lang.ThreadLocal<java.text.SimpleDateFormat> SDF_THREAD_LOCAL
-
-
Method Detail
-
dateFormat
public static java.lang.String dateFormat(java.util.Date date, java.lang.String pattern)
-
getDatasource
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.
-
toPyDataSet
@Deprecated public static DatasetUtilities.PyDataSet toPyDataSet(Dataset dataset)
Deprecated.Use DatasetUtilities.toPyDataSet()For backwards compatibility. @see DatasetUtilities
-
toDataSet
@Deprecated public static Dataset toDataSet(DatasetUtilities.PyDataSet pds)
Deprecated.use DatasetUtilities.toDataSet()For backwards compatibility. @see DatasetUtilities
-
toDataSet
@Deprecated public static Dataset toDataSet(org.python.core.PySequence headers, org.python.core.PySequence pyData)
Deprecated.Use DatasetUtilities.toDataSet()For backwards compatibility. @see DatasetUtilities
-
dataSetToCSV
@Deprecated public static java.lang.String dataSetToCSV(boolean headerRow, Dataset ds)
Deprecated.Use DatasetUtilities.toCSVJava()For backwards compatibility. @see DatasetUtilities
-
runUpdateQuery
public java.lang.Integer runUpdateQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
runUpdateQueryGetKey
@Deprecated public java.lang.Integer runUpdateQueryGetKey(java.lang.String q)
Deprecated.
-
runUpdateQueryGetKey
@Deprecated public java.lang.Integer runUpdateQueryGetKey(java.lang.String q, java.lang.String datasource)
Deprecated.
-
_runUpdateQuery
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
- Throws:
java.lang.Exception
-
runPrepStmt
@Deprecated public java.lang.Integer runPrepStmt(java.lang.String query, java.lang.Object[] args)
Deprecated.
-
runPrepStmt
@Deprecated public java.lang.Integer runPrepStmt(java.lang.String query, java.lang.String datasource, java.lang.Object[] args)
Deprecated.
-
runPrepStmtGetKey
@Deprecated public java.lang.Integer runPrepStmtGetKey(java.lang.String query, java.lang.Object[] args)
Deprecated.
-
runPrepStmtGetKey
@Deprecated public java.lang.Integer runPrepStmtGetKey(java.lang.String query, java.lang.String datasource, java.lang.Object[] args)
Deprecated.
-
runPrepUpdate
public java.lang.Integer runPrepUpdate(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
_runPrepStmt
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
- Throws:
java.lang.Exception
-
runPrepQuery
public DatasetUtilities.PyDataSet runPrepQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
_runPrepQuery
protected abstract Dataset _runPrepQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId, java.lang.Object[] args) throws java.lang.Exception
- Throws:
java.lang.Exception
-
runScalarPrepQuery
public java.lang.Object runScalarPrepQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
runQuery
public DatasetUtilities.PyDataSet runQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
runScalarQuery
public java.lang.Object runScalarQuery(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
error
protected org.python.core.PyException error(java.lang.String function, java.lang.Exception cause, java.lang.String... args)
-
getConnections
public Dataset getConnections()
-
getConnectionInfo
public Dataset getConnectionInfo(java.lang.String name)
-
_runQuery
protected abstract Dataset _runQuery(java.lang.String query, java.lang.String datasource, java.lang.String txId) throws java.lang.Exception
- Throws:
java.lang.Exception
-
_findDatasources
protected abstract java.util.List<? extends DatasourceMeta> _findDatasources()
-
toDataset
protected Dataset toDataset(java.util.List<? extends DatasourceMeta> list)
-
beginTransaction
public java.lang.String beginTransaction(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
commitTransaction
public void commitTransaction(java.lang.String txId) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
rollbackTransaction
public void rollbackTransaction(java.lang.String txId) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
closeTransaction
public void closeTransaction(java.lang.String txId) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
_beginTransaction
protected abstract java.lang.String _beginTransaction(java.lang.String datasource, int isolationLevel, long timeout) throws java.lang.Exception
- Throws:
java.lang.Exception
-
_commitTransaction
protected abstract void _commitTransaction(java.lang.String txId) throws java.lang.Exception
- Throws:
java.lang.Exception
-
_rollbackTransaction
protected abstract void _rollbackTransaction(java.lang.String txId) throws java.lang.Exception
- Throws:
java.lang.Exception
-
_closeTransaction
protected abstract void _closeTransaction(java.lang.String txId) throws java.lang.Exception
- Throws:
java.lang.Exception
-
createSProcCall
public SProcCall createSProcCall(org.python.core.PyObject[] pyArgs, java.lang.String[] keywords)
-
execSProcCall
public void execSProcCall(SProcCall callContext)
-
_call
protected abstract void _call(SProcCall callContext) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-