nl.nn.adapterframework.jdbc

Class JdbcQuerySenderBase<H>

java.lang.Object

nl.nn.adapterframework.jndi.JndiBase

nl.nn.adapterframework.jdbc.JdbcFacade

nl.nn.adapterframework.jdbc.JdbcSenderBase<H>

nl.nn.adapterframework.jdbc.JdbcQuerySenderBase<H>

All Implemented Interfaces:

HasPhysicalDestination, IBlockEnabledSender<H>, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, IXAEnabled, HasStatistics, IOutputStreamingSupport, IStreamingSender, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

DirectQuerySender, FixedQuerySender

@SupportsOutputStreaming
public abstract class JdbcQuerySenderBase<H>
extends JdbcSenderBase<H>

This executes the query that is obtained from the (here still abstract) method getStatement. Descendent classes can override getStatement to provide meaningful statements. If used with parameters, the values of the parameters will be applied to the statement. Each occurrence of a questionmark ('?') will be replaced by a parameter value. Parameters are applied in order: The n-th questionmark is replaced by the value of the n-th parameter.

Note on using packages

The package processor makes some assumptions about the datatypes:

• elements that start with a single quote are assumed to be Strings
• elements that contain a dash ('-') are assumed to be dates (yyyy-MM-dd) or timestamps (yyyy-MM-dd HH:mm:ss)
• elements containing a dot ('.') are assumed to be floats
• all other elements are assumed to be integers

Queries that return no data (queryType 'other') return a message indicating the number of rows processed

Since:

4.1

Author:

Gerrit van Brakel

Parameters

all parameters present are applied to the statement to be executed

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcQuerySenderBase.QueryType

Nested classes/interfaces inherited from interface nl.nn.adapterframework.statistics.HasStatistics

HasStatistics.Action

Field Summary

Fields

Modifier and Type	Field and Description
static String	UNP_END
static String	UNP_START

Fields inherited from class nl.nn.adapterframework.jdbc.JdbcSenderBase

connection, paramList

Fields inherited from class nl.nn.adapterframework.jndi.JndiBase

log

Constructor Summary

Constructors

Constructor and Description
JdbcQuerySenderBase()

Method Summary

Modifier and Type	Method and Description
protected String	adjustQueryAndParameterListForNamedParameters(ParameterList parameterList, String query)
protected boolean	canProvideOutputStream()
protected void	closeConnectionForSendMessage(Connection connection, PipeLineSession session)
protected void	closeStatementSet(QueryExecutionContext queryExecutionContext, PipeLineSession session)
void	configure() configure() is called once at startup of the framework in the configure method of the owner of this sender.
protected void	convertQuery(Connection connection, QueryExecutionContext queryExecutionContext)
protected Message	executeOtherQuery(Connection connection, PreparedStatement statement, String query, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList)
protected Message	executeOtherQuery(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session)
protected Message	executePackageQuery(QueryExecutionContext queryExecutionContext)
protected PipeRunResult	executeSelectQuery(PreparedStatement statement, Object blobSessionVar, Object clobSessionVar, javax.servlet.http.HttpServletResponse response, String contentType, String contentDisposition, PipeLineSession session, IForwardTarget next)
protected PipeRunResult	executeSelectQuery(PreparedStatement statement, Object blobSessionVar, Object clobSessionVar, PipeLineSession session, IForwardTarget next)
protected PipeRunResult	executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session, IForwardTarget next)
protected Message	executeUpdateBlobQuery(PreparedStatement statement, Message contents)
protected Message	executeUpdateClobQuery(PreparedStatement statement, Message contents)
protected String	fillParamArray(Object[] paramArray, String message)
int	getBatchSize()
protected CallableStatement	getCallWithRowIdReturned(Connection con, String query)
protected Connection	getConnectionForSendMessage(H blockHandle)
protected abstract String	getQuery(Message message) Obtain a query to be executed.
QueryExecutionContext	getQueryExecutionContext(Connection connection, Message message, PipeLineSession session)
JdbcQuerySenderBase.QueryType	getQueryTypeEnum()
protected Message	getResult(ResultSet resultset)
protected Message	getResult(ResultSet resultset, Object blobSessionVar, Object clobSessionVar)
protected PipeRunResult	getResult(ResultSet resultset, Object blobSessionVar, Object clobSessionVar, javax.servlet.http.HttpServletResponse response, String contentType, String contentDisposition, PipeLineSession session, IForwardTarget next)
protected ResultSet	getReturnedColumns(String[] columns, PreparedStatement st)
protected PreparedStatement	getStatement(Connection con, QueryExecutionContext queryExecutionContext)
void	open() This method will be called to start the sender.
protected PreparedStatement	prepareQuery(Connection con, QueryExecutionContext queryExecutionContext)
protected QueryExecutionContext	prepareStatementSet(H blockHandle, Connection connection, Message message, PipeLineSession session)
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 PipeRunResult	sendMessageOnConnection(Connection connection, Message message, PipeLineSession session, IForwardTarget next)
void	setAvoidLocking(boolean avoidLocking) If true, then select queries are executed in a way that avoids taking locks, e.g.
void	setBlobBase64Direction(Base64Pipe.Direction value) controls whether the streamed blobdata will need to be base64 encode or decode or not.
void	setBlobCharset(String string) Charset that is used to read and write BLOBs.
void	setBlobColumn(int i) Only for querytype 'updateBlob': column that contains the BLOB to be updated
void	setBlobsCompressed(boolean b) controls whether blobdata is stored compressed in the database
void	setBlobSessionKey(String string) For querytype 'updateBlob': key of session variable that contains the data (String or InputStream) to be loaded to the BLOB.
void	setBlobSmartGet(boolean b) Controls automatically whether blobdata is stored compressed and/or serialized in the database
void	setClobColumn(int i) Only for querytype 'updateClob': column that contains the CLOB to be updated
void	setClobSessionKey(String string) For querytype 'updateClob': key of session variable that contains the CLOB (String or InputStream) to be loaded to the CLOB.
void	setCloseInputstreamOnExit(boolean b) Deprecated.
void	setCloseOutputstreamOnExit(boolean b) When set to false, the Outputstream is not closed after BLOB or CLOB has been written to it
void	setColumnsReturned(String string) Comma separated list of columns whose values are to be returned.
void	setIncludeFieldDefinition(boolean b) when true, the result contains besides the returned rows also includes a header with information about the fetched fields
void	setLockRows(boolean b) When set true, exclusive row-level locks are obtained on all the rows identified by the select statement (e.g.
void	setLockWait(int i) when set and >=0, ' FOR UPDATE WAIT #' is used instead of ' FOR UPDATE NOWAIT SKIP LOCKED'
void	setMaxRows(int i) The maximum number of rows to be returned from the output of select queries, -1 means unlimited rows
void	setNullValue(String string) Value used in result as contents of fields that contain no value (sql-null)
void	setOutputFormat(DocumentFormat outputFormat) The type of output.
void	setPackageContent(String packageContent) Controls wheter the returned package content is db2 format or xml format.
void	setPrettyPrint(boolean prettyPrint) If true and scalar=false, multiline indented XML is produced
void	setQueryType(String queryType) Type of query to be executed
void	setResultQuery(String string) Query that can be used to obtain result of side-effect of update-query, like generated value of sequence.
void	setRowIdSessionKey(String string) If specified, the rowid of the processed row is put in the pipelinesession under the specified key (only applicable for querytype=other).
void	setScalar(boolean b) When true, the value of the first column of the first row (or the startrow) is returned as the only result, as a simple non-xml value
void	setScalarExtended(boolean b) When true and scalar is also true, but returns no value, one of the following is returned: '[absent]' no row is found '[null]' a row is found, but the value is a SQL-NULL '[empty]' a row is found, but the value is a empty string
void	setSqlDialect(String string) If set, the SQL dialect in which the queries are written and should be translated from to the actual SQL dialect
void	setStartRow(int i) The number of the first row to be returned from the output of select queries.
void	setStreamCharset(String string) Charset used when reading a stream (that is e.g.
void	setStreamResultToServlet(boolean b) Deprecated.
void	setSynchronous(boolean synchronous) When true, the result of sendMessage is the reply of the request.
void	setTrimSpaces(boolean b) Remove trailing blanks from all result values.
void	setUseNamedParams(Boolean b) Named parameters will be auto detected by default.
boolean	supportsOutputStreamPassThrough() Implementations should return true when they do not require an OutputStream, but can provide one to the preceding pipe if they are themselves provided with one from the next pipe.

Methods inherited from class nl.nn.adapterframework.jdbc.JdbcSenderBase

addParameter, close, getParameterList, getTimeout, sendMessage, setTimeout, toString

Methods inherited from class nl.nn.adapterframework.jdbc.JdbcFacade

getAuthAlias, getConnection, getConnectionWithTimeout, getDatasource, getDatasourceInfo, getDatasourceName, getDbmsSupport, getLogPrefix, getPassword, getPhysicalDestinationName, getUsername, isConnectionsArePooled, isTransacted, iterateOverStatistics, setAuthAlias, setConnectionsArePooled, setDatasourceName, setDbmsSupportFactory, setJmsRealm, setPassword, setTransacted, setUsername

Methods inherited from class nl.nn.adapterframework.jndi.JndiBase

getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes

Methods inherited from class java.lang.Object

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

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

closeBlock, openBlock, sendMessage

Methods inherited from interface nl.nn.adapterframework.stream.IStreamingSender

sendMessage

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.HasPhysicalDestination

getDomain

Field Detail

UNP_START

public static final String UNP_START

See Also:

Constant Field Values

UNP_END

public static final String UNP_END

See Also:

Constant Field Values

Constructor Detail

JdbcQuerySenderBase

public JdbcQuerySenderBase()

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 JdbcSenderBase<H>

Throws:

ConfigurationException

getQuery

protected abstract String getQuery(Message message)
                            throws SenderException

Obtain a query to be executed. Method-stub to be overridden in descender-classes.

Throws:

SenderException

getStatement

protected final PreparedStatement getStatement(Connection con,
                                               QueryExecutionContext queryExecutionContext)
                                        throws JdbcException,
                                               SQLException

Throws:

JdbcException

SQLException

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 JdbcSenderBase<H>

Throws:

SenderException

convertQuery

protected void convertQuery(Connection connection,
                            QueryExecutionContext queryExecutionContext)
                     throws JdbcException,
                            SQLException

Throws:

JdbcException

SQLException

prepareQuery

protected PreparedStatement prepareQuery(Connection con,
                                         QueryExecutionContext queryExecutionContext)
                                  throws SQLException,
                                         JdbcException

Throws:

SQLException

JdbcException

getCallWithRowIdReturned

protected CallableStatement getCallWithRowIdReturned(Connection con,
                                                     String query)
                                              throws SQLException

Throws:

SQLException

getReturnedColumns

protected ResultSet getReturnedColumns(String[] columns,
                                       PreparedStatement st)
                                throws SQLException

Throws:

SQLException

getQueryExecutionContext

public QueryExecutionContext getQueryExecutionContext(Connection connection,
                                                      Message message,
                                                      PipeLineSession session)
                                               throws SenderException,
                                                      SQLException,
                                                      ParameterException,
                                                      JdbcException

Throws:

SenderException

SQLException

ParameterException

JdbcException

getConnectionForSendMessage

protected Connection getConnectionForSendMessage(H blockHandle)
                                          throws JdbcException,
                                                 TimeoutException

Throws:

JdbcException

TimeoutException

closeConnectionForSendMessage

protected void closeConnectionForSendMessage(Connection connection,
                                             PipeLineSession session)
                                      throws JdbcException,
                                             TimeoutException

Throws:

JdbcException

TimeoutException

prepareStatementSet

protected QueryExecutionContext prepareStatementSet(H blockHandle,
                                                    Connection connection,
                                                    Message message,
                                                    PipeLineSession session)
                                             throws SenderException

Throws:

SenderException

closeStatementSet

protected void closeStatementSet(QueryExecutionContext queryExecutionContext,
                                 PipeLineSession session)

sendMessageOnConnection

protected PipeRunResult sendMessageOnConnection(Connection connection,
                                                Message message,
                                                PipeLineSession session,
                                                IForwardTarget next)
                                         throws SenderException,
                                                TimeoutException

Throws:

SenderException

TimeoutException

executeStatementSet

protected PipeRunResult executeStatementSet(QueryExecutionContext queryExecutionContext,
                                            Message message,
                                            PipeLineSession session,
                                            IForwardTarget next)
                                     throws SenderException,
                                            TimeoutException

Throws:

SenderException

TimeoutException

adjustQueryAndParameterListForNamedParameters

protected String adjustQueryAndParameterListForNamedParameters(ParameterList parameterList,
                                                               String query)
                                                        throws SenderException

Throws:

SenderException

getResult

protected Message getResult(ResultSet resultset)
                     throws JdbcException,
                            SQLException,
                            IOException,
                            javax.jms.JMSException

Throws:

JdbcException

SQLException

IOException

javax.jms.JMSException

getResult

protected Message getResult(ResultSet resultset,
                            Object blobSessionVar,
                            Object clobSessionVar)
                     throws JdbcException,
                            SQLException,
                            IOException,
                            javax.jms.JMSException

Throws:

JdbcException

SQLException

IOException

javax.jms.JMSException

getResult

protected PipeRunResult getResult(ResultSet resultset,
                                  Object blobSessionVar,
                                  Object clobSessionVar,
                                  javax.servlet.http.HttpServletResponse response,
                                  String contentType,
                                  String contentDisposition,
                                  PipeLineSession session,
                                  IForwardTarget next)
                           throws JdbcException,
                                  SQLException,
                                  IOException

Throws:

JdbcException

SQLException

IOException

executeUpdateBlobQuery

protected Message executeUpdateBlobQuery(PreparedStatement statement,
                                         Message contents)
                                  throws SenderException

Throws:

SenderException

executeUpdateClobQuery

protected Message executeUpdateClobQuery(PreparedStatement statement,
                                         Message contents)
                                  throws SenderException

Throws:

SenderException

canProvideOutputStream

protected boolean canProvideOutputStream()

supportsOutputStreamPassThrough

public boolean supportsOutputStreamPassThrough()

Description copied from interface: IOutputStreamingSupport

Implementations should return true when they do not require an OutputStream, but can provide one to the preceding pipe if they are themselves provided with one from the next pipe.

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

Throws:

StreamingException

executeSelectQuery

protected PipeRunResult executeSelectQuery(PreparedStatement statement,
                                           Object blobSessionVar,
                                           Object clobSessionVar,
                                           PipeLineSession session,
                                           IForwardTarget next)
                                    throws SenderException

Throws:

SenderException

executeSelectQuery

protected PipeRunResult executeSelectQuery(PreparedStatement statement,
                                           Object blobSessionVar,
                                           Object clobSessionVar,
                                           javax.servlet.http.HttpServletResponse response,
                                           String contentType,
                                           String contentDisposition,
                                           PipeLineSession session,
                                           IForwardTarget next)
                                    throws SenderException

Throws:

SenderException

executePackageQuery

protected Message executePackageQuery(QueryExecutionContext queryExecutionContext)
                               throws SenderException,
                                      JdbcException,
                                      IOException,
                                      javax.jms.JMSException

Throws:

SenderException

JdbcException

IOException

javax.jms.JMSException

executeOtherQuery

protected Message executeOtherQuery(QueryExecutionContext queryExecutionContext,
                                    Message message,
                                    PipeLineSession session)
                             throws SenderException

Throws:

SenderException

executeOtherQuery

protected Message executeOtherQuery(Connection connection,
                                    PreparedStatement statement,
                                    String query,
                                    PreparedStatement resStmt,
                                    Message message,
                                    PipeLineSession session,
                                    ParameterList parameterList)
                             throws SenderException

Throws:

SenderException

fillParamArray

protected String fillParamArray(Object[] paramArray,
                                String message)
                         throws SenderException

Throws:

SenderException

setPackageContent

public void setPackageContent(String packageContent)

Controls wheter the returned package content is db2 format or xml format. Possible values:

• select:
xml content s expected
• anything else:
db2 content is expected

setQueryType

public void setQueryType(String queryType)

Type of query to be executed

Default value

OTHER

getQueryTypeEnum

public JdbcQuerySenderBase.QueryType getQueryTypeEnum()

setScalar

public void setScalar(boolean b)

When true, the value of the first column of the first row (or the startrow) is returned as the only result, as a simple non-xml value

Default value

false

setScalarExtended

public void setScalarExtended(boolean b)

When true and scalar is also true, but returns no value, one of the following is returned:

• '[absent]' no row is found
• '[null]' a row is found, but the value is a SQL-NULL
• '[empty]' a row is found, but the value is a empty string

Default value

false

setMaxRows

public void setMaxRows(int i)

The maximum number of rows to be returned from the output of select queries, -1 means unlimited rows

Default value

-1

setStartRow

public void setStartRow(int i)

The number of the first row to be returned from the output of select queries. Rows before this are skipped from the output.

Default value

1

setNullValue

public void setNullValue(String string)

Value used in result as contents of fields that contain no value (sql-null)

Default value

empty string

setResultQuery

public void setResultQuery(String string)

Query that can be used to obtain result of side-effect of update-query, like generated value of sequence. Example: SELECT mysequence.currval FROM dual

setColumnsReturned

public void setColumnsReturned(String string)

Comma separated list of columns whose values are to be returned. Works only if the driver implements jdbc 3.0 getGeneratedKeys(). Note: not all drivers support multiple values and returned field names may vary between drivers. Works for H2 and Oracle. Could work for MS_SQL with a single identity column, with name GENERATED_KEYS, if a identity has been generated. Not supported for other DBMSes.

setUseNamedParams

public void setUseNamedParams(Boolean b)

Named parameters will be auto detected by default. Every string in the query which equals "?{"paramname"}" will be replaced by the value of the corresponding parameter. The parameters don't need to be in the correct order and unused parameters are skipped.

Default value

null

setIncludeFieldDefinition

public void setIncludeFieldDefinition(boolean b)

when true, the result contains besides the returned rows also includes a header with information about the fetched fields

Default value

application default (true)

setTrimSpaces

public void setTrimSpaces(boolean b)

Remove trailing blanks from all result values.

Default value

true

setRowIdSessionKey

public void setRowIdSessionKey(String string)

If specified, the rowid of the processed row is put in the pipelinesession under the specified key (only applicable for querytype=other). Note: If multiple rows are processed a SqlException is thrown.

setStreamResultToServlet

@Deprecated
public void setStreamResultToServlet(boolean b)

Deprecated.

If set, the result is streamed to the HttpServletResponse object of the RestServiceDispatcher (instead of passed as bytes or as a String)

Default value

false

setSqlDialect

public void setSqlDialect(String string)

If set, the SQL dialect in which the queries are written and should be translated from to the actual SQL dialect

setLockRows

public void setLockRows(boolean b)

When set true, exclusive row-level locks are obtained on all the rows identified by the select statement (e.g. by appending ' FOR UPDATE NOWAIT SKIP LOCKED' to the end of the query)

Default value

false

setLockWait

public void setLockWait(int i)

when set and >=0, ' FOR UPDATE WAIT #' is used instead of ' FOR UPDATE NOWAIT SKIP LOCKED'

Default value

-1

setSynchronous

public void setSynchronous(boolean synchronous)

When true, the result of sendMessage is the reply of the request.

Default value

true

setBlobColumn

public void setBlobColumn(int i)

Only for querytype 'updateBlob': column that contains the BLOB to be updated

Default value

1

setBlobSessionKey

public void setBlobSessionKey(String string)

For querytype 'updateBlob': key of session variable that contains the data (String or InputStream) to be loaded to the BLOB. When empty, the input of the pipe, which then must be a String, is used. For querytype 'select': key of session variable that contains the OutputStream, Writer or Filename to write the BLOB to

setBlobsCompressed

public void setBlobsCompressed(boolean b)

controls whether blobdata is stored compressed in the database

Default value

true

setBlobBase64Direction

public void setBlobBase64Direction(Base64Pipe.Direction value)

controls whether the streamed blobdata will need to be base64 encode or decode or not.

setBlobCharset

public void setBlobCharset(String string)

Charset that is used to read and write BLOBs. This assumes the blob contains character data. If blobCharset and blobSmartGet are not set, BLOBs are returned as bytes. Before version 7.6, blobs were base64 encoded after being read to accommodate for the fact that senders need to return a String. This is no longer the case

setBlobSmartGet

public void setBlobSmartGet(boolean b)

Controls automatically whether blobdata is stored compressed and/or serialized in the database

Default value

false

setClobColumn

public void setClobColumn(int i)

Only for querytype 'updateClob': column that contains the CLOB to be updated

Default value

1

setClobSessionKey

public void setClobSessionKey(String string)

For querytype 'updateClob': key of session variable that contains the CLOB (String or InputStream) to be loaded to the CLOB. When empty, the input of the pipe, which then must be a String, is used. For querytype 'select': key of session variable that contains the OutputStream, Writer or Filename to write the CLOB to

setCloseInputstreamOnExit

@Deprecated
public void setCloseInputstreamOnExit(boolean b)

Deprecated.

When set to false, the Inputstream is not closed after it has been used to update a BLOB or CLOB

Default value

true

setCloseOutputstreamOnExit

public void setCloseOutputstreamOnExit(boolean b)

When set to false, the Outputstream is not closed after BLOB or CLOB has been written to it

Default value

true

setStreamCharset

public void setStreamCharset(String string)

Charset used when reading a stream (that is e.g. going to be written to a BLOB or CLOB). When empty, the stream is copied directly to the BLOB, without conversion

setAvoidLocking

public void setAvoidLocking(boolean avoidLocking)

If true, then select queries are executed in a way that avoids taking locks, e.g. with isolation mode 'read committed' instead of 'repeatable read'.

Default value

false

setPrettyPrint

public void setPrettyPrint(boolean prettyPrint)

If true and scalar=false, multiline indented XML is produced

Default value

false

setOutputFormat

public void setOutputFormat(DocumentFormat outputFormat)

The type of output. If not set then defaults to old-style XML. If set to XML, new-style XML is used. EXPERIMENTAL: datatypes like numbers are not yet rendered correctly

Default value

false

getBatchSize

public int getBatchSize()