Using Database Operations

The Insert Operation

ProcedureTo perform an insert operation on a table:

  1. Execute the insert() method. Assign a value to a field.

  2. 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();
        }
    
    }