The completed Java source code for the jcdInsert Collaboration appears as follows:
public class jcdInsert
{
public com.stc.codegen.logger.Logger logger;
public com.stc.codegen.alerter.Alerter alerter;
public com.stc.codegen.util.CollaborationContext collabContext;
public com.stc.codegen.util.TypeConverter typeConverter;
public void receive( com.stc.connector.appconn.file.FileTextMessage
input, dtd.otdInputDTD_746620588.DBemployees otdInputDTD_DBemployees_1,
otdSQLServer.OtdSQLServerOTD otdSQLServer_1, com.stc.connector.appconn.
file.FileApplication FileClient_1 )
throws Throwable
{
FileClient_1.setText( "Inserting records into db_employee table .." );
FileClient_1.write();
otdInputDTD_DBemployees_1.unmarshalFromString( input.getText() );
otdSQLServer_1.getDb_employee().insert();
for (int i1 = 0; i1 < otdInputDTD_DBemployees_1.countX_sequence_A(); i1 += 1) {
otdSQLServer_1.getDb_employee().setEMP_NO( Integer.parseInt
( otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).getEmpNo() ) );
otdSQLServer_1.getDb_employee().setLAST_NAME( otdInputDTD_DBemployees_1.
getX_sequence_A( i1 ).getLastname() );
otdSQLServer_1.getDb_employee().setFIRST_NAME( otdInputDTD_DBemployees_1.
getX_sequence_A( i1 ).getFirstname() );
otdSQLServer_1.getDb_employee().setRATE( Double.parseDouble
( otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).getRate() ) );
otdSQLServer_1.getDb_employee().setLAST_UPDATE( java.sql.Timestamp.valueOf
( otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).getLastDate() ) );
otdSQLServer_1.getDb_employee().insertRow();
}
FileClient_1.setText( "Done Insert." );
FileClient_1.write();
}
}
|
The above code has been wrapped for display purposes.