Package org.frankframework.scheduler.job

Class ExecuteQueryJob

java.lang.Object

org.frankframework.core.TransactionAttributes

org.frankframework.scheduler.JobDef

org.frankframework.scheduler.job.ExecuteQueryJob

All Implemented Interfaces:

HasTransactionAttribute, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, IJob, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class ExecuteQueryJob
extends JobDef

Field Summary

Fields inherited from class org.frankframework.core.TransactionAttributes

log

Constructor Summary

Constructors

Constructor	Description
ExecuteQueryJob()

Method Summary

Modifier and Type	Method	Description
void	configure()
void	execute()	Actual implementation of the IJob.
String	getDatasourceName()
String	getJmsRealm()
String	getQuery()
int	getQueryTimeout()
void	setDatasourceName(String datasourceName)	JNDI name of datasource to be used
void	setQuery(String query)	The SQL query text to be executed
void	setQueryTimeout(int i)	The number of seconds the database driver will wait for a statement to execute.

Methods inherited from class org.frankframework.scheduler.JobDef

beforeExecuteJob, decrementCountThreads, executeJob, getApplicationContext, getConfigurationClassLoader, getCronExpression, getDescription, getIbisManager, getInterval, getJobDetail, getJobGroup, getLocker, getLogPrefix, getMessageKeeper, getName, getNumThreads, incrementCountThreads, isConfigured, setApplicationContext, setConfigurationMetrics, setCronExpression, setDescription, setInterval, setJobGroup, setLocker, setMessageKeeperSize, setName, setNumThreads, toString

Methods inherited from class org.frankframework.core.TransactionAttributes

configureTransactionAttributes, getTransactionAttribute, getTransactionTimeout, getTxDef, isTransacted, isTransacted, setTransacted, setTransactionAttribute, setTransactionTimeout

Methods inherited from class java.lang.Object

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

Constructor Details

ExecuteQueryJob

public ExecuteQueryJob()

Method Details

configure

public void configure()
               throws ConfigurationException

Specified by:

configure in interface IConfigurable

Overrides:

configure in class JobDef

Throws:

ConfigurationException

execute

public void execute()
             throws JobExecutionException,
TimeoutException

Description copied from interface: IJob

Actual implementation of the IJob. Is wrapped around a Locker and exceptions will be managed automatically.

Throws:

JobExecutionException - when the implementation fails to execute

TimeoutException - when the TransactionTimeout has been reached

setQuery

public void setQuery(String query)

The SQL query text to be executed

setDatasourceName

public void setDatasourceName(String datasourceName)

JNDI name of datasource to be used

Default value

"jdbc.datasource.default"

setQueryTimeout

public void setQueryTimeout(int i)

The number of seconds the database driver will wait for a statement to execute. If the limit is exceeded, a TimeoutException is thrown. 0 means no timeout

Default value

0

getQuery

public String getQuery()

getJmsRealm

public String getJmsRealm()

getDatasourceName

public String getDatasourceName()

getQueryTimeout

public int getQueryTimeout()