nl.nn.adapterframework.mongodb

Class MongoDbSender

java.lang.Object

nl.nn.adapterframework.senders.SenderBase

nl.nn.adapterframework.senders.SenderWithParametersBase

nl.nn.adapterframework.stream.StreamingSenderBase

nl.nn.adapterframework.mongodb.MongoDbSender

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, IOutputStreamingSupport, IStreamingSender, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class MongoDbSender
extends StreamingSenderBase
implements HasPhysicalDestination

Sender to perform action on a MongoDB database.

Author:

Gerrit van Brakel

Specific parameters

database Database to connect to. Overrides attribute database, collection Collection to act upon. Overrides attribute collection, filter Filter. Can contain references to parameters between '?{' and '}'. Overrides attribute filter, limit Limit to number of results returned. A value of 0 means 'no limit'. Overrides attribute limit

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MongoDbSender.MongoAction

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAMED_PARAM_END
static String	NAMED_PARAM_START
static String	PARAM_COLLECTION
static String	PARAM_DATABASE
static String	PARAM_FILTER
static String	PARAM_LIMIT

Fields inherited from class nl.nn.adapterframework.senders.SenderWithParametersBase

parameterNamesMustBeUnique, paramList

Fields inherited from class nl.nn.adapterframework.senders.SenderBase

log

Constructor Summary

Constructors

Constructor and Description
MongoDbSender()

Method Summary

Modifier and Type	Method and Description
protected void	addOptionalValue(ObjectBuilder builder, String name, org.bson.BsonValue bsonValue)
void	close() Stop/close the sender and deallocate resources.
void	configure() configure() is called once at startup of the framework in the configure method of the owner of this sender.
protected com.mongodb.client.MongoCollection<org.bson.Document>	getCollection(com.mongodb.client.MongoDatabase mongoDatabase, ParameterValueList pvl)
protected com.mongodb.client.MongoDatabase	getDatabase(ParameterValueList pvl)
protected org.bson.Document	getDocument(Message message)
protected org.bson.Document	getDocument(String message)
protected List<org.bson.Document>	getDocuments(Message message)
protected org.bson.Document	getFilter(ParameterValueList pvl, Message message)
protected int	getLimit(ParameterValueList pvl)
String	getPhysicalDestinationName()
void	open() This method will be called to start the sender.
MessageOutputStream	provideOutputStream(PipeLineSession session, IForwardTarget next) return a MessageOutputStream that can be used to write a message to, that then will be processed in a streaming way.
protected void	renderResult(com.mongodb.client.result.DeleteResult deleteResult, MessageOutputStream target)
protected void	renderResult(org.bson.Document findResult, MessageOutputStream target)
protected void	renderResult(com.mongodb.client.FindIterable<org.bson.Document> findResults, MessageOutputStream target)
protected void	renderResult(com.mongodb.client.result.InsertManyResult insertManyResult, MessageOutputStream target)
protected void	renderResult(com.mongodb.client.result.InsertOneResult insertOneResult, MessageOutputStream target)
protected void	renderResult(com.mongodb.client.result.UpdateResult updateResult, MessageOutputStream target)
PipeRunResult	sendMessage(Message message, PipeLineSession session, IForwardTarget next)
void	setAction(MongoDbSender.MongoAction action) Action
void	setCollection(String collection) Collection to act upon.
void	setCountOnly(boolean countOnly) Only for find operation: return only the count and not the full document(s)
void	setDatabase(String database) Database to connect to.
void	setDatasourceName(String datasourceName) The MongoDB datasource
void	setFilter(String filter) Filter.
void	setLimit(int limit) Limit to number of results returned.
void	setOutputFormat(DocumentFormat outputFormat) OutputFormat
void	setPrettyPrint(boolean prettyPrint) Format the output in easy legible way (currently only for XML)

Methods inherited from class nl.nn.adapterframework.stream.StreamingSenderBase

canProvideOutputStream, sendMessage, supportsOutputStreamPassThrough

Methods inherited from class nl.nn.adapterframework.senders.SenderWithParametersBase

addParameter, checkStringAttributeOrParameter, consumesSessionVariable, getParameterList, getParameterOverriddenAttributeValue, getParameterOverriddenAttributeValue, getParameterValueList

Methods inherited from class nl.nn.adapterframework.senders.SenderBase

createBean, getLogPrefix, getName, isSynchronous, setApplicationContext, setName

Methods inherited from class java.lang.Object

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

Methods inherited from interface nl.nn.adapterframework.core.HasPhysicalDestination

getDomain

Methods inherited from interface nl.nn.adapterframework.core.ISenderWithParameters

consumesSessionVariable

Methods inherited from interface nl.nn.adapterframework.core.ISender

isSynchronous, sendMessageOrThrow

Methods inherited from interface nl.nn.adapterframework.core.INamedObject

getName, setName

Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface nl.nn.adapterframework.core.IWithParameters

addParameter, getParameterList

Field Detail

PARAM_DATABASE

public static final String PARAM_DATABASE

See Also:

Constant Field Values

PARAM_COLLECTION

public static final String PARAM_COLLECTION

See Also:

Constant Field Values

PARAM_FILTER

public static final String PARAM_FILTER

See Also:

Constant Field Values

PARAM_LIMIT

public static final String PARAM_LIMIT

See Also:

Constant Field Values

NAMED_PARAM_START

public static final String NAMED_PARAM_START

See Also:

Constant Field Values

NAMED_PARAM_END

public static final String NAMED_PARAM_END

See Also:

Constant Field Values

Constructor Detail

MongoDbSender

public MongoDbSender()

Method Detail

configure

public void configure()
               throws ConfigurationException

Description copied from interface: ISender

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

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface ISender

Overrides:

configure in class StreamingSenderBase

Throws:

ConfigurationException

open

public void open()
          throws SenderException

Description copied from interface: ISender

This method will be called to start the sender. After this method is called the sendMessage method may be called. Purpose of this method is to reduce creating connections to databases etc. in the sendMessage() method.

Specified by:

open in interface ISender

Overrides:

open in class SenderBase

Throws:

SenderException

close

public void close()
           throws SenderException

Description copied from interface: ISender

Stop/close the sender and deallocate resources.

Specified by:

close in interface ISender

Overrides:

close in class SenderBase

Throws:

SenderException

provideOutputStream

public MessageOutputStream provideOutputStream(PipeLineSession session,
                                               IForwardTarget next)
                                        throws StreamingException

Description copied from interface: IOutputStreamingSupport

return a MessageOutputStream that can be used to write a message to, that then will be processed in a streaming way. If a target MessageOutputStream is required to stream output to, this can be obtained from next, if specified. If the implementor of this method is a pipe, and it is the last one in the chain of streaming pipes, it must provide the appropriate forward in the provide MessageOutputStream. If the class cannot provide an outputstream, it must return null. If the provider of an outputstream is a pipe itself, it must provide a proper pipeforward in the provided outputstream

Specified by:

provideOutputStream in interface IOutputStreamingSupport

Throws:

StreamingException

sendMessage

public PipeRunResult sendMessage(Message message,
                                 PipeLineSession session,
                                 IForwardTarget next)
                          throws SenderException,
                                 TimeoutException

Specified by:

sendMessage in interface IStreamingSender

Throws:

SenderException

TimeoutException

renderResult

protected void renderResult(com.mongodb.client.result.InsertOneResult insertOneResult,
                            MessageOutputStream target)
                     throws SAXException,
                            StreamingException

Throws:

SAXException

StreamingException

renderResult

protected void renderResult(com.mongodb.client.result.InsertManyResult insertManyResult,
                            MessageOutputStream target)
                     throws SAXException,
                            StreamingException

Throws:

SAXException

StreamingException

renderResult

protected void renderResult(org.bson.Document findResult,
                            MessageOutputStream target)
                     throws StreamingException

Throws:

StreamingException

renderResult

protected void renderResult(com.mongodb.client.FindIterable<org.bson.Document> findResults,
                            MessageOutputStream target)
                     throws StreamingException

Throws:

StreamingException

renderResult

protected void renderResult(com.mongodb.client.result.UpdateResult updateResult,
                            MessageOutputStream target)
                     throws SAXException,
                            StreamingException

Throws:

SAXException

StreamingException

renderResult

protected void renderResult(com.mongodb.client.result.DeleteResult deleteResult,
                            MessageOutputStream target)
                     throws SAXException,
                            StreamingException

Throws:

SAXException

StreamingException

addOptionalValue

protected void addOptionalValue(ObjectBuilder builder,
                                String name,
                                org.bson.BsonValue bsonValue)
                         throws SAXException

Throws:

SAXException

getDocument

protected org.bson.Document getDocument(Message message)
                                 throws IOException

Throws:

IOException

getDocument

protected org.bson.Document getDocument(String message)

getDocuments

protected List<org.bson.Document> getDocuments(Message message)
                                        throws IOException

Throws:

IOException

getDatabase

protected com.mongodb.client.MongoDatabase getDatabase(ParameterValueList pvl)
                                                throws SenderException

Throws:

SenderException

getCollection

protected com.mongodb.client.MongoCollection<org.bson.Document> getCollection(com.mongodb.client.MongoDatabase mongoDatabase,
                                                                              ParameterValueList pvl)
                                                                       throws SenderException

Throws:

SenderException

getFilter

protected org.bson.Document getFilter(ParameterValueList pvl,
                                      Message message)
                               throws IOException,
                                      ParameterException,
                                      IllegalArgumentException

Throws:

IOException

ParameterException

IllegalArgumentException

getLimit

protected int getLimit(ParameterValueList pvl)

getPhysicalDestinationName

public String getPhysicalDestinationName()

Specified by:

getPhysicalDestinationName in interface HasPhysicalDestination

setDatasourceName

public void setDatasourceName(String datasourceName)

The MongoDB datasource

Default value

setDatabase

public void setDatabase(String database)

Database to connect to. Can be overridden by parameter "database"

setCollection

public void setCollection(String collection)

Collection to act upon. Can be overridden by parameter "collection"

setAction

public void setAction(MongoDbSender.MongoAction action)

Action

setFilter

public void setFilter(String filter)

Filter. Can contain references to parameters between "?{" and "}". Can be overridden by parameter "filter"

setLimit

public void setLimit(int limit)

Limit to number of results returned. A value of 0 means 'no limit'. Can be overridden by parameter "limit".

Default value

0

setCountOnly

public void setCountOnly(boolean countOnly)

Only for find operation: return only the count and not the full document(s)

Default value

false

setOutputFormat

public void setOutputFormat(DocumentFormat outputFormat)

OutputFormat

Default value

JSON

setPrettyPrint

public void setPrettyPrint(boolean prettyPrint)

Format the output in easy legible way (currently only for XML)