扩展 WebSphere®MQ Integrator Broker V2.1 和 WebSphere Business Integration Message Broker V5

<CompanyNewsletter>
  <Recipients>
    <Recipient>john@doe.com</Recipient>
    <Recipient>jane@doe.com</Recipient>
    ...
  </Recipients>
  <Text>
    ...
  </Text>
</CompanyNewsletter>

WHILE condition
  build request message to check for e-Mail-address
  PROPAGATE
END WHILE;
send newsletter

SET OutputRoot = InputRoot;
-- Enter SQL below this line. SQL above this line might be
   regenerated, causing any  modifications to be lost.
DECLARE pRefNet REFERENCE TO OutputRoot.XML.Bill.Net;
DECLARE pRefTax REFERENCE TO OutputRoot.XML.Bill.Tax;
DECLARE pRefGross REFERENCE TO OutputRoot.XML.Bill.Gross;
SET pRefGross = CAST(pRefNet AS DECIMAL) * 
                CAST(pRefTax AS DECIMAL) +
                CAST(pRetNet AS DECIMAL);

void LilFactoryExportPrefix * LilFactoryExportSuffix bipGetParserFactory(void) {
  CciFactory*     factoryObject;
  int             rc;
  static CPI_VFT  vftable = {CPI_VFT_DEFAULT};
  // initialize the constants used by this plug-in
  initParserConstants();
  // setup function table with pointers to parser implementation functions
  vftable.iFpParseBufferEncoded       = cpiParseAndWriteBufferEncoded;
  vftable.iFpWriteBufferEncoded       = cpiParseAndWriteBufferEncoded;
  vftable.iFpSetElementValue          = cpiSetElementValue;
  vftable.iFpElementValue             = cpiElementValue;
  // mandatory functions, otherwise WMQI does not use this parser
  vftable.iFpCreateContext            = cpiCreateContext;
  vftable.iFpParseFirstChild          = cpiParseFirstLastChildAndPreviousNextSibling;
  vftable.iFpParseLastChild           = cpiParseFirstLastChildAndPreviousNextSibling;
  vftable.iFpParsePreviousSibling     = cpiParseFirstLastChildAndPreviousNextSibling;
  vftable.iFpParseNextSibling         = cpiParseFirstLastChildAndPreviousNextSibling;
  // create the parser factory for this plugin
  factoryObject = cpiCreateParserFactory(&rc, constParserFactory);
  if (factoryObject) {
    // Define the classes of message supported by the factory
    cpiDefineParserClass(&rc, factoryObject, constParserClass, &vftable);
  } else {
      static char* errMsg = "CciLogParser.lil: error creating" 
                            " the parser factory " CONST_PARSER_FACTORY;
      cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "bipGetParserFactory()",  
             constWBIMBCatalog, 3001, errMsg, errMsg, CONST_VIRTUALTRACENODENAME, 0);
  }
  return(factoryObject);
}

// -----------------------------------------------------------------------------
// Plugin Parser Implementation Function
void cpiSetElementValue(CciParser* parser, CciElement* element, CciElementValue* value) {
  CciElement* valueElement;
  CciSize     bufferSize;
  int         rc;
  CciChar     buffer[1024]; // maximum supported length of message
  char        charBuffer[1024];
  // set the value
  valueElement = element;
  if ((cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_VALUE) ||
      (cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_NAME_VALUE))  {
    cpiSetElementValueValue(&rc, element, value);
  } else if (cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_NAME) {
    /* Create a new value element, add as a first child, and set the value */
    valueElement = cpiCreateElement(&rc, parser);
    cpiSetElementType(&rc, valueElement, CCI_ELEMENT_TYPE_VALUE);
    cpiSetElementValueValue(&rc, valueElement, value);
    cpiAddAsFirstChild(&rc, element, valueElement);
  }
  buffer[0] = 0;
  bufferSize = cpiElementCharacterValue(&rc, valueElement, buffer, 1023);
  if (rc==CCI_EXCEPTION) {
    cciRethrowLastException(&rc);
  } else if (rc==CCI_SUCCESS) {
    cciUcsToMbs(&rc, buffer, charBuffer, 1023, BIP_DEF_COMP_CCSID);
    if (rc!=CCI_SUCCESS) {
      // Error occured, e.g the message contained non-ASCII 
      // characters which were expanded to more than one byte per character.
      sprintf(charBuffer, "CciLogParser.lil: error converting the log text "
                          "into a C-string, error code %i", rc);
      cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "cpiSetElementValue()", 
             constWBIMBCatalog, 3001, charBuffer, 
             charBuffer, CONST_VIRTUALTRACENODENAME, 0);             
    } else {
      // the original intend of this parser; write the message to the WMQI log
      cciLog(&rc, CCI_LOG_INFORMATION, __FILE__, __LINE__, "cpiSetElementValue()",
             constWBIMBCatalog, 3001, charBuffer, 
             charBuffer, CONST_VIRTUALTRACENODENAME, 0);
    }
  } else if (rc==CCI_BUFFER_TOO_SMALL) {
    // here we could allocate a new buffer and retrieve the text again,
    // but this sample just writes an error to the log
    strcpy(charBuffer, "CciLogParser.lil: buffer too small for conversion, " 
                       "pass only ASCII style messages");
    cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "cpiSetElementValue()", 
           constWBIMBCatalog, 3001, charBuffer, 
           charBuffer, CONST_VIRTUALTRACENODENAME, 0);             
  } else {
    // unhandled error
    sprintf(charBuffer, "CciLogParser.lil: unknown error rc=%i while retrieving the text", rc);
    cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "cpiSetElementValue()", 
           constWBIMBCatalog, 3001, charBuffer, 
           charBuffer, CONST_VIRTUALTRACENODENAME, 0);             
  }  
  return;
}

SET OutputRoot = InputRoot;
-- Enter SQL below this line.  SQL above this line might be regenerated, causing any
        
 modifications to be lost.
DECLARE pRefNet REFERENCE TO OutputRoot.XML.Bill.Net;
IF (pRefNet IS NULL) THEN
  SET OutputRoot.CCILOG.Msg = 'OutputRoot.XML.Bill.Net value was NULL';
ELSE
  SET OutputRoot.CCILOG.Msg = 'OutputRoot.XML.Bill.Net value was >' || pRefNet || '<';
END IF;
DECLARE pRefTax REFERENCE TO OutputRoot.XML.Bill.Tax;
IF (pRefTax IS NULL) THEN
  SET OutputRoot.CCILOG.Msg = 'OutputRoot.XML.Bill.Tax value was NULL';
ELSE
  SET OutputRoot.CCILOG.Msg = 'OutputRoot.XML.Bill.Tax value was >' || pRefTax || '<';
END IF;
DECLARE pRefGross REFERENCE TO OutputRoot.XML.Bill.Gross;
IF (pRefGross IS NULL) THEN
  SET OutputRoot.CCILOG.Msg = 'OutputRoot.XML.Bill.Gross value was NULL';
ELSE
  SET OutputRoot.CCILOG.Msg = 'OutputRoot.XML.Bill.Gross value was >' || pRefGross || '<';
END IF;
SET pRefGross = CAST(pRefNet AS DECIMAL) * 
                CAST(pRefTax AS DECIMAL) + 
                CAST(pRefNet AS DECIMAL);
SET OutputRoot.CCILOG.Msg = 'New value for OutputRoot.XML.Bill.Gross >' || pRefGross || '<';
-- Clean Up the CCILOG message tree
DETACH OutputRoot.CCILOG;
      

#ifndef __MVS__
  #include <malloc.h>
#endif
#include <windows.h>
#include <memory.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <wchar.h>
#include <BipCci.h>
#include <BipCni.h>
#include <BipCpi.h>
#ifdef __cplusplus
extern "C" {
#endif
void LilFactoryExportPrefix * LilFactoryExportSuffix bipGetParserFactory(void);
#ifdef __cplusplus
}
#endif
#ifdef __MVS__
#define BIP_DEF_COMP_CCSID 1047
#else
#define BIP_DEF_COMP_CCSID 1208
#endif
#define CONST_PARSER_CLASS              "CCILOG"
#define CONST_PARSER_FACTORY            "ComIbmSampleCciLogParserFactory"
#define CONST_WBIMB_CATALOG             "WMQIv210"
#define CONST_VIRTUALTRACENODENAME      "CciLogParser - Extension for ESQL"
CciChar * constParserClass    = 0;
CciChar * constParserFactory  = 0;
CciChar * constWBIMBCatalog   = 0;
// -----------------------------------------------------------------------------
// Plugin Parser Implementation Function
//
//  the signature of cpiParseBufferEncoded() and cpiWriteBufferEncoded() is 
//  the same and their body is empty, so just this one function is used
int cpiParseAndWriteBufferEncoded(CciParser* parser, CciContext* context, 
                                  int encoding, int ccsid) {
  return 0;
}
// -----------------------------------------------------------------------------
// Plugin Parser Implementation Function
CciContext* cpiCreateContext(CciParser* parser) {
    return((CciContext*) 0);
}
// -----------------------------------------------------------------------------
// Plugin Parser Implementation Function
//
//  the signature of cpiParseFirstChild(), cpiParseLastChild(), 
//  cpiParsePreviousSibling() and cpiParseNextSibling() is the
//  same and their body is empty, so just this one function is used
void cpiParseFirstLastChildAndPreviousNextSibling(CciParser* parser, 
                                      CciContext* context, CciElement* element) {
  return;
}
// -----------------------------------------------------------------------------
// Plugin Parser Implementation Function
void cpiSetElementValue(CciParser* parser, CciElement* element, CciElementValue* value) {
  CciElement* valueElement;
  CciSize     bufferSize;
  int         rc;
  CciChar     buffer[1024]; // maximum supported length of message
  char        charBuffer[1024];
  // set the value
  valueElement = element;
  if ((cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_VALUE) ||
      (cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_NAME_VALUE))  {
    cpiSetElementValueValue(&rc, element, value);
  } else if (cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_NAME) {
    /* Create a new value element, add as a first child, and set the value */
    valueElement = cpiCreateElement(&rc, parser);
    cpiSetElementType(&rc, valueElement, CCI_ELEMENT_TYPE_VALUE);
    cpiSetElementValueValue(&rc, valueElement, value);
    cpiAddAsFirstChild(&rc, element, valueElement);
  }
  buffer[0] = 0;
  bufferSize = cpiElementCharacterValue(&rc, valueElement, buffer, 1023);
  if (rc==CCI_EXCEPTION) {
    cciRethrowLastException(&rc);
  } else if (rc==CCI_SUCCESS) {
    cciUcsToMbs(&rc, buffer, charBuffer, 1023, BIP_DEF_COMP_CCSID);
    if (rc!=CCI_SUCCESS) {
      // Error occured, e.g the message contained non-ASCII 
      // characters which were expanded to more than one byte per character.
      sprintf(charBuffer, "CciLogParser.lil: error converting the log text "
                          "into a C-string, error code %i", rc);
      cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "cpiSetElementValue()", 
             constWBIMBCatalog, 3001, charBuffer, 
             charBuffer, CONST_VIRTUALTRACENODENAME, 0);             
    } else {
      // the original intend of this parser; write the message to the WMQI log
      cciLog(&rc, CCI_LOG_INFORMATION, __FILE__, __LINE__, "cpiSetElementValue()",
             constWBIMBCatalog, 3001, charBuffer, 
             charBuffer, CONST_VIRTUALTRACENODENAME, 0);
    }
  } else if (rc==CCI_BUFFER_TOO_SMALL) {
    // here we could allocate a new buffer and retrieve the text again,
    // but this sample just writes an error to the log
    strcpy(charBuffer, "CciLogParser.lil: buffer too small for conversion, " 
                       "pass only ASCII style messages");
    cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "cpiSetElementValue()", 
           constWBIMBCatalog, 3001, charBuffer, 
           charBuffer, CONST_VIRTUALTRACENODENAME, 0);             
  } else {
    // unhandled error
    sprintf(charBuffer, 
            "CciLogParser.lil: unknown error rc=%i while retrieving the text", rc);
    cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "cpiSetElementValue()", 
           constWBIMBCatalog, 3001, charBuffer, 
           charBuffer, CONST_VIRTUALTRACENODENAME, 0);             
  }  
  return;
}
// -----------------------------------------------------------------------------
// Plugin Parser Implementation Function
const CciElementValue* cpiElementValue(CciParser*  parser, CciElement* element) {
  CciElement* firstChild;
  const CciElementValue* value;
  int         rc;
  if ((cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_VALUE) ||
      (cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_NAME_VALUE)) {
    value = cpiElementValueValue(&rc, element);
  }
  else if (cpiElementType(&rc, element) == CCI_ELEMENT_TYPE_NAME) {
    firstChild = cniFirstChild(&rc, element);
    value = cpiElementValueValue(&rc, firstChild);
  }
  else {
  }
  return(value);
}
// -----------------------------------------------------------------------------
// utility function
const CciChar* CciString(const char* source, int codepage) {
  // maximum number of characters in Unicode representation
  int rc;
  int maxChars = strlen(source) + 1 ;
  CciChar* buffer = (CciChar*) malloc(maxChars * sizeof(CciChar));
  cciMbsToUcs(&rc, source, buffer, maxChars, codepage);
  
  return buffer;
}
// -----------------------------------------------------------------------------
// utility function
void initParserConstants(void) {
  constParserClass   = (CciChar*) CciString(CONST_PARSER_CLASS,   BIP_DEF_COMP_CCSID);
  constParserFactory = (CciChar*) CciString(CONST_PARSER_FACTORY, BIP_DEF_COMP_CCSID);
  constWBIMBCatalog  = (CciChar*) CciString(CONST_WBIMB_CATALOG,  BIP_DEF_COMP_CCSID);
}
// -----------------------------------------------------------------------------
// entry point for WMQI
void LilFactoryExportPrefix * LilFactoryExportSuffix bipGetParserFactory(void) {
  CciFactory*     factoryObject;
  int             rc;
  static CPI_VFT  vftable = {CPI_VFT_DEFAULT};
  // initialize the constants used by this plug-in
  initParserConstants();
  // setup function table with pointers to parser implementation functions
  vftable.iFpParseBufferEncoded       = cpiParseAndWriteBufferEncoded;
  vftable.iFpWriteBufferEncoded       = cpiParseAndWriteBufferEncoded;
  vftable.iFpSetElementValue          = cpiSetElementValue;
  vftable.iFpElementValue             = cpiElementValue;
  // mandatory functions, otherwise WMQI does not use this parser
  vftable.iFpCreateContext            = cpiCreateContext;
  vftable.iFpParseFirstChild          = cpiParseFirstLastChildAndPreviousNextSibling;
  vftable.iFpParseLastChild           = cpiParseFirstLastChildAndPreviousNextSibling;
  vftable.iFpParsePreviousSibling     = cpiParseFirstLastChildAndPreviousNextSibling;
  vftable.iFpParseNextSibling         = cpiParseFirstLastChildAndPreviousNextSibling;
  // create the parser factory for this plugin
  factoryObject = cpiCreateParserFactory(&rc, constParserFactory);
  if (factoryObject) {
    // Define the classes of message supported by the factory
    cpiDefineParserClass(&rc, factoryObject, constParserClass, &vftable);
  } else {
      static char* errMsg = "CciLogParser.lil: error creating the parser factory " 
                            CONST_PARSER_FACTORY;
      cciLog(&rc, CCI_LOG_ERROR, __FILE__, __LINE__, "bipGetParserFactory()",              
             constWBIMBCatalog, 3001, errMsg, errMsg, CONST_VIRTUALTRACENODENAME, 0);
  }
  return(factoryObject);
}