Execute the insert() method. Assign a value to a field.
Insert the row by calling insertRow()
This example inserts an employee record.
package prjJDBC_JCDjcdALL;
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,
com.stc.connector.appconn.file.FileApplication FileClient_1,
dtd.otdInputDTD_1394195520.DBemployees otdInputDTD_DBemployees_1,
dtd.otdOutputDTD882991309.DBemployee otdOutputDTD_DBemployee_1,
otdJDBC.OtdJDBCOTD otdJDBC_1 )
throws Throwable
{
FileClient_1.setText( "Inserting records into db_employee table .." );
FileClient_1.write();
otdInputDTD_DBemployees_1.unmarshalFromString( input.getText() );
for (int i1 = 0; i1 < otdInputDTD_DBemployees_1.countX_sequence_A(); i1 += 1) {
otdJDBC_1.getInsert_Ps().setEmp_no( typeConverter.stringToShort(
otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).getEmpNo(), "#", false, 0 ) );
otdJDBC_1.getInsert_Ps().setLast_name(
otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).getLastname() );
otdJDBC_1.getInsert_Ps().setFirst_name(
otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).getFirstname() );
otdJDBC_1.getInsert_Ps().setRate(
new java.math.BigDecimal( otdInputDTD_DBemployees_1.getX_sequence_A( i1 ).
getRate() ) ); otdJDBC_1.getInsert_Ps().setLast_update(
typeConverter.stringToSQLDate( otdInputDTD_DBemployees_1.
getX_sequence_A( i1 ).getLastDate(), "yyyy-MM-dd hh:mm:ss", false, "" ) );
otdJDBC_1.getInsert_Ps().executeUpdate();
}
FileClient_1.setText( "Done Insert." );
FileClient_1.write();
}
}
|