Package net.simplace.pipe.processors

Klasse SQLStatementProcessor

java.lang.Object
net.simplace.pipe.control.FWProcessor
net.simplace.pipe.processors.SQLStatementProcessor
public class SQLStatementProcessor extends FWProcessor
This processor performs SQL-Statements on a existing Database
Parameter Description
db_conn JDBC Connection from Pipeline.
#1, #2, #3, ... SQL statments to process (e.g. SELECT or UPDATE or DROP table). For SELECT statements the following parameters resultParamtKey and resultParamClass should be used to specify the SQL statement return type and output parameter key.
OUT: resultParamKey
or
#0.resultParamKey,
#1.resultParamKey,
...		 (optional) if Statement should produce a result saved to pipeline, set this key. If multiple SELECT statements are processed within the processor call, the "#X."- prefix can be used to specify individual output parameter keys for each SELECT statement. If prefix is missing only one single SELECT statement can be processed (because multiple would all use the same output parameter key!)
resultParamClass
or
#0.resultParamClass,
#1.resultParamClass,
...		 (optional) if Statement should produce a result saved to pipeline, set this with needed classname
Default: java.lang.String If multiple SELECT statements are processed within the processor call, the "#X."- prefix can be used to specify individual output classes for each SELECT statement. For all SELECT statement the prefix is missing, the general prefix-less parameter resultParamClass is used.
Furthermore following configuration is expected (as a subelement in processor element in the configuration file) to describe the concrete data, that shall be read. Use normal parameterTags such as SQL STATEMENT UPDATE ${some.variable} SET ... if a result is requested, use only one statement (#0)! Result will be packed to given Classtype.
Autor:
Andreas Enders

  • Konstruktordetails

    • SQLStatementProcessor

      public SQLStatementProcessor()

  • Methodendetails

    • process

      protected boolean process() throws PipeLineException
      Beschreibung aus Klasse kopiert: FWProcessor
      Must be overridden to implement concrete pipe procedure.
      Angegeben von:
      process in Klasse FWProcessor
      Gibt zurück:
      success
      Löst aus:
      PipeLineException

    • checkInParameterMap

      public boolean checkInParameterMap()
      Checks whether the in-channel contains all required parameters.
      Setzt außer Kraft:
      checkInParameterMap in Klasse FWProcessor
      Gibt zurück:
      true if not overridden by implementations