transactionimpl.java

一个不错的corba实例

package Bank;

import java.sql.*;
import org.omg.CORBA.ORB;
import org.omg.CosNaming.*;

public class TransactionImpl extends _TransactionImplBase implements Transaction
{
  static int transactionId = 11;
  String name;
  public String updateDetails (String counterId, String date, double amountDebit, double amountCredit, String accountId)
  {
      try{
          transactionId += 1;
          String str = "TD000" + transactionId;
          Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
          Connection con = DriverManager.getConnection("jdbc:odbc:MyDataSource","faculty","");
          PreparedStatement st = con.prepareStatement("insert into counter_transaction  values(?,?,?,?,?,?)");
          st.setString(1,str);
          st.setString(2,counterId);
          st.setString(3,accountId);
          st.setString(4,date);
          st.setDouble(5,amountDebit);
          st.setDouble(6,amountCredit);
          st.executeUpdate();
     }
      catch(Exception e)
      {
	System.out.println(e);
      }   
      return "Operation successful";
  }
   public static void main(String args[])
   {
        try{
             ORB orb = ORB.init(args,null);
             TransactionImpl transaction = new TransactionImpl();
             orb.connect(transaction);
             org.omg.CORBA.Object  obj = orb.resolve_initial_references("NameService");
             NamingContext namingContext = NamingContextHelper.narrow(obj);
             NameComponent nameComponent = new NameComponent("Bank","");
             NameComponent path[] = {nameComponent};
             System.out.println(path+":" + nameComponent);
             namingContext.rebind(path,transaction);
             
             Object waitForCall = new Object();
             synchronized(waitForCall)
             {
	waitForCall.wait();
              }             
        }
        catch(Exception e)
        {
	System.out.println(e);
         }
   }
}