com.wm.app.tn.db
Class DeliveryOperations

java.lang.Object
  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)