Program – 2

Program – 2

Client

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class client

{

                public static void main(String a[]) throws Exception

                {

                                Socket S1=new Socket(InetAddress.getLocalHost(),7000);

                                System.out.println("Connected with Server1");

                                DataInputStream DIS = new DataInputStream(System.in);

                                DataInputStream DS1 = new DataInputStream(S1.getInputStream());

                                PrintStream PS = new PrintStream(S1.getOutputStream());

                                System.out.print("Enter Cell no : ");

                                String k1=DIS.readLine();

                                PS.println(k1.trim());

                                String res = DS1.readLine();

                                StringTokenizerStt =new StringTokenizer(res,"#");

                                while(Stt.hasMoreTokens())

                                {

                                                String temp=Stt.nextToken();

                                                System.out.println(temp);

                                }

                }

}

Server-1

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

importjava.lang.*;

class server1

{

                public static void main(String a[]) throws Exception

                {

                                String ans="",total = ""; booleanchk=true;

                                System.out.println("Waiting for Client1...");

                                ServerSocket SS1 = new ServerSocket(7000);

                                Socket S1 =SS1.accept();

                                System.out.println("client Connected");

                                DataInputStream DIS1 = new DataInputStream(S1.getInputStream());

                                PrintStream PS1 = new PrintStream(S1.getOutputStream());

                                String cellno = DIS1.readLine();

                                String firstpart = cellno.substring(0,5);

                                String secondpart = cellno.substring(5,10);

                                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                                Connection con=DriverManager.getConnection("Jdbc:Odbc:cellfull","","");

                                Statement stat = con.createStatement();

                                String query = "Select company from cellcomp where compid = '"+firstpart+"'";

                                ResultSetrs = stat.executeQuery(query);

                                while(rs.next())

                                ans =rs.getString(1);

                                if(ans!="")

                                total=" Connection is " +ans+"#";

                                elsechk= false;

                                rs.close();

                               

                                query = "Select uname  from cellhalf where cellcode = '"+secondpart+"'";

                                rs = stat.executeQuery(query);

                                while(rs.next())

                                ans =rs.getString(1);

                                if(ans!="")

{

                                                total=total+" User name is " +ans+"#";

                                                System.out.print(total);}

                                                elsechk = false;

                                                rs.close();

                                                stat.close();

                                                con.close();

                                if (!chk)

                                {

                                Socket S2=new Socket(InetAddress.getLocalHost(),7777);

                                System.out.println("Connected with Server2");

                                DataInputStream DS2 = new DataInputStream(S2.getInputStream());

                                PrintStream PS2 = new PrintStream(S2.getOutputStream());

                                PS2.println(cellno);

                                PS1.println(DS2.readLine());

                                }

                                PS1.println(total);

                }

}

Server-2

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class server2

{

                public static void main(String a[]) throws Exception

                {

                                String ans="";

                                System.out.println("Waiting for Server1...");

                                ServerSocket SS2 = new ServerSocket(7777);

                                Socket S2 =SS2.accept();

                                System.out.println("Server1 Connected");

                                DataInputStream DIS2 = new DataInputStream(S2.getInputStream());

                                PrintStream PS2 = new PrintStream(S2.getOutputStream());

                                String inp = DIS2.readLine();

                                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                                Connection con=DriverManager.getConnection("Jdbc:Odbc:cellfull","","");

                                Statement stat = con.createStatement();

                                String query = "Select user from celltable where cellno = '"+inp+"'";

                                ResultSetrs = stat.executeQuery(query);

                                while(rs.next())

                                ans =rs.getString(1);

                                if(ans!=""){

                                PS2.println("Username for  "+inp+"  is "+ans);

                                }

                                else PS2.println("Record Not Found");                           

                                rs.close();

                                stat.close();

                                con.close();

                }

}