com.wm.app.tn.db
Class BizDocStore

java.lang.Object
  extended by com.wm.app.tn.db.BizDocStore

public class BizDocStore
extends java.lang.Object

Operations on documents in the database.


Field Summary
static int U_D
           
static int U_DS
           
static int U_DSR
           
static int U_DST
           
 
Constructor Summary
BizDocStore()
           
 
Method Summary
static boolean acceptDocument(java.lang.String rec_id, java.lang.String doc_id, boolean err)
          For internal use only
static int archiveDocuments(java.sql.Timestamp thresh)
          For internal use only
static boolean changeRepeatByOne(BizDocEnvelope doc)
          Change the repeat number on a document.
static boolean changeRepeatByOne(java.lang.String doc_id, int repeatNum)
          Change the repeat number on a document.
static boolean changeRepeatByOneForResubmission(BizDocEnvelope doc)
          Change the repeat number on a document.
static boolean changeRepeatByOneForResubmission(java.lang.String doc_id, int repeatNum)
          Change the repeat number on a document.
static boolean changeStatus(BizDocEnvelope doc, java.lang.String sys, java.lang.String usr, java.lang.String dataType)
          Change the status on a document.
static boolean changeStatus(java.lang.String doc_id, java.lang.String sys, java.lang.String usr)
          Change the status on a document.
static boolean changeStatus(java.lang.String doc_id, java.lang.String sys, java.lang.String usr, java.lang.String dbSource)
           
static int checkUnique(int which, java.lang.String internalId, java.lang.String natId, java.lang.String senderId, java.lang.String otherId)
          Check for uniqueness of documents.
static int deleteDocuments(java.lang.String docId, java.lang.String sysStatus, java.lang.String userStatus, java.lang.String docTypeId, boolean delRelated)
          For internal use only
static int deleteDocuments(java.sql.Timestamp thresh)
          For internal use only
static int deleteEvents(EventQuery query)
          Delete events from the table.
static boolean documentExists(java.lang.String docId)
          Check for documents with the supplied webMethods doc ID
static java.util.ArrayList executeQuery(java.lang.String query, java.sql.Timestamp min_ts, java.sql.Timestamp max_ts)
           
static com.wm.data.IData getComments(java.lang.String docId)
          For internal use only
static java.util.Vector getDocInfo(java.lang.String documentId, java.lang.String senderId, java.lang.String receiverId)
          Get webMethods internal document id, system status, user status of documents using the document id, sender id and receiver id Depending on the uniqueness criteria, there is a chance that this could return more than one row.
static BizDocEnvelope getDocument(java.lang.String docId, boolean content)
          Get a BizDoc by ID.
static BizDocEnvelope getDocument(java.lang.String docId, boolean content, java.lang.String archive)
           
static BizDocEnvelope getDocument(java.lang.String docId, boolean content, java.lang.String[] includeParts, java.lang.String[] excludeParts)
          Get a BizDoc by ID.
static BizDocEnvelope getDocument(java.lang.String docId, boolean content, java.lang.String[] includeParts, java.lang.String[] excludeParts, java.lang.String archive)
           
static java.util.ArrayList getDocuments(java.sql.Timestamp min_ts, java.sql.Timestamp max_ts)
           
static java.util.ArrayList getEarlier(java.lang.String query, java.sql.Timestamp ts)
           
static java.util.ArrayList getEarlierDocuments(java.sql.Timestamp ts)
           
static com.wm.data.IData getRelatedDocuments(java.lang.String docId, java.lang.String groupId)
          Look for related documents.
static com.wm.data.IData getRelatedDocuments(java.lang.String docId, java.lang.String groupId, java.lang.String ConvId)
          Deprecated. as of Trading Networks 6.0, replaced by two-arg getRelatedDocuments
static java.util.HashSet<java.lang.String> getRoutingStatusList()
           
static java.lang.String[] getUserStatus()
          For internal use only
static boolean insertContentPart(java.lang.String docId, BizDocContentPart part)
          Insert a BizDocContentPart into the datastore.
static boolean insertDocument(BizDocEnvelope doc, boolean content)
          Insert a BizDoc as new into the datastore.
static void loadRoutingStatus(java.sql.Connection conn, java.lang.String status)
           
static void loadRoutingStatus(java.lang.String status)
           
static void loadUserStatus()
           
static void main(java.lang.String[] args)
           
static java.lang.String[] pollDocuments(java.lang.String rec_id)
          For internal use only
static java.lang.String[] pollDocumentsForUser(java.lang.String username)
           
static com.wm.data.IData queryDocuments(SimpleDocQuery query, boolean agg, int pageSize, int maxRowCount, int queryTimeout, int threshold)
          Get all BizDocs that satisfy a certain set of criteria.
static com.wm.data.IData queryDocuments(SimpleDocQuery query, boolean agg, int pageSize, int maxRowCount, int queryTimeout, int threshold, java.lang.String queryId)
          Get all BizDocs that satisfy a certain set of criteria.
static com.wm.data.IData queryEvents(EventQuery query, int pageSize, int maxRowCount, int queryTimeout, int threshold)
          Get event information.
static com.wm.data.IData queryEvents(EventQuery query, int pageSize, int maxRowCount, int queryTimeout, int threshold, java.lang.String queryId)
          Get event information.
static boolean queueForDelivery(BizDocEnvelope doc)
          For internal use only
static boolean queueForPolling(BizDocEnvelope doc)
          For internal use only
static boolean relateDocuments(BizDocEnvelope from, BizDocEnvelope to, java.lang.String rel)
          Related the two specified documents.
static boolean relateDocuments(java.lang.String from, java.lang.String to, java.lang.String rel)
          Related the two specified documents.
static boolean replaceContentPart(java.lang.String docId, BizDocContentPart part)
          Replace a BizDocContentPart into the datastore.
static BizDocContentPart retrieveContentPart(java.lang.String docId, java.lang.String partName)
          Retrieve a BizDocContentPart from the datastore.
static int updateAttributes(BizDocEnvelope doc)
          Updates user attributes in the database on the supplied bizdoc.
static java.util.ArrayList updateBizDocTimestamp(java.lang.String[] docs, java.lang.String[] crt_ts, java.lang.String[] last_mod)
           
static boolean updateComments(java.lang.String doc_id, java.lang.String comment)
          Update the comments on a document.
static boolean updateConversationID(BizDocEnvelope doc)
          Update Conversation ID in the database on the supplied bizdoc.
static void updateSystemAttributes(BizDocEnvelope doc)
          Updates system attributes in the database on the supplied bizdoc.
static java.util.ArrayList updateTimestamp(java.lang.String[] ids, java.lang.String[] last_mod, java.lang.String query)
           
static java.util.ArrayList updateTimestamp(java.lang.String[] ids, java.lang.String[] crt_time, java.lang.String[] last_mod, java.lang.String query)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

U_D

public static final int U_D
See Also:
Constant Field Values

U_DS

public static final int U_DS
See Also:
Constant Field Values

U_DSR

public static final int U_DSR
See Also:
Constant Field Values

U_DST

public static final int U_DST
See Also:
Constant Field Values
Constructor Detail

BizDocStore

public BizDocStore()
Method Detail

archiveDocuments

public static int archiveDocuments(java.sql.Timestamp thresh)
                            throws DatastoreException
For internal use only

Throws:
DatastoreException

deleteDocuments

public static int deleteDocuments(java.sql.Timestamp thresh)
                           throws DatastoreException
For internal use only

Throws:
DatastoreException

deleteDocuments

public static int deleteDocuments(java.lang.String docId,
                                  java.lang.String sysStatus,
                                  java.lang.String userStatus,
                                  java.lang.String docTypeId,
                                  boolean delRelated)
                           throws DatastoreException
For internal use only

Throws:
DatastoreException

queueForPolling

public static boolean queueForPolling(BizDocEnvelope doc)
                               throws DatastoreException
For internal use only

Throws:
DatastoreException

queueForDelivery

public static boolean queueForDelivery(BizDocEnvelope doc)
                                throws DatastoreException
For internal use only

Throws:
DatastoreException

pollDocuments

public static java.lang.String[] pollDocuments(java.lang.String rec_id)
                                        throws DatastoreException
For internal use only

Throws:
DatastoreException

pollDocumentsForUser

public static java.lang.String[] pollDocumentsForUser(java.lang.String username)
                                               throws DatastoreException
Throws:
DatastoreException

acceptDocument

public static boolean acceptDocument(java.lang.String rec_id,
                                     java.lang.String doc_id,
                                     boolean err)
                              throws DatastoreException
For internal use only

Throws:
DatastoreException

queryEvents

public static com.wm.data.IData queryEvents(EventQuery query,
                                            int pageSize,
                                            int maxRowCount,
                                            int queryTimeout,
                                            int threshold)
                                     throws DatastoreException,
                                            java.io.IOException,
                                            com.wm.app.repo.RepositoryException,
                                            com.wm.app.b2b.server.ServiceException
Get event information.

Parameters:
query - the query to satisfy
pageSize - the number of rows per page; specify -1 to disable paging
maxRowCount - the maximum number of rows to return -- excess rows will be silently dropped. 0 means unlimited
queryTimeout - the maximum number of seconds to wait for the query to return. 0 means unlimited.
threshold - the number of rows to be stored in the session object; this allows you to override the tn.query.threshold parameter in properties.cnf. In a cluster, this should be disabled by setting it to -1. If the value is set to -1, its value from tn.query.threshold parameter in properties.cnf
Returns:
an IData of events satisfying the query (may be empty)
Throws:
DatastoreException - if a database exception prevents getting the query results
java.io.IOException
com.wm.app.repo.RepositoryException
com.wm.app.b2b.server.ServiceException

queryEvents

public static com.wm.data.IData queryEvents(EventQuery query,
                                            int pageSize,
                                            int maxRowCount,
                                            int queryTimeout,
                                            int threshold,
                                            java.lang.String queryId)
                                     throws DatastoreException,
                                            java.io.IOException,
                                            com.wm.app.repo.RepositoryException,
                                            com.wm.app.b2b.server.ServiceException
Get event information.

Parameters:
query - the query to satisfy
pageSize - the number of rows per page; specify -1 to disable paging
maxRowCount - the maximum number of rows to return -- excess rows will be silently dropped. 0 means unlimited
queryTimeout - the maximum number of seconds to wait for the query to return. 0 means unlimited.
threshold - the number of rows to be stored in the session object; this allows you to override the tn.query.threshold parameter in properties.cnf. In a cluster, this should be disabled by setting it to -1. If the value is set to -1, its value from tn.query.threshold parameter in properties.cnf
queryId - specifies the unique identifier to store the paged query results. This is applicable only when the results are paged. If this value is not set, an Id is automatically generated
Returns:
an IData of events satisfying the query (may be empty)
Throws:
DatastoreException - if a database exception prevents getting the query results
java.io.IOException
com.wm.app.repo.RepositoryException
com.wm.app.b2b.server.ServiceException

deleteEvents

public static int deleteEvents(EventQuery query)
                        throws DatastoreException
Delete events from the table.

Parameters:
query - all events satisfying this query will be deleted
Returns:
how many events were deleted
Throws:
DatastoreException - if a database exception prevents the delete

queryDocuments

public static com.wm.data.IData queryDocuments(SimpleDocQuery query,
                                               boolean agg,
                                               int pageSize,
                                               int maxRowCount,
                                               int queryTimeout,
                                               int threshold)
                                        throws DatastoreException,
                                               java.io.IOException,
                                               com.wm.app.repo.RepositoryException,
                                               com.wm.app.b2b.server.ServiceException
Get all BizDocs that satisfy a certain set of criteria.

Parameters:
query - the query to satisfy
agg - should the aggregating version of the query be used?
pageSize - the number of rows per page; specify -1 to disable paging
maxRowCount - the maximum number of rows to return -- excess rows will be silently dropped. 0 means unlimited
queryTimeout - the maximum number of seconds to wait for the query to return. 0 means unlimited.
threshold - the number of rows to be stored in the session object; this allows you to override the tn.query.threshold parameter in properties.cnf. In a cluster, this should be disabled by setting it to -1. If the value is set to -1, its value from tn.query.threshold parameter in properties.cnf
Returns:
an IData of docs satisfying the query (may be empty)
Throws:
DatastoreException - if a database exception prevents getting the query results
java.io.IOException
com.wm.app.repo.RepositoryException
com.wm.app.b2b.server.ServiceException

queryDocuments

public static com.wm.data.IData queryDocuments(SimpleDocQuery query,
                                               boolean agg,
                                               int pageSize,
                                               int maxRowCount,
                                               int queryTimeout,
                                               int threshold,
                                               java.lang.String queryId)
                                        throws DatastoreException,
                                               java.io.IOException,
                                               com.wm.app.repo.RepositoryException,
                                               com.wm.app.b2b.server.ServiceException
Get all BizDocs that satisfy a certain set of criteria.

Parameters:
query - the query to satisfy
agg - should the aggregating version of the query be used?
pageSize - the number of rows per page; specify -1 to disable paging
maxRowCount - the maximum number of rows to return -- excess rows will be silently dropped. 0 means unlimited
queryTimeout - the maximum number of seconds to wait for the query to return. 0 means unlimited.
threshold - the number of rows to be stored in the session object; this allows you to override the tn.query.threshold parameter in properties.cnf. In a cluster, this should be disabled by setting it to -1. If the value is set to -1, its value from tn.query.threshold parameter in properties.cnf
queryId - specifies the unique identifier to store the paged query results. This is applicable only when the results are paged. If this value is not set, an Id is automatically generated
Returns:
an IData of docs satisfying the query (may be empty)
Throws:
DatastoreException - if a database exception prevents getting the query results
java.io.IOException
com.wm.app.repo.RepositoryException
com.wm.app.b2b.server.ServiceException

getDocument

public static BizDocEnvelope getDocument(java.lang.String docId,
                                         boolean content)
                                  throws DatastoreException
Get a BizDoc by ID. This will return a BizDoc from the repository if there's one with the specified ID. The information in the doc is not guaranteed in any way unless the lock key is supplied as well.

Parameters:
docId - the ID of the document to fetch
content - should the content be returned as well?
Returns:
the document in question (null if it doesn't exist)
Throws:
DatastoreException - if a database exception prevents fetching the requested document

getDocument

public static BizDocEnvelope getDocument(java.lang.String docId,
                                         boolean content,
                                         java.lang.String archive)
                                  throws DatastoreException
Throws:
DatastoreException

getDocument

public static BizDocEnvelope getDocument(java.lang.String docId,
                                         boolean content,
                                         java.lang.String[] includeParts,
                                         java.lang.String[] excludeParts)
                                  throws DatastoreException
Get a BizDoc by ID. This will return a BizDoc from the repository if there's one with the specified ID. The information in the doc is not guaranteed in any way unless the lock key is supplied as well.

Parameters:
docId - the ID of the document to fetch
content - should the content be returned as well?
includeParts - the names of the content parts to be retrived (may be null)
excludeParts - the names of the content parts not to be retrived (may be null)
Returns:
the document in question (null if it doesn't exist)
Throws:
DatastoreException - if a database exception prevents fetching the requested document

getDocument

public static BizDocEnvelope getDocument(java.lang.String docId,
                                         boolean content,
                                         java.lang.String[] includeParts,
                                         java.lang.String[] excludeParts,
                                         java.lang.String archive)
                                  throws DatastoreException
Throws:
DatastoreException

checkUnique

public static int checkUnique(int which,
                              java.lang.String internalId,
                              java.lang.String natId,
                              java.lang.String senderId,
                              java.lang.String otherId)
                       throws DatastoreException
Check for uniqueness of documents. Documents can be unique in a variety of different ways:
  1. doc ID only -- for documents with a globally unique identifier
  2. doc ID from sender -- different senders may reuse the same ID
  3. doc ID from sender with receiver -- different senders may reuse the same ID, one sender may reuse the same ID to different receivers
  4. doc ID from sender with doctype -- different senders may reuse the same ID, one sender may reuse the same ID on documents of different types

Parameters:
which - type of uniqueness check to perform
internalId - the internal ID of the bizdoc
natId - the native ID to look for
senderId - the sender ID to look for (may be null)
otherId - the "other" ID to look for (i.e. receiver ID or type ID; may be null)
Returns:
how many documents matched
Throws:
DatastoreException - if some exception prevents the operation

documentExists

public static boolean documentExists(java.lang.String docId)
                              throws DatastoreException
Check for documents with the supplied webMethods doc ID

Parameters:
docId - the document ID to look for
Returns:
is there a document in the database with that ID?
Throws:
DatastoreException - if some exception prevents the operation

getUserStatus

public static java.lang.String[] getUserStatus()
                                        throws DatastoreException
For internal use only

Throws:
DatastoreException

getComments

public static com.wm.data.IData getComments(java.lang.String docId)
                                     throws DatastoreException
For internal use only

Throws:
DatastoreException

insertDocument

public static boolean insertDocument(BizDocEnvelope doc,
                                     boolean content)
                              throws DatastoreException
Insert a BizDoc as new into the datastore. Content is inserted, as well.

Parameters:
doc - the document to insert
content - insert the content of this document into the database if it's available
Returns:
true if the insert succeeded, false otherwise
Throws:
DatastoreException - if a database exception prevents inserting the supplied document

insertContentPart

public static boolean insertContentPart(java.lang.String docId,
                                        BizDocContentPart part)
                                 throws DatastoreException
Insert a BizDocContentPart into the datastore.

Parameters:
docId - the internal ID for this content part
part - the content part to insert
Returns:
true if the insert succeeded, false otherwise
Throws:
DatastoreException - if a database exception prevents inserting the supplied document

replaceContentPart

public static boolean replaceContentPart(java.lang.String docId,
                                         BizDocContentPart part)
                                  throws DatastoreException
Replace a BizDocContentPart into the datastore.

Parameters:
docId - the internal ID for this content part
part - the content part to insert
Returns:
true if the insert succeeded, false otherwise
Throws:
DatastoreException - if a database exception prevents inserting the supplied document

retrieveContentPart

public static BizDocContentPart retrieveContentPart(java.lang.String docId,
                                                    java.lang.String partName)
                                             throws DatastoreException
Retrieve a BizDocContentPart from the datastore.

Parameters:
docId - the internal ID for this content part
partName - the name of content part to retrive
Returns:
BizDocContentPart
Throws:
DatastoreException - if a database exception prevents retrieving the content part

updateAttributes

public static int updateAttributes(BizDocEnvelope doc)
                            throws DatastoreException
Updates user attributes in the database on the supplied bizdoc. This will delete the existing user attributes and rewrite the current set.

Parameters:
doc - the document in question
Returns:
the number of attributes written
Throws:
DatastoreException - if a database exception prevents inserting the supplied document

updateSystemAttributes

public static void updateSystemAttributes(BizDocEnvelope doc)
                                   throws java.lang.Exception
Updates system attributes in the database on the supplied bizdoc. Records details about the update (user, timestamp, old/new values) to the ActivityLog.

Parameters:
doc - the document to be updated
Throws:
DatastoreException - if a database exception prevents inserting the supplied document
java.lang.Exception

updateConversationID

public static boolean updateConversationID(BizDocEnvelope doc)
                                    throws DatastoreException
Update Conversation ID in the database on the supplied bizdoc.

Parameters:
doc - the document in question
Returns:
true if the update succeeded, false otherwise
Throws:
DatastoreException - if a database exception prevents inserting the supplied document

updateComments

public static boolean updateComments(java.lang.String doc_id,
                                     java.lang.String comment)
                              throws DatastoreException
Update the comments on a document.

Parameters:
doc_id - the ID of the document to update comments
comment - the comment to be updated
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

changeStatus

public static boolean changeStatus(BizDocEnvelope doc,
                                   java.lang.String sys,
                                   java.lang.String usr,
                                   java.lang.String dataType)
                            throws DatastoreException
Change the status on a document.

Parameters:
doc - the document to change status on
sys_local - the new system status (null if no change)
usr_local - the new user status (null if no change)
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

changeRepeatByOne

public static boolean changeRepeatByOne(BizDocEnvelope doc)
                                 throws DatastoreException
Change the repeat number on a document.

Parameters:
doc - the document to change repeat number on
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

changeRepeatByOneForResubmission

public static boolean changeRepeatByOneForResubmission(BizDocEnvelope doc)
                                                throws DatastoreException
Change the repeat number on a document.

Parameters:
doc - the document to change repeat number on
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

changeStatus

public static boolean changeStatus(java.lang.String doc_id,
                                   java.lang.String sys,
                                   java.lang.String usr)
                            throws DatastoreException
Change the status on a document.

Parameters:
doc_id - the ID of the document to change status on
sys - the new system status (null if no change)
usr - the new user status (null if no change)
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

changeStatus

public static boolean changeStatus(java.lang.String doc_id,
                                   java.lang.String sys,
                                   java.lang.String usr,
                                   java.lang.String dbSource)
                            throws DatastoreException
Throws:
DatastoreException

changeRepeatByOne

public static boolean changeRepeatByOne(java.lang.String doc_id,
                                        int repeatNum)
                                 throws DatastoreException
Change the repeat number on a document.

Parameters:
doc_id - the ID of the document to change status on
repeatNum - the current value of repeat number
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

changeRepeatByOneForResubmission

public static boolean changeRepeatByOneForResubmission(java.lang.String doc_id,
                                                       int repeatNum)
                                                throws DatastoreException
Change the repeat number on a document.

Parameters:
doc_id - the ID of the document to change status on
repeatNum - the current value of repeat number
Returns:
did the update take place?
Throws:
DatastoreException - if some exception prevents altering the requested document

getDocInfo

public static java.util.Vector getDocInfo(java.lang.String documentId,
                                          java.lang.String senderId,
                                          java.lang.String receiverId)
                                   throws DatastoreException
Get webMethods internal document id, system status, user status of documents using the document id, sender id and receiver id Depending on the uniqueness criteria, there is a chance that this could return more than one row.

Parameters:
documentId - the document id
senderId - the sender's internal id
receiverId - the receiver's internal id
Returns:
a java.util.Vector consisting of IDatas. Each element in this vector will be an instance of com.wm.data.IData and each of IData will have the following 3 columns - String InternalDocId - webMethods internal id of the document - String SystemStatus - system status of the document - String UserStatus - user status of the document
Throws:
DatastoreException

relateDocuments

public static boolean relateDocuments(BizDocEnvelope from,
                                      BizDocEnvelope to,
                                      java.lang.String rel)
                               throws DatastoreException
Related the two specified documents. Relationships are considered non-associative: that is, A relates to B but B may not relate to A in the same way, or at all.

Parameters:
from - the "from" document
to - the "to" document
rel - the nature of the relationship
Returns:
did the update work?
Throws:
DatastoreException

relateDocuments

public static boolean relateDocuments(java.lang.String from,
                                      java.lang.String to,
                                      java.lang.String rel)
                               throws DatastoreException
Related the two specified documents. Relationships are considered non-associative: that is, A relates to B but B may not relate to A in the same way, or at all.

Parameters:
from - the "from" document
to - the "to" document
rel - the nature of the relationship
Returns:
did the update work?
Throws:
DatastoreException

getRelatedDocuments

public static com.wm.data.IData getRelatedDocuments(java.lang.String docId,
                                                    java.lang.String groupId)
                                             throws DatastoreException
Look for related documents. This will return all documents that are related "to" or "from" the specified document, as well as all the documents in the specified group.

Parameters:
docId - the doc ID to search on
groupId - the group ID to search on (optional)
Returns:
an IData containing all the relationships -- the key is the relationship, the value is String[]{ from, to }. (Remember, IDatas can have multiple values per key.) The special keys "$group" contain String[]s of all docIds in the group.
Throws:
DatastoreException

getRelatedDocuments

public static com.wm.data.IData getRelatedDocuments(java.lang.String docId,
                                                    java.lang.String groupId,
                                                    java.lang.String ConvId)
                                             throws DatastoreException
Deprecated. as of Trading Networks 6.0, replaced by two-arg getRelatedDocuments

Throws:
DatastoreException
See Also:
getRelatedDocuments(String docId, String groupId)

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception
Throws:
java.lang.Exception

loadRoutingStatus

public static void loadRoutingStatus(java.lang.String status)

loadRoutingStatus

public static void loadRoutingStatus(java.sql.Connection conn,
                                     java.lang.String status)

getRoutingStatusList

public static java.util.HashSet<java.lang.String> getRoutingStatusList()

loadUserStatus

public static void loadUserStatus()

updateBizDocTimestamp

public static java.util.ArrayList updateBizDocTimestamp(java.lang.String[] docs,
                                                        java.lang.String[] crt_ts,
                                                        java.lang.String[] last_mod)
                                                 throws DatastoreException
Throws:
DatastoreException

executeQuery

public static java.util.ArrayList executeQuery(java.lang.String query,
                                               java.sql.Timestamp min_ts,
                                               java.sql.Timestamp max_ts)

getEarlierDocuments

public static java.util.ArrayList getEarlierDocuments(java.sql.Timestamp ts)
                                               throws DatastoreException
Throws:
DatastoreException

getEarlier

public static java.util.ArrayList getEarlier(java.lang.String query,
                                             java.sql.Timestamp ts)

updateTimestamp

public static java.util.ArrayList updateTimestamp(java.lang.String[] ids,
                                                  java.lang.String[] crt_time,
                                                  java.lang.String[] last_mod,
                                                  java.lang.String query)
                                           throws DatastoreException
Throws:
DatastoreException

updateTimestamp

public static java.util.ArrayList updateTimestamp(java.lang.String[] ids,
                                                  java.lang.String[] last_mod,
                                                  java.lang.String query)
                                           throws DatastoreException
Throws:
DatastoreException

getDocuments

public static java.util.ArrayList getDocuments(java.sql.Timestamp min_ts,
                                               java.sql.Timestamp max_ts)
                                        throws DatastoreException
Throws:
DatastoreException