com.wm.app.tn.db
Class DeliveryOperations
java.lang.Object
com.wm.app.tn.db.DeliveryOperations
public class DeliveryOperations
- extends java.lang.Object
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 |
DeliveryOperations
public DeliveryOperations()
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)