Package org.frankframework.scheduler.job

Class ExecuteQueryJob

java.lang.Object

org.frankframework.core.TransactionAttributes

org.frankframework.scheduler.AbstractJobDef

org.frankframework.scheduler.job.ExecuteQueryJob

All Implemented Interfaces:

FrankElement, HasApplicationContext, HasName, HasTransactionAttribute, IConfigurable, IScopeProvider, NameAware, ConfigurableLifecycle, IJob, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class ExecuteQueryJob
extends AbstractJobDef

Scheduled job to execute JDBC Queries using a FixedQuerySender.

Field Summary

Fields inherited from class org.frankframework.core.TransactionAttributes

log

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
ExecuteQueryJob()

Method Summary

Modifier and Type	Method	Description
void	configure()	Configure this component.
void	execute()	Is wrapped around a Locker and exceptions will be managed automatically.
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.AbstractJobDef

beforeExecuteJob, decrementCountThreads, executeJob, getIbisManager, getJobDetail, getMessageKeeper, incrementCountThreads, isRunning, setCronExpression, setDescription, setInterval, setJobGroup, setLocker, setMessageKeeperSize, setName, setNumThreads, start, stop, toString

Methods inherited from class org.frankframework.core.TransactionAttributes

configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface org.frankframework.lifecycle.ConfigurableLifecycle

getPhase, isAutoStartup

Methods inherited from interface org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasTransactionAttribute

getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute

Methods inherited from interface org.frankframework.scheduler.job.IJob

getCronExpression, getInterval, getJobGroup, getLocker, getName, isConfigured

Methods inherited from interface org.springframework.context.SmartLifecycle

stop

Constructor Details

ExecuteQueryJob

public ExecuteQueryJob()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IConfigurable

Configure this component.

configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

In the case of a container, this will propagate the configure signal to all components that apply.

Specified by:

configure in interface IConfigurable

Overrides:

configure in class AbstractJobDef

Throws:

ConfigurationException - in case it was not able to configure the component.

execute

public void execute()
             throws JobExecutionException,
TimeoutException

Description copied from class: AbstractJobDef

Is wrapped around a Locker and exceptions will be managed automatically.

Specified by:

execute in class AbstractJobDef

Throws:

JobExecutionException - when the implementation fails to execute

TimeoutException - when the TransactionTimeout has been reached

setQuery

@Mandatory
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