servlets & RMI

[Anonymous]

How to access database in remote server through a request to servlet page?(Servlets+RMI)Anybody pls help me with coding!!!1

[Ajan Balakrishnan]

This is sample code i used for testing. I think this will give you a basic idea of how these things work. You can modify the code to suit your need
Interface Code

package com.ooiq;
public interface EMDataInsert extends java.rmi.Remote
{
public void setData(String a, String b, String c, String d) throws java.rmi.RemoteException;
}

RMI Client Code

package com.ooiq;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.net.MalformedURLException;
import java.rmi.NotBoundException;
public class EMDataInsertClient
{
/**
 * EMDataInsert constructor comment.
 */
public EMDataInsertClient() 
{

}
/**
 * Starts the application.
 * @param args an array of command-line arguments
 */
public static void main(java.lang.String[] args)
{
// Insert code to start the application here.

String machineName = args[0].trim().toUpperCase();
String componentName = args[1].trim().toUpperCase();
String dateTs = args[3].trim();
String timeTs = args[4].trim();
String status = args[2];
String stampTsDB2 = "";
String yearTs = "";

if(Integer.parseInt(dateTs.substring(6)) > 70)
 yearTs = "19" + dateTs.substring(6);
else
yearTs = "20" + dateTs.substring(6);  

stampTsDB2 = yearTs + "-" + dateTs.substring(0,2) + "-" + dateTs.substring(3,5);   
stampTsDB2 = stampTsDB2 + "-"+ timeTs.substring(0,2) + "." + timeTs.substring(3,5); 
stampTsDB2 = stampTsDB2 + "." + timeTs.substring(6) + "." + "000000";

try 
{
EMDataInsert e = (EMDataInsert)Naming.lookup("rmi://abalakri/EMDataInsert");
e.setData(machineName, componentName, stampTsDB2, status);

}
catch (MalformedURLException e)
{
System.out.println("MalformedURLException :" + e.getMessage());
}
catch (RemoteException e)
{
System.out.println("RemoteException :" + e.getMessage());
}
catch (NotBoundException e)
{
System.out.println("NotBoundException :" + e.getMessage());
}


}

}

Implentation Code. Here is where you can make your database calls.

package com.ooiq;
import java.sql.*;
public class EMDataInsertImpl extends java.rmi.server.UnicastRemoteObject implements EMDataInsert 
{
public static final String defaultDB2Ts = "9999-12-31-00.00.00.000000";
/**
 * EMDataInsert constructor comment.
 */
public EMDataInsertImpl() throws java.rmi.RemoteException
{
System.out.println("EMDataInsertImpl");
}
public void setData(String machineName, String componentName, String stampTsDB2, String status) throws java.rmi.RemoteException
{
int componentId = 0;
Connection connection = null;
System.out.println(machineName+","+componentName+","+stampTsDB2+"," + status);

try
{
connection = new ooiq.dev.UDBConnection().getConnection();
}
catch(Exception e)
{
System.out.println(e.getMessage());
}

ooiq.dev.TmachineCmpntBean mcb = new ooiq.dev.TmachineCmpntBean(connection);
mcb.setComponentName(componentName);
mcb.setMachineName(machineName);

ooiq.dev.TOutageLogBean olb = new ooiq.dev.TOutageLogBean(connection);

try
{
mcb.findByPrimaryKey();
componentId = mcb.getComponentId();

if (status.equalsIgnoreCase("DOWN")) 
{

olb.setComponentId(componentId);
olb.setDownTime(stampTsDB2);
olb.setUpTime(defaultDB2Ts);
olb.add();

}
else
{
olb.setComponentId(componentId);
olb.setUpTime(stampTsDB2);
olb.update();

}
}
catch(SQLException e)
{
System.out.println(e.getMessage());
}
catch(Exception e)
{
System.out.println(e.getMessage());
}
}

 
}

RMI server

package com.ooiq;
import java.rmi.Naming;
public class EMDataInsertServer
{
/**
 * EMDataInsert constructor comment.
 */
 
public EMDataInsertServer() 
{
 try
 {
   EMDataInsertImpl edi = new EMDataInsertImpl();
   Naming.rebind("rmi://abalakri:1099/EMDataInsert", edi);
 } 
 catch (Exception e)
 {
   System.out.println("Trouble: " + e);
 }
}
 
  
/**
 * Starts the application.
 * @param args an array of command-line arguments
 */
public static void main(java.lang.String[] args)
{
// Insert code to start the application here.

 new EMDataInsertServer();

}
}

FYI, UDBConnection,TmachineCmpntBean,TOutageLogBean are my connection and DB query beans
Let me know if this helps
Thanks
Ajan

[This message has been edited by Ajan Balakrishnan (edited March 15, 2001).]