edu.indiana.dde.mylead.dai
Class MyLeadDeleteReplicaImpl

java.lang.Object
  extended by uk.org.ogsadai.engine.Activity
      extended by uk.org.ogsadai.activity.sql.SQLActivity
          extended by edu.indiana.dde.mylead.dai.MyLeadActivity
              extended by edu.indiana.dde.mylead.dai.MyLeadDeleteReplicaImpl

public class MyLeadDeleteReplicaImpl
extends MyLeadActivity

Handles myleadDeleteReplica Elements from a Grid Data Service Document.


Nested Class Summary
 
Nested classes/interfaces inherited from class uk.org.ogsadai.activity.sql.SQLActivity
uk.org.ogsadai.activity.sql.SQLActivity.ParameterInput, uk.org.ogsadai.activity.sql.SQLActivity.StreamInput, uk.org.ogsadai.activity.sql.SQLActivity.ValueInput
 
Field Summary
protected static java.lang.String CREATOR_DN
           
protected static java.lang.String NICKNAME
           
protected static java.lang.String NICKNAME_COL
           
protected static java.lang.String REPLICA_ID_COL
           
protected static java.lang.String REPLICA_TBL
           
protected  org.w3c.dom.NodeList replicaList
           
 
Fields inherited from class edu.indiana.dde.mylead.dai.MyLeadActivity
AUTHORITY_ADDATTR, AUTHORITY_CREATE, AUTHORITY_DEL_REPLICA, AUTHORITY_DEL_USER, AUTHORITY_DELETEATTR, AUTHORITY_UPDATE, mActivityName, mDn, mTimingPnt, MYLEAD_DB, MYLEAD_WRITER_REPLICA, MYLEAD_WRITER_TBL, startTime
 
Fields inherited from class uk.org.ogsadai.activity.sql.SQLActivity
CREATE_DATABASE, DROP_DATABASE, EXPRESSION, mAllInput, mConnection, mConnectionManager, mCredentials, mExpression, mExpressionInput, mInputStreams, mIsTransaction, mNameToInput, mOpenConnection, mOutput, mStatement, RESULT_STREAM, SQL_PARAMETERS, STORED_PROCEDURE, WEB_ROW_SET_STREAM
 
Fields inherited from class uk.org.ogsadai.engine.Activity
mContext, mExternalInputs, mExternalOutputs, mInternalInputs, mInternalOutputs
 
Constructor Summary
MyLeadDeleteReplicaImpl(org.w3c.dom.Element element)
          Constructor
 
Method Summary
protected  boolean getResult()
          This method is called by processBlock, and it processes each nickname listed in the perform document .
 void processBlock()
          This method will return the output on the outputStream.
 
Methods inherited from class edu.indiana.dde.mylead.dai.MyLeadActivity
checkAuthorization, dumpLog, endProcessing, finalize, getObjectId, getParameter, getWhiteboardId, markTime, queryTimestamp, startProcessing
 
Methods inherited from class uk.org.ogsadai.activity.sql.SQLActivity
initialise, loadNextExpression, parseCommand, parseResultStream, parseSQLParameters, prepareStatement, setupInputStreamNames
 
Methods inherited from class uk.org.ogsadai.engine.Activity
cleanUp, connectsTo, getActivityConfiguration, getName, getObservableStatus, getProperties, getStatus, hasActivityConfiguration, hasProperties, processFirst, setCompleted, setError
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

CREATOR_DN

protected static final java.lang.String CREATOR_DN
See Also:
Constant Field Values

NICKNAME

protected static final java.lang.String NICKNAME
See Also:
Constant Field Values

REPLICA_TBL

protected static final java.lang.String REPLICA_TBL
See Also:
Constant Field Values

NICKNAME_COL

protected static final java.lang.String NICKNAME_COL
See Also:
Constant Field Values

REPLICA_ID_COL

protected static final java.lang.String REPLICA_ID_COL
See Also:
Constant Field Values

replicaList

protected org.w3c.dom.NodeList replicaList
Constructor Detail

MyLeadDeleteReplicaImpl

public MyLeadDeleteReplicaImpl(org.w3c.dom.Element element)
                        throws uk.org.ogsadai.common.exception.engine.activity.ActivityUserException,
                               uk.org.ogsadai.common.exception.engine.activity.ActivitySystemException
Constructor

Parameters:
element - Element containing Statement conforming to schema for this activity. It is assumed schema checks have been carried out.
Throws:
uk.org.ogsadai.common.exception.engine.activity.ActivitySystemException - If there is a problem constructing the activity due to an implementation error or OGSA-DAI confguration problem.
uk.org.ogsadai.common.exception.engine.activity.ActivityUserException - If there is a problem constructing the activity due to a user mistake such as an invalid setting.
Method Detail

getResult

protected boolean getResult()
                     throws java.sql.SQLException,
                            uk.org.ogsadai.common.exception.engine.activity.ActivitySystemException,
                            uk.org.ogsadai.common.exception.engine.activity.ActivityUserException
This method is called by processBlock, and it processes each nickname listed in the perform document . It returns either true or false to processBlock. The getResult method must return a boolean value even though it's not used by processBlock in this case. The reason is that getResult is a method in the underlying SQLActivity method.

Overrides:
getResult in class uk.org.ogsadai.activity.sql.SQLActivity
Returns:
boolean indicating if getResult was successful.
Throws:
java.sql.SQLException
uk.org.ogsadai.common.exception.engine.activity.ActivitySystemException
uk.org.ogsadai.common.exception.engine.activity.ActivityUserException

processBlock

public void processBlock()
This method will return the output on the outputStream. After the MyLeadDeleteReplicaImpl instance has been constructed, all of the parameters have been parsed from the input perform document. OGSA-DAI will then call processBlock(). When this method is called, if there is not a connection, a connection will be acquired (or processing is complete). If a connection is established (either new or already existing) then getResult() will be called. The getResult() method will put the output to mOutput. Compared to other activities which may process in blocks, this activity always writes it result out as a single block since only the status ir returned. No Exceptions are thrown since they will be flagged as a status flag with the activity and the output stream will be closed On error endProcessing is called and the ERROR status is set.

Specified by:
processBlock in class uk.org.ogsadai.engine.Activity