<sx:escapeSubstitutions character='"' escapeCharacter="\"/>

  <sx:escapeSubstitutions character="'" escapeSequence="&quot;"/>

  <sx:parameter name="validate"><sx:defaultValue>yes</sx:defaultValue></sx:parameter>

  <sx:parameter name="validate">yes</sx:parameter>

  <sx:parameter name="myParam">
    <sx:serialize>
      <sx:transform>
        <sx:xslt> 
          <sx:urlSource url="styles/transform1.xsl"/> 
        </sx:xslt> 
        <sx:content ref="flat1"/>
      </sx:transform>
    </sx:serialize>
  </sx:parameter>

  <sx:parameter name="output-file-name">
    <sx:findAndReplace searchFor="(books.*)[.]txt" replaceWith ="$1-new.txt"><sx:toString value="{name}"/></sx:findAndReplace>
  </sx:parameter>   

  <sx:document id="odd-element-document">
    <document>
      <title>Title</title>
      <para>First paragraph.</para>
    </document>
  </sx:document>

  <sx:transform id="test-choose-odd">
    <sx:document ref="odd-element-document"/>
    <sx:choose>
      <sx:when test="count(//*) mod 2 = 0">
        <sx:document>
          <result>even</result>
        </sx:document>
      </sx:when>
      <sx:otherwise>
        <sx:document>
          <result>odd</result>
        </sx:document>
      </sx:otherwise>
    </sx:choose>
    <sx:assert test="text()='odd'">Expected odd number of elements.
    </sx:assert>
  </sx:transform>

The output of this sx:choose element is the document

  <result>odd</result>

  <!-- Define a choose expression with embedded parameter 
    "term", term values having the format <number><D|M|Y>,
    and expanding to

      <periodMultiplier>number</periodMultiplier>
      <period>D|M|Y</period>
  -->

  <sx:choose id="fpml-period-from-term">
    <sx:when test="fn:ends-with($term,'D')">
      <sx:fieldElementMap element="periodMultiplier">
        <sx:toString select="fn:substring-before($term,'D')"/>
      </sx:fieldElementMap>
      <period>D</period>
    </sx:when>
    <sx:when test="fn:ends-with($term,'M')">
      <sx:fieldElementMap element="periodMultiplier">
        <sx:toString select="fn:substring-before($term,'M')"/>
      </sx:fieldElementMap>
      <period>M</period>
    </sx:when>
    <sx:when test="fn:ends-with($term,'Y')">
      <sx:fieldElementMap element="periodMultiplier">
        <sx:toString select="fn:substring-before($term,'Y')"/>
      </sx:fieldElementMap>
      <period>Y</period>
    </sx:when>
  </sx:choose>

  <!-- Expand the "fpml-period-from-term" sx:choose element  
    someplace in an sx:recordMapping block where literal
    content is allowed

  <calculationPeriodFrequency>
    <sx:parameter name="term" value="{calculation_period}"/>
    <sx:choose ref="fpml-period-from-term"/>
  </calculationPeriodFrequency> 

The output of this sx:choose element depends on the value of the field calculation_period. If for a particular record the value of the field is "6M", the element expands to

      <periodMultiplier>6</periodMultiplier>
      <period>M</period>

  <sx:service id="post-book-order">
    <sx:serialize>
      <sx:transform>
         <sx:content ref="myns:book-order"/>
         <sx:xslt ref="myns:confirm-order"/>
      </sx:transform>
      <sx:onError>
        <sx:transform>
          <sx:xslt ref="myns:book-order"/>
        </sx:transform>
      </sx:onError>
    </sx:serialize>
  </sx:service>

  <sx:service id="books">
    <sx:serialize>
      <sx:transform>
        <sx:content ref="myns:books"/>
        <sx:xslt ref="myns:books"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

In this example, you have an input record with a field service_from_date, which has the value

2005-06-28 00:00:00 

You want to change it to

20050628

You can make the replacement with the sx:findAndReplace element as follows.

  <sx:findAndReplace searchFor="([0-9]{4})-([0-9]{2})-([0-9]{2})(.*)" replaceWith="$1$2$3">      
    <sx:toString value="{service_from_date}"/> 
  </sx:findAndReplace> 

In this example, you have an input record with a field PLAN_IT_COST, which has the value

2,500,300.00

You want to change it to

2500300.00

You can make the replacement with the sx:findAndReplace element as follows.

  <sx:findAndReplace searchFor="," replaceWith ="">
    <sx:toString value="{PLAN_IT_COST}"/>
  </sx:findAndReplace>

  <sx:positionalField name="price2" width="10" justify="right" label="Price">
    <sx:defaultValue>
      <sx:findAndReplace searchFor ="." replaceWith="," useRegex="false">
        <sx:toString value="{price}"/>    
      </sx:findAndReplace>
    </sx:defaultValue>
  </sx:positionalField>

  

The example below executes the shell command request.exe -request request.xml, reads its standard output, and writes it to an XML file.

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:service id="request">
    <sx:serialize>
      <sx:parameter name="request" value="trade-query.xml"/>
      <sx:xsltSerializer>
          <sx:outputProperty name="indent" value="yes" />
      </sx:xsltSerializer>
      <sx:document>
        <sx:commandSource directory="/WorkingDirectory">
          <sx:envVariable name="ENV_VAR" value="value1"/>
          <sx:command>request.exe</sx:command>
          <sx:commandArg>-request</sx:commandArg>
          <sx:commandArg><sx:toString value="$request"/></sx:commandArg>
        </sx:commandSource>
      </sx:document>
    </sx:serialize>
  </sx:service>

</sx:resources>

<sx:resources xmlns:sx="http://www.servingxml.com/core">
  
  <sx:service id="books">
    <sx:serialize>
      <sx:xsltSerializer>
        <sx:fileSink file="books.xml"/>
      </sx:xsltSerializer>
      <sx:transform>
        <sx:content ref="books"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>
  
  <sx:document id="books">
    <sx:urlSource url="documents/books.xml"/>
  </sx:document>
  
</sx:resources>

<sx:resources xmlns:sx="http://www.servingxml.com/core">
  
  <sx:service id="books">
    <sx:serialize>
      <sx:transform>
        <sx:document>
          <sx:fileSource file="books.xml"/>
        </sx:document>
      </sx:transform>
    </sx:serialize>
  </sx:service>
  
</sx:resources>

  <sx:flatFileReader id="csv-file-reader">
    <sx:inlineSource>field1,field2
      value1,value2
      value1,value2</sx:inlineSource>
    <sx:fieldDelimiter value=","/>
  </sx:flatFileReader>

<sx:resources xmlns:sx="http://www.servingxml.com/core">
  
  <sx:service id="books">
    <sx:serialize>
      <sx:transform>
        <sx:document>
          <sx:urlSource url="books.xml"/>
        </sx:document>
      </sx:transform>
    </sx:serialize>
  </sx:service>
  
</sx:resources>

  <sx:transform>
    <sx:document ref="t:transaction"/>
    <sx:subtreeFilter path="/transaction/R04">
      <sx:assert test="count(//*) mod 2 = 0">Expected even number of elements. 
      </sx:assert> 
    </sx:subtreeFilter>
  </sx:transform>

              
    <sx:serialize>
      <sx:transform>
        <sx:content ref="countries"/>
      </sx:transform>
      <sx:batchedSerializer path="country" batchSize="50">
        <sx:xsltSerializer>
          <sx:fileSink file="output/countries-{$sx:batchSequenceNumber}.xml"/>
        </sx:xsltSerializer>
      </sx:batchedSerializer>
    </sx:serialize>

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:service id="books">
    <sx:serialize>
      <sx:transform>
        <sx:content ref="books"/>
        <sx:xslt ref="books"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

  <sx:dynamicContent name="books" class="samples.books.BookCatalog">
    <sx:key>
      <sx:keyField name="category"/>
    </sx:key>
  </sx:dynamicContent>

</sx:resources>

  <sx:customSerializer id="fop-serializer"
                    class="com.servingxml.extensions.fop.xmlpipeline.FopEmitter">
  </sx:customSerializer>

  <sx:service id="pulp">
    <sx:serialize>
      <sx:saxSink ref="myns:fop-serializer"/>
      <sx:transform>
        <sx:content ref="myns:pulp"/>
        <sx:xslt ref="myns:novel-fo"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:document id="countries">
    <sx:urlSource url="documents/countries.xml"/>
  </sx:document>

</sx:resources>

This example uses an sx:directoryReader element to read the names of the files in a directory called "data", and an sx:document element to load each of the files.

<sx:documentSequence wrapWith="documents">
  <sx:directoryReader directory="data"/>
  <sx:document>
      <sx:fileSource directory="{parentDirectory}" file="{name}"/>
  </sx:document>
</sx:documentSequence>

Note that an sx:recordStream element is also subtitutable for a sx:recordReader, which allows additional filtering on the contents of the file system. An sx:transform element is likewise subtitutable for a sx:content, which allows additional transformation and validation of the individual documents.

<sx:documentSequence wrapWith="documents">
  <sx:recordStream>
    <sx:directoryReader directory="data"/>
    <sx:restrictRecordFilter>
      <sx:fieldRestriction field="name" pattern="countries.*[.]xml"/>
    </sx:restrictRecordFilter>
  </sx:recordStream>
  <sx:transform>
    <sx:document>
      <sx:fileSource directory="{parentDirectory}" file="{name}"/>
    </sx:document>
    <msv:schemaValidator>
      <sx:urlSource url="data/countries.xsd"/>
    </msv:schemaValidator>
  </sx:transform>
</sx:documentSequence>

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:dynamicContent name="books" class="samples.books.BookCatalog">
    <sx:key>
      <sx:keyField name="category"/>
    </sx:key>
  </sx:dynamicContent>

</sx:resources>

<sx:xsltSerializer> 
  <sx:outputProperty name="encoding" value="{$encodingParam}"/> 
  <sx:outputProperty name="indent" value="{$indentModeParam}"/> 
</sx:xsltSerializer> 

<sx:resources xmlns:sx="http://www.servingxml.com/core">
   
  <sx:service id="invoices"> 
    <sx:transform>
      <!-- Here we extract a document fragment from the SAX stream -->
      <sx:processSubtree path="/invoices/invoice">
         <sx:serialize>
            <!-- We initialize a parameter with an XPATH expression
                 applied to the document fragment -->
            <sx:parameter name="invoice-name" select="@id"/> 
            <sx:xsltSerializer>
              <sx:fileSink file="output/invoice{$invoice-name}.html"/>
            </sx:xsltSerializer>
            <sx:transform>
              <sx:xslt><sx:urlSource url="styles/invoice2html.xsl"/></sx:xslt> 
            </sx:transform>
         </sx:serialize>
      </sx:processSubtree>
    </sx:transform>
  </sx:service>

</sx:resources>

  <sx:recordContent id="countries">
    <sx:flatFileReader>
      <sx:urlSource url="books/countries.csv"/>
      <sx:flatFile>
        <sx:flatFileBody>
          <sx:flatRecordType name="country">
            <sx:fieldDelimiter value=","/> 
            <sx:delimitedField name="countryCode"/>
            <sx:delimitedField name="countryName"/>
          </sx:flatRecordType>
        </sx:flatFileBody>
      </sx:flatFile>
    </sx:recordReader>
      
    <sx:recordMapping>
      <countries>
        <sx:onRecord>
          <country>
            <sx:fieldAttributeMap attribute="countryCode" attribute="countryCode"/>
            <sx:fieldElementMap element="countryName" element="countryName"/>
          </country>  
        </sx:onRecord>
      </countries>
    </sx:recordMapping>  
    
  </sx:recordContent>

<sx:transform> 
  <sx:document/> 
  <sx:removeEmptyAttributes elements="*" attributes="*" exceptAttributes="fileNumber"/> 
</sx:transform> 

<sx:transform> 
  <sx:document/> 
  <sx:removeEmptyElements elements="date1 date2"/> 
</sx:transform> 

The example below shows a resources script that implements a SAX pipeline. PreFilter and PostFilter are the names of Java classes that implement the org.xml.sax.XMLFilter interface.

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:service id="myService">
    <sx:serialize>
      <sx:transform>
        <sx:document>
          <sx:urlSource url="documents/mixed-up.xml"/>
        </sx:document>
        <sx:saxFilter class="PreFilter"/>
        <sx:xslt>
          <sx:urlSource url="styles/filter.xsl"/>
        </sx:xslt>
        <sx:saxFilter class="PostFilter"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

</sx:resources>

<sx:resources xmlns:sx="http://www.servingxml.com/core">
  
  <sx:service id="pipeline">
    <sx:serialize>
      <sx:transform>
        <sx:document>
          <sx:saxReader class="MySaxReader"/>
        </sx:document>
        <sx:saxFilter class="PreFilter"/>
        <sx:xslt><sx:urlSource url="styles/filter.xsl"/></sx:xslt>
        <sx:saxFilter class="PostFilter"/>     
      </sx:transform>
    </sx:serialize>
  </sx:service>

</sx:resources>

  <sx:service id="books">
    <sx:serialize>
      <sx:transform>
        <sx:content ref="myns:books"/>
        <sx:xslt ref="myns:books"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

  <sx:wrap>
    <sx:xsltSerializer/>
    <envelope>
      <header>
        <sx:attribute name="mode" value="xml"/>
        <creationDate>
          <sx:currentDateTime/>
        </creationDate>
      </header>
      <body>
        <myns:books xmlns:myns="http://mycompany.com/mynames/"
                    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                    xsi:schemaLocation="url2">
          <!-- Content to be wrapped -->
          <sx:transform>
            <sx:document/>
            <sx:processSubtree path="/myns:books/myns:book">
              <sx:choose>
                <sx:when test="@categoryCode='F'">
                  <sx:transform/>
                </sx:when>
              </sx:choose>
            </sx:processSubtree>
          </sx:transform>
        </myns:books>
      </body>
      <trailer>This is a trailer element</trailer>
    </envelope>
  </sx:wrap>

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:xslt id="books">
    <sx:urlSource url="books/books.xsl"/>
  </sx:xslt>

</sx:resources>

<sx:resources xmlns:sx="http://www.servingxml.com/core">
  
  <sx:service id="books">
    <sx:serialize>
      <sx:transform>
        <sx:content ref="books"/>
        <sx:xslt ref="books"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

  <sx:document id="books">
    <sx:urlSource url="documents/books.xml"/>
  </sx:document>
  
  <sx:xslt id="books">
    <!--sx:parameter name="category"><sx:defaultValue>F</sx:defaultValue></sx:parameter-->
    <sx:withParameters parameters="category"/>
    <sx:urlSource url="styles/books.xsl"/>
  </sx:xslt>

</sx:resources>

<sx:resources xmlns:sx="http://www.servingxml.com/core">
              
  <sx:service id="myPipeline">
    <sx:serialize>
      <sx:transform>
        <sx:document><sx:fileSource file="input.xml"/></document>        
        <sx:xslt><sx:urlSource url="filter.xsl"/></sx:xslt>
      </sx:transform>
      <sx:xsltSerializer>
        <sx:fileSink file="output.xml"/>
        <sx:outputProperty name="indent" value="yes"/>
      </sx:xsltSerializer>
    </sx:serialize>
  </sx:service>
  
</sx:resources>

<sx:restrictRecordFilter>  
  <sx:and>
    <sx:recordRestriction recordType="claim_detail"/>  
    <sx:fieldRestriction field="valid" pattern="y"/>  
  </sx:and>
</sx:restrictRecordFilter> 

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:service id="countries">
    <sx:recordStream>
      <sx:flatFileReader>
        <sx:fileSource file="data/countries.csv"/>
        <sx:flatFile ref="countriesFile"/>
      </sx:flatFileReader>
      <sx:batchRecords batchSize="50"/>
      <sx:flatFileWriter>
        <sx:fileSink file="output/countries-{$sx:batchSequenceNumber}.csv"/>
        <sx:flatFile ref="countriesFile"/>
      </sx:flatFileWriter>
    </sx:recordStream>
  </sx:service>

  <sx:flatFile id="countriesFile">
    <sx:commentStarter value="#"/>
    <sx:flatFileBody>
      <sx:flatRecordType name="country">
        <sx:fieldDelimiter value=","/>
        <sx:delimitedField name="code"/>
        <sx:delimitedField name="name" trimLeading="true"/>
      </sx:flatRecordType>
    </sx:flatFileBody>
  </sx:flatFile>

</sx:resources>

  <sx:service id="countries">
    <sx:recordStream>
      <sx:flatFileReader>
        <sx:fileSource file="data/{$rootName}.csv"/>
        <sx:flatFile ref="my-input-file-layout"/>
      </sx:flatFileReader>
      <sx:batchedRecordWriter batchSize="50">
        <sx:flatFileWriter>
          <sx:fileSink file="output/{$rootName}-{$sx:batchSequenceNumber}.csv"/>
          <sx:flatFile ref="my-output-file-layout"/>
        </sx:flatFileWriter>
      </sx:batchedRecordWriter>
    </sx:recordStream>
  </sx:service>

The input is three records of record type "orderRemarks",

The XML representation of the "orderRemarks" records is

<orderRemarks><REMTEI>REM</REMTEI><REM>AAAA</REM></orderRemarks> 
<orderRemarks><REMTEI>REM</REMTEI><REM>BBBB</REM></orderRemarks> 
<orderRemarks><REMTEI>REM</REMTEI><REM>CCCC</REM></orderRemarks> 

The sx:combineRecords element below composes the three input records into a composite record with record type "composite", and with a repeating group field "detail" that contains the three original records. It creates a new field "remarks" whose value is calculated from the original records.

    <sx:combineRecords recordType="composite" repeatingGroup="detail"
                startTest="sx:current/orderRemarks"
                endTest="not(sx:current/orderRemarks)">
      <sx:newField name="remarks" select="detail/orderRemarks/REM"/>
    </sx:combineRecords>

The output is the composite record.

<composite> 
  <detail> 
    <orderRemarks><REMTEI>REM</REMTEI><REM>AAAA</REM></orderRemarks> 
    <orderRemarks><REMTEI>REM</REMTEI><REM>BBBB</REM></orderRemarks> 
    <orderRemarks><REMTEI>REM</REMTEI><REM>CCCC</REM></orderRemarks> 
  </detail> 
  <remarks>AAAA BBBB CCCC</remarks> 
</composite> 

The example below shows a fragment of a resources script that uses a record filter. HotRecordFilter is the names of a Java class that extends the com.servingxml.components.recordio.AbstractRecordFilter class, which provides a default implementation of the com.servingxml.components.recordio.RecordFilter interface.

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:recordContent id="hot">
    <sx:flatFileReader>
      <sx:flatFile ref="hotFlatFile"/>
      <sx:customRecordFilter class="HotRecordFilter"/>
    </sx:flatFileReader> ...
    
  </sx:recordContent> 

  <sx:flatFile id="hotFlatFile">
    <sx:flatFileBody>
      <sx:flatRecordTypeChoice>
        <sx:positionalField name="record-type" width="5"/>
        <sx:when  test="record-type='BKP84'">
          <sx:flatRecordType name="bkp84">
            <sx:positionalField name="record-type-prefix"  width="3"/>
            <sx:positionalField name="record-type"  start="1" width="5"/>
            <sx:positionalField name="value" width="7"/>
            <sx:positionalField name="amount" width="2"/>
            <sx:positionalField name="currency" width="3"/>
            <sx:positionalField name="precision" width="1"/>
          </sx:flatRecordType>
        </sx:when>
        <sx:when test="record-type='BKT06'"> ...
        
      </sx:flatRecordTypeChoice>
    </sx:flatFileBody>
  </sx:flatFile> ...

</sx:resources>  

The HotRecordFilter class is implemented as shown below. The class needs to be compiled and put in the classpath where the framework can find it, for example, by adding it to the target\servingxml\classes directory.

import com.servingxml.app.Flow;
import com.servingxml.app.ServiceContext;
import com.servingxml.components.recordio.AbstractRecordFilter;
import com.servingxml.util.Name;
import com.servingxml.util.QualifiedName;
import com.servingxml.util.record.Record;
import com.servingxml.util.record.RecordBuilder;
import com.servingxml.util.ServingXmlException;

public class HotRecordFilter extends AbstractRecordFilter {
  private static final Name BKP84_RECORD_TYPE = new QualifiedName("bkp84");
  private static final Name AMOUNT_NAME = new QualifiedName("amount");
  private static final Name PRECISION_NAME = new QualifiedName("precision");
  private static final Name CALCULATED_AMOUNT_NAME = new QualifiedName("calculatedAmount");
  
  public void writeRecord(ServiceContext context, Flow flow) 
   {

    Record record = flow.getRecord();
    Flow newFlow = flow;
    if (record.getRecordType().getName().equals(BKP84_RECORD_TYPE)) {
      RecordBuilder recordBuilder = new RecordBuilder(record);
      String amountString = record.getString(AMOUNT_NAME);
      if (amountString == null) {
        throw new ServingXmlException("amount is NULL");
      }
      String precisionString = record.getString(PRECISION_NAME);
      if (precisionString == null) {
        throw new ServingXmlException("precision is NULL");
      }
      int amount = Integer.parseInt(amountString,16);
      int precision = Integer.parseInt(precisionString);
      double calculatedAmount = (double)amount/Math.pow(10.0,(double)precision);
      recordBuilder.setDouble(CALCULATED_AMOUNT_NAME,calculatedAmount);
      record = recordBuilder.toRecord();
      newFlow = flow.replaceRecord(context, record);
    }

    super.writeRecord(context, newFlow);
  }
}

The example below shows a resources script that uses a record reader. TradeRecordFilter is the names of a Java class that extends the com.servingxml.components.recordio.AbstractRecordReader class, which provides a default implementation of the com.servingxml.components.recordio.RecordReader interface.

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:service id="trades">
    <sx:serialize>
      <sx:transform>
        <sx:content ref="trades"/>
      </sx:transform>
    </sx:serialize>
  </sx:service>

  <sx:recordContent id="trades">
    <sx:customRecordReader class="TradeRecordReader"/>
    <sx:recordMapping ...
  </sx:recordContent>

</sx:resources>

The TradeRecordReader class is implemented as shown below. The class needs to be compiled and put in the classpath where the framework can find it, for example, by adding it to the target\servingxml\classes directory.

import com.servingxml.app.ServiceContext;
import com.servingxml.components.recordio.AbstractRecordReader;
import com.servingxml.app.Flow;
import com.servingxml.util.Name;
import com.servingxml.util.QualifiedName;
import com.servingxml.util.ServingXmlException;
import com.servingxml.util.record.Record;
import com.servingxml.util.record.RecordBuilder;

public class TradeRecordReader extends AbstractRecordReader {
  private static final Name TRADE_RECORD_TYPE = new QualifiedName("trade");
  private static final Name TRANSACTION_RECORD_TYPE = new QualifiedName("transaction");
  private static final Name RECORD_TYPE_NAME = new QualifiedName("record_type");
  private static final Name ID_NAME = new QualifiedName("id");
  private static final Name TRADE_DATE_NAME = new QualifiedName("trade_date");
  private static final Name TRADE_TIME_NAME = new QualifiedName("trade_time");
  private static final Name DESCRIPTION_NAME = new QualifiedName("description");
  private static final Name REFERENCE_NAME = new QualifiedName("reference");
  
  public void readRecords(ServiceContext context, Flow flow) 
   {

    //  Start the record stream
    startRecordStream(context, flow);

    RecordBuilder trRecordBuilder = new RecordBuilder(TRADE_RECORD_TYPE);
    RecordBuilder tnRecordBuilder = new RecordBuilder(TRANSACTION_RECORD_TYPE);

    Record record;

    trRecordBuilder.setString(RECORD_TYPE_NAME,"TR");
    trRecordBuilder.setString(ID_NAME,"0001");
    trRecordBuilder.setString(TRADE_DATE_NAME,"03/25/2005");
    trRecordBuilder.setString(TRADE_TIME_NAME,"01:50:00");
    trRecordBuilder.setString(DESCRIPTION_NAME,"This is a trade record");
    record = trRecordBuilder.toRecord();
    trRecordBuilder.clear();

    //  Write the "trade" record
    writeRecord(context, flow, record);

    tnRecordBuilder.setString(RECORD_TYPE_NAME,"TN");
    tnRecordBuilder.setString(ID_NAME,"0002");
    tnRecordBuilder.setString(REFERENCE_NAME,"X1234");
    tnRecordBuilder.setString(DESCRIPTION_NAME,"A child transaction");
    record = tnRecordBuilder.toRecord();   
    tnRecordBuilder.clear();

    //  Write the first "transaction" record
    writeRecord(context, flow, record);

    tnRecordBuilder.setString(RECORD_TYPE_NAME,"TN");
    tnRecordBuilder.setString(ID_NAME,"0003");
    tnRecordBuilder.setString(REFERENCE_NAME,"X1235");
    tnRecordBuilder.setString(DESCRIPTION_NAME,"Another child transaction");
    record = tnRecordBuilder.toRecord();
    tnRecordBuilder.clear();

    //  Write the second "transaction" record
    writeRecord(context, flow, record);

    //  End the record stream
    endRecordStream(context, flow);
  }
}                              

  <sx:recordStream>
    <sx:flatFileReader>
      <sx:urlSource url="data/countriesWithDiscards.csv"/>
      <sx:flatFile ref="countriesFile"/>
    </sx:flatFileReader>
    <msv:recordValidator>
      <sx:urlSource url="data/country-record.xsd"/>
    </msv:recordValidator>
    <sx:discardHandler>
      <sx:log message="{$sx:message}"/>
      <sx:modifyRecord>
        <sx:newField name="message" value="{$sx:message}"/>
      </sx:modifyRecord>
      <sx:flatFileWriter>
        <sx:fileSink file="output/countryDiscards.csv"/>
        <sx:flatFile ref="discardFile"/>
      </sx:flatFileWriter>
    </sx:discardHandler>
  </sx:recordStream>

<sx:restrictRecordFilter>  
  <sx:and>
    <sx:or>
      <sx:recordRestriction recordType="claim_detail"/>  
      <sx:recordRestriction recordType="expense_detail"/>  
    </sx:or>
    <sx:fieldRestriction field="valid" match="y"/>  
  </sx:and>
</sx:restrictRecordFilter> 

<sx:resources xmlns:sx="http://www.servingxml.com/core">

  <sx:service id="updateEmployee">
    <sx:recordStream>
      <sx:parameterReader recordType="employee"/>
      <sx:sqlWriter>
        <sx:sqlConnectionPool ref="jdbcPool"/>
        <sx:sqlUpdate>
          UPDATE EMP SET JOB = '{$job}' WHERE EMPNO='{$empNo}'
        </sx:sqlUpdate>
      </sx:sqlWriter>
    </sx:recordStream>
  </sx:service>
  
  <sx:sqlConnectionPool id="jdbcPool"
                        driver="oracle.jdbc.driver.OracleDriver"
                        databaseUrl="jdbc:oracle:thin:@127.0.0.1:1521:dev"
                        user="scott"
                        password="spring"
                        minConnections="2"
                        testStatement="SELECT * FROM DUAL"/>

</sx:resources>

  <sx:quoteSymbol character='"' escapeCharacter="\"/>

  <sx:quoteSymbol character="'" escapeSequence="&quot;"/>