net.bluemind.scheduledjob.persistence

Class ScheduledJobStore

java.lang.Object

net.bluemind.core.jdbc.JdbcAbstractStore

net.bluemind.scheduledjob.persistence.ScheduledJobStore

public class ScheduledJobStore
extends JdbcAbstractStore

Nested Class Summary

Nested classes/interfaces inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

JdbcAbstractStore.Creator<T>, JdbcAbstractStore.DataType, JdbcAbstractStore.EntityPopulator<T>, JdbcAbstractStore.SqlOperation<Res>, JdbcAbstractStore.StatementValues<T>

Field Summary

Fields inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

datasource

Constructor Summary

Constructors

Constructor and Description
ScheduledJobStore(javax.sql.DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
JobExecution	createExecution(JobExecution je)
void	delete(java.util.List<java.lang.Integer> ids)
void	ensureDefaultPlan(java.lang.String domainName, java.lang.String jid)
java.util.Set<LogEntry>	fetchLogEntries(SecurityContext context, int execId)
ListResult<JobExecution>	findExecutions(JobExecutionQuery jeq)
Job	getJobFromId(java.lang.String jobId)
void	loadStatusesAndPlans(SecurityContext context, JobQuery jq, java.util.Collection<Job> ret)
void	storeLogEntries(int jobExececutionId, java.util.Set<LogEntry> entries)
void	updateExecution(JobExecution je)
void	updateJob(Job job)

Methods inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

batchInsert, batchInsert, delete, doOrContinue, doOrFail, getConnection, insert, insert, insert, insert, insertAndReturn, insertWithSerial, inTransaction, lastInsertId, select, select, select, staticInTransaction, unique, unique, unique, unique, update, update, update, update, update

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScheduledJobStore

public ScheduledJobStore(javax.sql.DataSource dataSource)

Method Detail

updateExecution

public void updateExecution(JobExecution je)
                     throws ServerFault

Throws:

ServerFault

createExecution

public JobExecution createExecution(JobExecution je)
                             throws ServerFault

Throws:

ServerFault

delete

public void delete(java.util.List<java.lang.Integer> ids)
            throws ServerFault

Parameters:

je -

Throws:

ServerFault

getJobFromId

public Job getJobFromId(java.lang.String jobId)
                 throws java.sql.SQLException

Parameters:

jobId -

Returns:

Throws:

java.sql.SQLException

ensureDefaultPlan

public void ensureDefaultPlan(java.lang.String domainName,
                              java.lang.String jid)

Parameters:

d -

jid -

findExecutions

public ListResult<JobExecution> findExecutions(JobExecutionQuery jeq)
                                        throws ServerFault

Parameters:

jeq -

Returns:

Throws:

ServerFault

loadStatusesAndPlans

public void loadStatusesAndPlans(SecurityContext context,
                                 JobQuery jq,
                                 java.util.Collection<Job> ret)

Parameters:

context -

jq -

ret -

storeLogEntries

public void storeLogEntries(int jobExececutionId,
                            java.util.Set<LogEntry> entries)
                     throws ServerFault

Parameters:

je -

entries -

Throws:

ServerFault

fetchLogEntries

public java.util.Set<LogEntry> fetchLogEntries(SecurityContext context,
                                               int execId)

Parameters:

context -

execId -

Returns:

updateJob

public void updateJob(Job job)
               throws ServerFault

Parameters:

job -

Throws:

ServerFault