Chapter 60. Migrating CTL1 to CTL2

function transform(idx) {
     <other function body>
     $0.customer := $0.customer;
}

function integer transform(integer idx) {
     <other function body>
     $0.customer = $0.customer;
     return 0;
}

<record variable name> = @<port number>;

<record variable name>.* = $<port number>.*;

<record variable name> = @<metadata name>

<record variable name>.* = $<metadata name>.*;

@<port number>[<field number>]

$<port number>.<corresponding field name>

@<metadata name>[<field number>]

$<metadata name>.<corresponding field name>

<record variable name>["<field name>"]

<record variable name>.<field name>

write_dict(string <entry name>, string <entry value>);

dictionary.<entry name> = <entry value>;

dict_put_str(string <entry name>, string <entry value>);

string myVariable;
myVariable = read_dict(<entry name>);

string myVariable;
myVariable = dictionary.<entry name>;

string myVariable;
myVariable = dict_get_str(<entry name>);

//#CTL1

int myInt;
int myCase;

myCase = 1;

// Transforms input record into output record.
function transform() {

   myInt = random_int(0,1);

   switch(myInt) {
      case (myCase-1) : { print_err("two"); print_err("first case1"); }
      case (myCase) : { print_err("three"); print_err("second case1"); }			
   }

   $0.field1 := $0.field1;

   return 0
}

//#CTL2

integer myInt;

// Transforms input record into output record.
function integer transform() {

   myInt = randomInteger(0,1);

   switch(myInt) {
      case 0 : printErr("zero"); printErr("first case"); break;
      case 1 : printErr("one"); printErr("second case");			
   }

   $0.field1 = $0.field1;

   return 0;
}

//#CTL1

// Transforms input record into output record.
function transform() {
   $0.field1 := $0.field1;
   $0.field2 := $0.field2;
   $0.field3 := sequence(Sequence0).current;
   $0.field4 := sequence(Sequence0).next;
   $0.field5 := sequence(Sequence0, string).current;
   $0.field6 := sequence(Sequence0, string).next;
   $0.field7 := sequence(Sequence0, long).current;
   $0.field8 := sequence(Sequence0, long).next;

   return 0
}

//#CTL2

// Transforms input record into output record.
function integer transform() {
   $0.field1 = $0.field1;
   $0.field2 = $0.field2;
   $0.field3 = sequence(seqCTL2).current();
   $0.field4 = sequence(seqCTL2).next();
   $0.field5 = sequence(seqCTL2, string).current();
   $0.field6 = sequence(seqCTL2, string).next();
   $0.field7 = sequence(seqCTL2, long).current();
   $0.field8 = sequence(seqCTL2, long).next();

   return 0;
}

//#CTL1

// variable for storing number of duplicates
int count;
int startCount;

// values of fields of the first records
string Field1FirstRecord;
string Field2FirstRecord;

// values of fields of next records
string Field1NextRecord;
string Field2NextRecord;

// values of fields of the last records
string Field1Value;
string Field2Value;

// record with the same metadata as those of lookup table
record (Metadata0) myRecord;

// Transforms input record into output record.
function transform() {

   // getting the first record whose key value equals to $0.Field2
   // must be specified the value of both Field1 and Field2
   Field1FirstRecord = lookup(LookupTable0,$0.Field2).Field1;
   Field2FirstRecord = lookup(LookupTable0,$0.Field2).Field2;

   // if lookup table contains duplicate records with the value specified above
   // their number is returned by the following expression
   // and assigned to the count variable
   count = lookup_found(LookupTable0);

   // it is copied to another variable
   startCount = count;

   // loop for searching the last record in lookup table
   while ((count - 1) > 0) {

      // searching the next record with the key specified above
      Field1NextRecord = lookup_next(LookupTable0).Field1;
      Field2NextRecord = lookup_next(LookupTable0).Field2;

      // decrementing counter
      count--;
   }

   // if record had duplicates, otherwise the first record
   Field1Value = nvl(Field1NextRecord,Field1FirstRecord);
   Field2Value = nvl(Field2NextRecord,Field2FirstRecord);

   // mapping to the output
   // last record from lookup table
   $0.Field1 := Field1Value;
   $0.Field2 := Field2Value;

   // corresponding record from the edge
   $0.Field3 := $0.Field1;
   $0.Field4 := $0.Field2;

   // count of duplicate records
   $0.Field5 := startCount;

   return 0
}

//#CTL2

// record with the same metadata as those of lookup table
recordName1 myRecord;

// variable for storing number of duplicates
integer count;
integer startCount;

// Transforms input record into output record.
function integer transform() {

   // if lookup table contains duplicate records,
   // their number is returned by the following expression
   // and assigned to the count variable
   count = lookup(simpleLookup0).count($0.Field2);

   // This is copied to startCount
   startCount = count;

   // getting the first record whose key value equals to $0.Field2
   myRecord = lookup(simpleLookup0).get($0.Field2);

   // loop for searching the last record in lookup table
   while ((count-1) > 0) {

      // searching the next record with the key specified above
      myRecord = lookup(simpleLookup0).next();

      // decrementing counter
      count--;
   }

   // mapping to the output
   // last record from lookup table
   $0.Field1 = myRecord.Field1;
   $0.Field2 = myRecord.Field2;

   // corresponding record from the edge
   $0.Field3 = $0.Field1;
   $0.Field4 = $0.Field2;

   // count of duplicate records
   $0.Field5 = startCount;

   return 0;
}

   //#TL

   int retInt; 
   function transform() {	

         if ($0.field3 < 5) retInt = 0; else retInt = 1;

         // the following part is the mapping:
         $0.* := $0.*;
         $0.field1 := uppercase($0.field1);
         $1.* := $0.*;
         $1.field1 := uppercase($0.field1);	

         return retInt
   }

   //#CTL2

   integer retInt; 
   function integer transform() {	

         // the following part is the mapping:
         $0.* = $0.*;
         $0.field1 = upperCase($0.field1);
         $1.* = $0.*;
         $1.field1 = upperCase($0.field1);	

         if ($0.field3 < 5) return = 0; else return 1;
   }