Package org.springframework.integration.jdbc

Class StoredProcExecutor

java.lang.Object
org.springframework.integration.jdbc.StoredProcExecutor
All Implemented Interfaces:
Aware, BeanFactoryAware, InitializingBean
public class StoredProcExecutor extends Object implements BeanFactoryAware, InitializingBean
This class is used by all Stored Procedure (Stored Function) components and provides the core functionality to execute those.
Since:
2.1
Author:
Gunnar Hillert, Artem Bilan, Gary Russell, Christian Tzolov

  • Constructor Details

    • StoredProcExecutor

      public StoredProcExecutor(DataSource dataSource)
      Constructor taking DataSource from which the DB Connection can be obtained.
      Parameters:
      dataSource - used to create a SimpleJdbcCall instance, must not be Null

  • Method Details

    • afterPropertiesSet

      public void afterPropertiesSet()
      Verifies parameters, sets the parameters on SimpleJdbcCallOperations and ensures the appropriate SqlParameterSourceFactory is defined when ProcedureParameter are passed in.
      Specified by:
      afterPropertiesSet in interface InitializingBean

    • executeStoredProcedure

      public Map<String,Object> executeStoredProcedure()
      Execute a Stored Procedure or Function - Use when no Message is available to extract ProcedureParameter values from it.
      Returns:
      Map containing the stored procedure results if any.

    • executeStoredProcedure

      public Map<String,Object> executeStoredProcedure(Message<?> message)
      Execute a Stored Procedure or Function - Use with Message is available to extract ProcedureParameter values from it.
      Parameters:
      message - A message.
      Returns:
      Map containing the stored procedure results if any.

    • setIgnoreColumnMetaData

      public void setIgnoreColumnMetaData(boolean ignoreColumnMetaData)
      For fully supported databases, the underlying SimpleJdbcCall can retrieve the parameter information for the to be invoked Stored Procedure from the JDBC Meta-data. However, if the used database does not support meta data lookups or if you like to provide customized parameter definitions, this flag can be set to 'true'. It defaults to 'false'.
      Parameters:
      ignoreColumnMetaData - true to ignore column metadata.

    • setProcedureParameters

      public void setProcedureParameters(List<ProcedureParameter> procedureParameters)
      Custom Stored Procedure parameters that may contain static values or Strings representing an Expression.
      Parameters:
      procedureParameters - The parameters.

    • setSqlParameters

      public void setSqlParameters(List<SqlParameter> sqlParameters)
      If you database system is not fully supported by Spring and thus obtaining parameter definitions from the JDBC Meta-data is not possible, you must define the SqlParameter explicitly.
      Parameters:
      sqlParameters - The parameters.

    • setSqlParameterSourceFactory

      public void setSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
      Provides the ability to set a custom SqlParameterSourceFactory. Keep in mind that if ProcedureParameter are set explicitly and you would like to provide a custom SqlParameterSourceFactory, then you must provide an instance of ExpressionEvaluatingSqlParameterSourceFactory. If not the SqlParameterSourceFactory will be replaced the default ExpressionEvaluatingSqlParameterSourceFactory.
      Parameters:
      sqlParameterSourceFactory - the parameter source factory.

    • getStoredProcedureName

      public String getStoredProcedureName()
      Returns:
      the name of the Stored Procedure or Function if set. Null otherwise.

    • getStoredProcedureNameExpressionAsString

      public String getStoredProcedureNameExpressionAsString()
      Returns:
      the Stored Procedure Name Expression as a String if set. Null otherwise.

    • setStoredProcedureName

      public void setStoredProcedureName(String storedProcedureName)
      The name of the Stored Procedure or Stored Function to be executed. If isFunction is set to "true", then this property specifies the Stored Function name. Alternatively you can also specify the Stored Procedure name via setStoredProcedureNameExpression(Expression). E.g., that way you can specify the name of the Stored Procedure or Stored Function through MessageHeaders.
      Parameters:
      storedProcedureName - Must not be null and must not be empty
      See Also:

    • setStoredProcedureNameExpression

      public void setStoredProcedureNameExpression(Expression storedProcedureNameExpression)
      Using the storedProcedureNameExpression the Message can be used as source for the name of the Stored Procedure or Stored Function. If isFunction is set to "true", then this property specifies the Stored Function name. By providing a SpEL expression as value for this setter, a subset of the original payload, a header value or any other resolvable SpEL expression can be used as the basis for the Stored Procedure / Function. For the Expression evaluation the full message is available as the root object. For instance the following SpEL expressions (among others) are possible:
      • payload.foo
      • headers.foobar
      • new java.util.Date()
      • 'foo' + 'bar'
      Alternatively you can also specify the Stored Procedure name via setStoredProcedureName(String)
      Parameters:
      storedProcedureNameExpression - Must not be null.

    • setUsePayloadAsParameterSource

      public void setUsePayloadAsParameterSource(boolean usePayloadAsParameterSource)
      If set to 'true', the payload of the Message will be used as a source for providing parameters. If false the entire Message will be available as a source for parameters. If no ProcedureParameter are passed in, this property will default to true. This means that using a default BeanPropertySqlParameterSourceFactory the bean properties of the payload will be used as a source for parameter values for the to-be-executed Stored Procedure or Function. However, if ProcedureParameters are passed in, then this property will by default evaluate to false. ProcedureParameter allow for SpEl Expressions to be provided and therefore it is highly beneficial to have access to the entire Message.
      Parameters:
      usePayloadAsParameterSource - If false the entire Message is used as parameter source.

    • setIsFunction

      public void setIsFunction(boolean isFunction)
      Indicates whether a Stored Procedure or a Function is being executed. The default value is false.
      Parameters:
      isFunction - If set to true an Sql Function is executed rather than a Stored Procedure.

    • setReturnValueRequired

      public void setReturnValueRequired(boolean returnValueRequired)
      Indicates the procedure's return value should be included in the results returned.
      Parameters:
      returnValueRequired - true to include the return value.

    • setSkipUndeclaredResults

      public void setSkipUndeclaredResults(boolean skipUndeclaredResults)
      If this variable is set to true then all results from a stored procedure call that don't have a corresponding SqlOutParameter declaration will be bypassed. E.g. Stored Procedures may return an update count value, even though your Stored Procedure only declared a single result parameter. The exact behavior depends on the used database. The value is set on the underlying JdbcTemplate. Only few developers will probably ever like to process update counts, thus the value defaults to true.
      Parameters:
      skipUndeclaredResults - The boolean.

    • setReturningResultSetRowMappers

      public void setReturningResultSetRowMappers(Map<String,RowMapper<?>> returningResultSetRowMappers)
      If the Stored Procedure returns ResultSets you may provide a map of RowMapper to convert the ResultSet to meaningful objects.
      Parameters:
      returningResultSetRowMappers - The map may not be null and must not contain null values.

    • setJdbcCallOperationsCacheSize

      public void setJdbcCallOperationsCacheSize(int jdbcCallOperationsCacheSize)
      Defines the maximum number of SimpleJdbcCallOperations A value of zero will disable the cache. The default is 10.
      Parameters:
      jdbcCallOperationsCacheSize - Must not be negative.

    • setBeanFactory

      public void setBeanFactory(BeanFactory beanFactory)
      Allows to set the optional BeanFactory which is used to add a BeanResolver to the StandardEvaluationContext. If not set this property defaults to null.
      Specified by:
      setBeanFactory in interface BeanFactoryAware
      Parameters:
      beanFactory - If set must not be null.