Program – 4

Program – 4

Client

import java.io.*;

import java.net.*;

class cli

{

public static void main(String ar[])

   {

try

   {

    Socket s=new Socket("localhost",7777);

DataInputStream in=new DataInputStream(System.in);

PrintStream p=new PrintStream(s.getOutputStream());

DataInputStream din=new DataInputStream(s.getInputStream());

    String str,str1;

System.out.println("Enter 6 digit Account Number");

str=in.readLine();

p.println(str);

System.out.println("====Server Reply=====");

    str1=din.readLine();

System.out.println(str1);

   }

catch(Exception e)

   {

System.out.println(e);

   }

  }

}

Server-1

import java.io.*;

import java.net.*;

importjava.sql.*;

class ser1

{

public static void main(String ar[])

   {

try

   {

ServerSocketss=new ServerSocket(7777);

     Socket s=ss.accept();

DataInputStream din=new DataInputStream(s.getInputStream());

PrintStream p=new PrintStream(s.getOutputStream());

     String str,str1="",str2;

str=din.readLine();

System.out.println(str);

int flag=0;

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

     Connection con=DriverManager.getConnection("jdbc:odbc:db1");

     Statement smt=con.createStatement();

ResultSetrs=smt.executeQuery("select * from lab71 where AccuntNo="+str+"");

while(rs.next())

     {

     str1=rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3);

flag=1;

     }

if(flag==1)

     {

System.out.println("Record Found");

p.println(str1);

     }

else

      {

       Socket s1=new Socket("localhost",7771);

PrintStream p1=new PrintStream(s1.getOutputStream());

DataInputStream din1=new DataInputStream(s1.getInputStream());

System.out.println("Record is Not Available in server1.So Account Number sending to server2");

p1.println(str);

       str2=din1.readLine();

System.out.println(str2);

p.println(str2);

      }

   }

catch(Exception e)

   {

System.out.println(e);

   }

 }

}

Server-2

import java.io.*;

import java.net.*;

importjava.sql.*;

class ser2

{

public static void main(String ar[])

  {

try

     {

ServerSocketss=new ServerSocket(7771);

       Socket s=ss.accept();

DataInputStream din=new DataInputStream(s.getInputStream());

PrintStream p=new PrintStream(s.getOutputStream());

       String str,str1="",str2="";

str=din.readLine();

System.out.println(str);

int flag=0;

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

       Connection con=DriverManager.getConnection("jdbc:odbc:db2");

       Statement smt=con.createStatement();

ResultSetrs=smt.executeQuery("select * from lab72 where AccuntNo="+str+"");

while(rs.next())

       {

         str1=rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3);

flag=1;

       }

if(flag==1)

       {

System.out.println("Record Found In server2");

p.println(str1);

       }

else

       {

System.out.println("Record Also not Found in Server2");

p.println("Record Also not Found in Server2");

       }

      }

catch(Exception e)

     {

System.out.println(e);

     }

   }

}

Program – 3

Program – 3

Client

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class Client

{

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

                {

                                String arr[] =new String[3];int i=0;

                                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 credit card no : ");

                                String k1=DIS.readLine();

                PS.println(k1.trim());

                    String res = DS1.readLine();

                if(res.equals("Record Not Found"))

                System.out.println("Record Not Found");

                else{

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

                                while(Stt.hasMoreTokens())

                                                {

                                                                String temp=Stt.nextToken();

                                                                arr[i]=temp;

                                                                i++;

                                                }

                                System.out.println("Customer name is "+arr[0]);

                                System.out.println("Balance is  "  +arr[1]);

                 }

                }

}

Server-1

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

importjava.lang.*;

class Server1

{

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

                {

                                charch;String encrypt="";

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

                                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 creditno = DIS1.readLine();  

                                for(int i=0;i<creditno.length();i++)

                                {

                                                ch=creditno.charAt(i);

                                                encrypt+=(char)((int)ch+12);

                                }

                                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(encrypt);

                    String res =DS2.readLine();

                if(res.equals("Record Not Found"))

                    {

                PS1.println("Record Not Found");   

                    }

                else{

                                String decrypt="";

                                StringTokenizerStt =new StringTokenizer(res,"+*=");

                                while(Stt.hasMoreTokens())

                                                {

                                                                String temp=Stt.nextToken();

                                                                for(int i=0;i<temp.length();i++)

                                                                {

                                                                                ch=temp.charAt(i);

                                                                                decrypt+=(char)((int)ch-4);

                                                                }

                                                                decrypt+="#";

                                }

                System.out.print(decrypt);

                PS1.println(decrypt);

                 }            

                }

}

Server-2

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class Server2

{

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

                {

                                String ans1="",ans2="";char ch;String encrypt="",decrypt="";

                                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();

                                for(int i=0;i<inp.length();i++)

                                {

                                                ch=inp.charAt(i);

                                                decrypt+=(char)((int)ch-12);

                                }

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

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

                                Statement stat = con.createStatement();

                                String query = "Select Custname,balance from credittable where creditno = '"+decrypt+"'";

                                ResultSetrs = stat.executeQuery(query);

                                while(rs.next()){

                                ans1 =rs.getString(1);

                                ans2=rs.getString(2);

                                }

                                if(ans1!=""){

                                for(int i=0;i<ans1.length();i++)

                                {

                                                ch=ans1.charAt(i);

                                                encrypt+=(char)((int)ch+4);

                                }

                                encrypt+="+*=";

                                if(ans2!=""){

                                for(int i=0;i<ans2.length();i++)

                                {

                                                ch=ans2.charAt(i);

                                                encrypt+=(char)((int)ch+4);

                                }

                                }

                                PS2.println(encrypt);

                                }

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

                                rs.close();

                                stat.close();

                                con.close();

                }}