private void addCdcColSpecs(ArrayList<ColumnSpec> cdcSpecs,OneRowChange cdcRowChangeData){
  int cdcPos=cdcSpecs.size();
  if (cdcColumnsAtFront)   cdcPos=0;
  ColumnSpec spec=cdcRowChangeData.new ColumnSpec();
  spec.setIndex(cdcPos + 1);
  spec.setName("CDC_OP_TYPE");
  spec.setType(java.sql.Types.VARCHAR);
  spec.setLength(1);
  cdcSpecs.add(cdcPos,spec);
  spec=cdcRowChangeData.new ColumnSpec();
  spec.setIndex(cdcPos + 1 + 1);
  spec.setName("CDC_TIMESTAMP");
  spec.setType(java.sql.Types.TIMESTAMP);
  cdcSpecs.add(cdcPos + 1,spec);
  spec=cdcRowChangeData.new ColumnSpec();
  spec.setIndex(cdcPos + 1 + 2);
  spec.setName("CDC_SEQUENCE_NUMBER");
  spec.setType(java.sql.Types.BIGINT);
  cdcSpecs.add(cdcPos + 2,spec);
}

private void addCdcColSpecs ( ArrayList < ColumnSpec > cdcSpecs , OneRowChange cdcRowChangeData ) { int cdcPos = cdcSpecs . size ( ) ; if ( cdcColumnsAtFront ) cdcPos = 0 ; ColumnSpec spec = cdcRowChangeData . new ColumnSpec ( ) ; spec . setIndex ( cdcPos + 1 ) ; spec . setName ( "CDC_OP_TYPE" ) ; spec . setType ( java . sql . Types . VARCHAR ) ; spec . setLength ( 1 ) ; cdcSpecs . add ( cdcPos , spec ) ; spec = cdcRowChangeData . new ColumnSpec ( ) ; spec . setIndex ( cdcPos + 1 + 1 ) ; spec . setName ( "CDC_TIMESTAMP" ) ; spec . setType ( java . sql . Types . TIMESTAMP ) ; cdcSpecs . add ( cdcPos + 1 , spec ) ; spec = cdcRowChangeData . new ColumnSpec ( ) ; spec . setIndex ( cdcPos + 1 + 2 ) ; spec . setName ( "CDC_SEQUENCE_NUMBER" ) ; spec . setType ( java . sql . Types . BIGINT ) ; cdcSpecs . add ( cdcPos + 2 , spec ) ; }
add cdc column specifications .
