KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > daffodilwoods > daffodildb > server > sessionsystem > sessioncondition > InvalidCommittedCondition


1 package com.daffodilwoods.daffodildb.server.sessionsystem.sessioncondition;
2
3 import com.daffodilwoods.database.resource.DException;
4 import com.daffodilwoods.database.general.SystemFields;
5 import com.daffodilwoods.daffodildb.utils.field.FieldBase;
6 import com.daffodilwoods.daffodildb.server.sql99.dql.iterator._Iterator;
7 import com.daffodilwoods.daffodildb.server.sessionsystem.SystemFieldsCharacteristics;
8
9 /**
10  *
11  * <p>Description: condition for getting the invalid records committed by current session </p>
12  * <p>Company: Daffodil Software Ltd.</p>
13  * @version 1.0
14  */
15 public class InvalidCommittedCondition implements _SessionCondition {
16
17 Object JavaDoc[] condition;
18    private static int[] IST = {SystemFields.invalidSessionId ,SystemFields.transactionId } ;
19     public InvalidCommittedCondition(Object JavaDoc presentConditionValues) {
20         condition = new Object JavaDoc[2];
21         condition[0] = presentConditionValues ;
22         condition[1] = SystemFields.maxIntegerValue;
23     }
24
25 /**
26  * Evaluates the condition above.
27  * @param values
28  * @return
29  * @throws DException
30  */
31     public boolean evaluate(_Iterator nonIndexedIterator ) throws DException {
32      Object JavaDoc[] valuesToCompare = (Object JavaDoc[])nonIndexedIterator.getColumnValues(IST);//new int[]{SystemFields.invalidSessionId ,SystemFields.transactionId } ) ;
33 return (StaticConditionHelper.compare(condition[0],valuesToCompare[0]) == 0)
34             && (StaticConditionHelper.compare(condition[1],valuesToCompare[1]) != 0);
35     }
36
37
38     /**
39      * refreshes the condition with new sessionId.
40      * @param values
41      * @throws DException
42      */
43     public void setParameterValues(Object JavaDoc[] values) throws DException {
44         condition[0] = values[0] ;
45     }
46
47     public String JavaDoc toString(){
48         try {
49             return "[ INVALID_COMMITTED_CONDITION => invalidSessionId = "+((FieldBase)condition[0]).getObject()+" and transactionId <> maxIntegerValue ]";
50         }
51         catch (DException ex) {
52             return null;
53         }
54    }
55
56 }
57
Popular Tags