com.wm.app.tn.db
Class DeliveryOperations

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

public class DeliveryOperations
extends java.lang.Object


Constructor Summary
DeliveryOperations()
           
 
Method Summary
static boolean changeJob(java.lang.String server_id, java.lang.Object o, int op)
           
static int changeServer(java.lang.String from, java.lang.String to, boolean includeFailed)
           
static boolean changeService(java.lang.Object o, int op)
           
static boolean checkJob(java.sql.Connection conn, java.lang.String jobId)
           
static int delete(DeliveryJobQuery query)
           
static int delete(DeliveryServiceQuery query)
           
static void getActiveJobs(java.util.Hashtable cache, java.lang.String serverId)
           
static GuaranteedJob getAnyJob(java.lang.String jobId, boolean content)
          Returns the associated job
static int getGroupSize()
           
static int getJobIds(java.util.Vector ids, java.lang.String serverId)
           
static int getOtherJobs(java.util.Hashtable cache, java.lang.String serverId, boolean content)
          Returns all the jobs not associated with the given serverId
static int getPauseLength()
           
static int getServices(java.util.Hashtable cache)
           
static java.lang.String getSql(java.lang.String[] cols)
           
static void main(java.lang.String[] args)
           
static void notifyJobs(BizDocEnvelope doc)
           
static com.wm.data.IData query(DeliveryJobQuery query, int pageSize, int maxR, int qryT, int threshold, java.lang.String queryId)
           
static com.wm.data.IData query(DeliveryServiceQuery query, int pageSize, int maxR, int qryT, int threshold, java.lang.String queryId)
           
static int reassign(java.lang.String from, java.lang.String to)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DeliveryOperations

public DeliveryOperations()
Method Detail

getServices

public static int getServices(java.util.Hashtable cache)
                       throws java.sql.SQLException,
                              DatastoreException
Throws:
java.sql.SQLException
DatastoreException

changeService

public static boolean changeService(java.lang.Object o,
                                    int op)
                             throws java.sql.SQLException,
                                    DatastoreException
Throws:
java.sql.SQLException
DatastoreException

query

public static com.wm.data.IData query(DeliveryServiceQuery query,
                                      int pageSize,
                                      int maxR,
                                      int qryT,
                                      int threshold,
                                      java.lang.String queryId)
                               throws java.sql.SQLException,
                                      java.io.IOException,
                                      com.wm.app.repo.RepositoryException,
                                      com.wm.app.b2b.server.ServiceException
Throws:
java.sql.SQLException
java.io.IOException
com.wm.app.repo.RepositoryException
com.wm.app.b2b.server.ServiceException

delete

public static int delete(DeliveryServiceQuery query)
                  throws java.sql.SQLException
Throws:
java.sql.SQLException

getAnyJob

public static GuaranteedJob getAnyJob(java.lang.String jobId,
                                      boolean content)
                               throws java.sql.SQLException,
                                      java.io.IOException,
                                      DatastoreException
Returns the associated job

Throws:
java.sql.SQLException
java.io.IOException
DatastoreException

getOtherJobs

public static int getOtherJobs(java.util.Hashtable cache,
                               java.lang.String serverId,
                               boolean content)
                        throws java.sql.SQLException,
                               java.io.IOException,
                               DatastoreException
Returns all the jobs not associated with the given serverId

Throws:
java.sql.SQLException
java.io.IOException
DatastoreException

getActiveJobs

public static void getActiveJobs(java.util.Hashtable cache,
                                 java.lang.String serverId)
                          throws java.sql.SQLException,
                                 java.io.IOException,
                                 DatastoreException
Throws:
java.sql.SQLException
java.io.IOException
DatastoreException

getJobIds

public static int getJobIds(java.util.Vector ids,
                            java.lang.String serverId)
                     throws java.sql.SQLException,
                            java.io.IOException,
                            DatastoreException
Throws:
java.sql.SQLException
java.io.IOException
DatastoreException

changeJob

public static boolean changeJob(java.lang.String server_id,
                                java.lang.Object o,
                                int op)
                         throws java.sql.SQLException,
                                java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

query

public static com.wm.data.IData query(DeliveryJobQuery query,
                                      int pageSize,
                                      int maxR,
                                      int qryT,
                                      int threshold,
                                      java.lang.String queryId)
                               throws java.sql.SQLException,
                                      java.io.IOException,
                                      com.wm.app.repo.RepositoryException,
                                      com.wm.app.b2b.server.ServiceException
Throws:
java.sql.SQLException
java.io.IOException
com.wm.app.repo.RepositoryException
com.wm.app.b2b.server.ServiceException

delete

public static int delete(DeliveryJobQuery query)
                  throws EXMLException,
                         java.sql.SQLException
Throws:
EXMLException
java.sql.SQLException

reassign

public static int reassign(java.lang.String from,
                           java.lang.String to)
                    throws java.sql.SQLException,
                           DatastoreException
Throws:
java.sql.SQLException
DatastoreException

changeServer

public static int changeServer(java.lang.String from,
                               java.lang.String to,
                               boolean includeFailed)
                        throws java.sql.SQLException,
                               DatastoreException
Throws:
java.sql.SQLException
DatastoreException

getSql

public static java.lang.String getSql(java.lang.String[] cols)

notifyJobs

public static void notifyJobs(BizDocEnvelope doc)

main

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

getGroupSize

public static int getGroupSize()

getPauseLength

public static int getPauseLength()

checkJob

public static boolean checkJob(java.sql.Connection conn,
                               java.lang.String jobId)