org.milyn.routing.db

Class SQLExecutor

java.lang.Object

org.milyn.routing.db.SQLExecutor

All Implemented Interfaces:

org.milyn.cdr.SmooksResourceConfigurationFactory, org.milyn.delivery.ContentHandler, org.milyn.delivery.dom.DOMElementVisitor, org.milyn.delivery.dom.DOMVisitAfter, org.milyn.delivery.dom.DOMVisitBefore, org.milyn.delivery.dom.DOMVisitor, org.milyn.delivery.ordering.Consumer, org.milyn.delivery.ordering.Producer, org.milyn.delivery.sax.SAXVisitAfter, org.milyn.delivery.sax.SAXVisitBefore, org.milyn.delivery.sax.SAXVisitor, org.milyn.delivery.Visitor

@VisitBeforeIf(condition="parameters.containsKey(\'executeBefore\') && parameters.executeBefore.value == \'true\'")
 @VisitAfterIf(condition="!parameters.containsKey(\'executeBefore\') || parameters.executeBefore.value != \'true\'")
public class SQLExecutor
extends Object
implements org.milyn.cdr.SmooksResourceConfigurationFactory, org.milyn.delivery.sax.SAXVisitBefore, org.milyn.delivery.sax.SAXVisitAfter, org.milyn.delivery.dom.DOMElementVisitor, org.milyn.delivery.ordering.Producer, org.milyn.delivery.ordering.Consumer

SQLExecutor Visitor.

Supports extraction and persistence to a Database.

Author:

tom.fennelly@gmail.com

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SQLExecutor.ResultSetScopeDecoder

Constructor Summary

Constructors

Constructor and Description
SQLExecutor()

Method Summary

Modifier and Type	Method and Description
boolean	consumes(Object object)
org.milyn.cdr.SmooksResourceConfiguration	createConfiguration()
Set<? extends Object>	getProducts()
String	getResultSetName()
void	intitialize()
SQLExecutor	setDatasource(org.milyn.db.AbstractDataSource datasource)
SQLExecutor	setExecuteBefore(boolean executeBefore)
SQLExecutor	setResultSetName(String resultSetName)
SQLExecutor	setResultSetScope(ResultSetScope resultSetScope)
SQLExecutor	setResultSetTTL(long resultSetTTL)
SQLExecutor	setStatement(String statement)
void	visitAfter(Element element, org.milyn.container.ExecutionContext executionContext)
void	visitAfter(org.milyn.delivery.sax.SAXElement saxElement, org.milyn.container.ExecutionContext executionContext)
void	visitBefore(Element element, org.milyn.container.ExecutionContext executionContext)
void	visitBefore(org.milyn.delivery.sax.SAXElement saxElement, org.milyn.container.ExecutionContext executionContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLExecutor

public SQLExecutor()

Method Detail

setDatasource

public SQLExecutor setDatasource(org.milyn.db.AbstractDataSource datasource)

setStatement

public SQLExecutor setStatement(String statement)

setResultSetName

public SQLExecutor setResultSetName(String resultSetName)

getResultSetName

public String getResultSetName()

setResultSetScope

public SQLExecutor setResultSetScope(ResultSetScope resultSetScope)

setResultSetTTL

public SQLExecutor setResultSetTTL(long resultSetTTL)

setExecuteBefore

public SQLExecutor setExecuteBefore(boolean executeBefore)

createConfiguration

public org.milyn.cdr.SmooksResourceConfiguration createConfiguration()

Specified by:

createConfiguration in interface org.milyn.cdr.SmooksResourceConfigurationFactory

intitialize

@Initialize
public void intitialize()
                             throws org.milyn.cdr.SmooksConfigurationException

Throws:

org.milyn.cdr.SmooksConfigurationException

getProducts

public Set<? extends Object> getProducts()

Specified by:

getProducts in interface org.milyn.delivery.ordering.Producer

consumes

public boolean consumes(Object object)

Specified by:

consumes in interface org.milyn.delivery.ordering.Consumer

visitBefore

public void visitBefore(org.milyn.delivery.sax.SAXElement saxElement,
                        org.milyn.container.ExecutionContext executionContext)
                 throws org.milyn.SmooksException,
                        IOException

Specified by:

visitBefore in interface org.milyn.delivery.sax.SAXVisitBefore

Throws:

org.milyn.SmooksException

IOException

visitAfter

public void visitAfter(org.milyn.delivery.sax.SAXElement saxElement,
                       org.milyn.container.ExecutionContext executionContext)
                throws org.milyn.SmooksException,
                       IOException

Specified by:

visitAfter in interface org.milyn.delivery.sax.SAXVisitAfter

Throws:

org.milyn.SmooksException

IOException

visitBefore

public void visitBefore(Element element,
                        org.milyn.container.ExecutionContext executionContext)
                 throws org.milyn.SmooksException

Specified by:

visitBefore in interface org.milyn.delivery.dom.DOMVisitBefore

Throws:

org.milyn.SmooksException

visitAfter

public void visitAfter(Element element,
                       org.milyn.container.ExecutionContext executionContext)
                throws org.milyn.SmooksException

Specified by:

visitAfter in interface org.milyn.delivery.dom.DOMVisitAfter

Throws:

org.milyn.SmooksException