psdi.app.asset.topology.cron

Class SQLRunner

java.lang.Object

psdi.app.asset.topology.cron.SQLRunner

All Implemented Interfaces:

FixedLoggerNames, FixedLoggers

public class SQLRunner
extends java.lang.Object
implements FixedLoggers

Run SQL directly in case the mboset API is not applicable, eg, very large database. Make sure the SQL is safe and presents no conflicts against business logic.

Field Summary

Fields inherited from interface psdi.util.logging.FixedLoggers

APPLOGGER, CRONTASKLOGGER, CRONTASKMGRLOGGER, CRONTASKMGRSQLLOGGER, DBCONNECTIONLOGGER, DDLOGGER, DMLOGGER, EVENTLOGGER, EXCEPTIONLOGGER, MAILLOGGER, MAXIMOLOGGER, MTLOGGER, NULLMBOPOINTER, SECURITY, SENDFAILEDLOGGER, SERVICELOGGER, SQLLOGGER

Fields inherited from interface psdi.util.logging.FixedLoggerNames

appenderPrefix, LOGGERNAME_APP, LOGGERNAME_CRONTASK, LOGGERNAME_CRONTASKMGR, LOGGERNAME_DBCONNECTION, LOGGERNAME_DD, LOGGERNAME_DM, LOGGERNAME_DMPREVIEW, LOGGERNAME_EVENT, LOGGERNAME_EXCEPTION, LOGGERNAME_MAIL, LOGGERNAME_MAXIMO, LOGGERNAME_MT, LOGGERNAME_NULLMBOPOINTER, LOGGERNAME_SECURITY, LOGGERNAME_SENDFAILED, LOGGERNAME_SERVICE, LOGGERNAME_SQL, LOGGERNAME_SQL_CRONTASKMGR, LOGGERNAME_TXN, loggerPrefix

Constructor Summary

Constructors

Constructor and Description
SQLRunner()

Method Summary

Modifier and Type	Method and Description
static long	ensureSequenceIsGreaterThanLargestValue(java.lang.String tablename, java.lang.String fieldName, UserInfo userInfo) This process reads the next sequence value for tableName.columnName and compares it to the current max(tableName.sequenceName).
static int	executeSql(java.lang.String sql, UserInfo userInfo)
static java.lang.Object	executeSqlReturnFirstResult(UserInfo userInfo, java.lang.String sql, java.lang.Object[] args)
static long	nextSequenceValue(UserInfo userInfo, java.lang.String tableName, java.lang.String fieldName) Return the next sequence value for a table.column

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLRunner

public SQLRunner()

Method Detail

executeSql

public static int executeSql(java.lang.String sql,
                             UserInfo userInfo)
                      throws MXException,
                             java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

executeSqlReturnFirstResult

public static java.lang.Object executeSqlReturnFirstResult(UserInfo userInfo,
                                                           java.lang.String sql,
                                                           java.lang.Object[] args)
                                                    throws MXException,
                                                           java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

ensureSequenceIsGreaterThanLargestValue

public static long ensureSequenceIsGreaterThanLargestValue(java.lang.String tablename,
                                                           java.lang.String fieldName,
                                                           UserInfo userInfo)
                                                    throws MXException,
                                                           java.rmi.RemoteException

This process reads the next sequence value for tableName.columnName and compares it to the current max(tableName.sequenceName). If the max() is greater than the current sequence, then we keep generating sequences until we are past the max() value.

Parameters:

tablename -

fieldName -

userInfo -

Returns:

the current value in sequence.

Throws:

MXException

java.rmi.RemoteException

nextSequenceValue

public static long nextSequenceValue(UserInfo userInfo,
                                     java.lang.String tableName,
                                     java.lang.String fieldName)
                              throws java.rmi.RemoteException,
                                     MXException

Return the next sequence value for a table.column

Parameters:

userInfo -

tableName -

fieldName -

Returns:

Throws:

java.rmi.RemoteException

MXException