Package com.inductiveautomation.ignition.common.script.builtin

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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

Constructor Detail

AbstractDBUtilities

public AbstractDBUtilities()

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