JayBawankar

ds rmidb client server

Jul 12th, 2017
56
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 11.19 KB | None | 0 0
  1. //AP1
  2. -------------------------------------
  3.  
  4. import java.rmi.*;
  5. import java.sql.*;
  6. import java.net.*;
  7. import java.util.ArrayList;
  8. public interface AP1 extends Remote
  9. {
  10.     //public String[] getResult() throws RemoteException;
  11.    
  12.     public void insert(int rn,String name,int t1,int t2) throws RemoteException;
  13.     public void modify(int roll,int col,String newval) throws RemoteException;
  14.     public void del(int r) throws RemoteException;
  15.     public ArrayList<String> display() throws RemoteException;
  16. }
  17.  
  18.  
  19. //AP2
  20. -----------------------------------------
  21.  
  22.  
  23. import java.io.*;
  24. import java.rmi.RemoteException;
  25. import java.rmi.server.UnicastRemoteObject;
  26. import java.sql.*;
  27. import java.util.ArrayList;
  28.  
  29. public class AP2 extends UnicastRemoteObject implements AP1
  30. {
  31.     public AP2() throws RemoteException
  32.     {}
  33.    
  34.     public static Connection connectionDB()
  35.     {
  36.         try
  37.         {
  38.             Connection conn=null;
  39.             Class.forName("oracle.jdbc.OracleDriver");  
  40.             conn=DriverManager.getConnection("jdbc:oracle:thin:@localhost:1522:apurva","hr","hr");
  41.             return conn;
  42.         }
  43.         catch(Exception E)
  44.         {
  45.             System.out.print("\nEXCEPTION: "+E);
  46.         }
  47.         return null;
  48.     }
  49.     public void insert(int rn,String name,int t1,int t2) throws RemoteException
  50.     {
  51.         try
  52.         {
  53.             Connection conn=connectionDB();
  54.             if(conn!=null)
  55.                 System.out.print("\nCONNECTION ESTABLISHED");
  56.            
  57.             String ins = "INSERT INTO STUD_AP (ROLLNO, NAME, T1, T2) VALUES"
  58.                 + "("+rn+",'"+name+"',"+t1+","+t2+")";
  59.             Statement s1=conn.createStatement();
  60.             s1.executeUpdate(ins);
  61.             conn.close();
  62.         }
  63.         catch(Exception E)
  64.         {
  65.             System.out.println("EXCEPTION: "+E);
  66.         }
  67.     }
  68.     public void del(int roll) throws RemoteException
  69.     {
  70.         try
  71.         {
  72.             Connection conn=connectionDB();
  73.             if(conn!=null)
  74.                 System.out.print("\nCONNECTION ESTABLISHED");
  75.            
  76.             BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
  77.            
  78.             String d = "DELETE FROM STUD_AP WHERE ROLLNO = "+roll;
  79.                    
  80.             Statement s1=conn.createStatement();
  81.             s1.execute(d);
  82.             conn.close();
  83.         }
  84.         catch(Exception E)
  85.         {
  86.             System.out.println("EXCEPTION: "+E);
  87.         }
  88.     }
  89.     public void modify(int roll,int col,String newval) throws RemoteException
  90.     {
  91.         try
  92.         {
  93.             Connection conn=connectionDB();
  94.             if(conn!=null)
  95.                 System.out.print("\nCONNECTION ESTABLISHED");
  96.            
  97.             String stmt;
  98.             switch(col)
  99.             {
  100.                 case 1:stmt="NAME = '"+newval+"'";   break;
  101.                 case 2:stmt="T1 = '"+newval+"'";   break;
  102.                 case 3:stmt="T2 = '"+newval+"'";   break;
  103.                 default: stmt="";
  104.             }
  105.             String d = "UPDATE STUD_AP SET "+stmt+" WHERE ROLLNO = "+roll;
  106.                    
  107.             Statement s1=conn.createStatement();
  108.             s1.execute(d);
  109.             conn.close();
  110.         }
  111.         catch(Exception E)
  112.         {
  113.             System.out.println("EXCEPTION: "+E);
  114.         }
  115.     }
  116.     public ArrayList<String> display() throws RemoteException
  117.     {
  118.         ArrayList<String> arr=new ArrayList<String>();
  119.         try
  120.         {
  121.             Connection conn=connectionDB();
  122.             if(conn!=null)
  123.                 System.out.print("\nCONNECTION ESTABLISHED");
  124.             Statement s=conn.createStatement();
  125.             s.execute("SELECT * FROM STUD_AP");
  126.             ResultSet rs=s.getResultSet();
  127.             //System.out.print("\n\nSTUD_AP\n");
  128.             int i=0,total=0;
  129.             //System.out.print("\nID  NAME  T1  T2  TOTAL");
  130.             while(rs.next())
  131.             {
  132.                 i++;
  133.                 int t1=Integer.parseInt(rs.getString("T1"));
  134.                 int t2=Integer.parseInt(rs.getString("T2"));
  135.                 total=t1+t2;
  136.                 String str=rs.getString("ROLLNO")+"  "+rs.getString("NAME")+"  "+t1+"  "+t2+"   "+total;
  137.                 arr.add(str);
  138.                 //System.out.print("\n"+rs.getString("ROLLNO")+"  "+rs.getString("NAME")+"  "+t1+"  "+t2+"   "+total);
  139.             }
  140.             conn.close();
  141.         }
  142.         catch(Exception E)
  143.         {
  144.             System.out.println("EXCEPTION: "+E);
  145.         }
  146.         return arr;
  147.     }
  148. }
  149.  
  150.  
  151. //APClient
  152. ----------------------------------------------
  153.  
  154. import java.io.BufferedReader;
  155. import java.io.IOException;
  156. import java.io.InputStreamReader;
  157. import java.rmi.Naming;
  158. import java.util.ArrayList;
  159.  
  160. public class APClient
  161. {
  162.     public static void main(String args[]) throws IOException
  163.     {
  164.         BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
  165.         try
  166.         {
  167.             System.out.print("\n1.INSERT\n2.MODIFY\n3.DELETE\n4.DISPLAY \nENTER YOUR CHOICE: ");
  168.             int ch=Integer.parseInt(br.readLine());
  169.            
  170.             String s1="rmi://localhost/insert";
  171.             AP1 a=(AP1)Naming.lookup(s1);
  172.            
  173.             String s2="rmi://localhost/modify";
  174.             AP1 b=(AP1)Naming.lookup(s2);
  175.            
  176.             String s3="rmi://localhost/del";
  177.             AP1 c=(AP1)Naming.lookup(s3);
  178.            
  179.             String s4="rmi://localhost/display";
  180.             AP1 d=(AP1)Naming.lookup(s4);
  181.            
  182.             switch(ch)
  183.             {
  184.                 case 1: //INSERT
  185.                         System.out.print("\nINSERT\n");
  186.                         String name;
  187.                         int rn,t1,t2;
  188.                         System.out.print("\nENTER VALUES: ");
  189.                         System.out.print("\nROLL NO.: ");
  190.                         rn=Integer.parseInt(br.readLine());
  191.                         System.out.print("\nNAME: ");
  192.                         name=br.readLine();
  193.                         System.out.print("\nT1: ");
  194.                         t1=Integer.parseInt(br.readLine());
  195.                         System.out.print("\nT2: ");
  196.                         t2=Integer.parseInt(br.readLine());
  197.                         a.insert(rn,name,t1,t2);
  198.                 break;
  199.                
  200.                 case 2: //MODIFY
  201.                         System.out.print("\nUPDATE");
  202.                         System.out.print("\nENTER ROLLNO.: ");
  203.                         int roll=Integer.parseInt(br.readLine());
  204.                         System.out.print("\nWHAT DO U WANT TO UPDATE? : 1.NAME 2. T1 3. T2 : ");
  205.                         int col=Integer.parseInt(br.readLine());
  206.                         System.out.print("\nENTER NEW VALUE: ");
  207.                         String newval=br.readLine();
  208.                         b.modify(roll,col,newval);
  209.                 break;
  210.                    
  211.                 case 3: //DELETE
  212.                         System.out.print("\nDELETE");
  213.                         System.out.print("\nENTER ROLL NO.: ");
  214.                         int c1=Integer.parseInt(br.readLine());
  215.                         c.del(c1);
  216.                 break;
  217.                    
  218.                 case 4: //DISPLAY
  219.                         System.out.print("\nDISPLAY");
  220.                         ArrayList<String> arr=new ArrayList<String>();
  221.                         arr=d.display();
  222.                         System.out.print("\nID  NAME  T1  T2  TOTAL");
  223.                         for(String s:arr)
  224.                         {
  225.                             System.out.print("\n"+s);
  226.                         }
  227.                            
  228.                 break;
  229.                    
  230.                 default:System.out.println("\nINVALID CHOICE");
  231.             }          
  232.         }
  233.         catch(Exception ex)
  234.         {
  235.             System.out.println("EXCEPTION OCCURED "+ex);
  236.         }
  237.     }
  238. }
  239.  
  240.  
  241. //APServer
  242. -------------------------------------------
  243.  
  244. import java.rmi.Naming;
  245. import java.rmi.RemoteException;
  246.  
  247. public class APServer
  248. {
  249.     public static void main(String args[]) throws RemoteException
  250.     {
  251.         try
  252.         {
  253.             AP2 a= new AP2();
  254.             Naming.bind("insert", a);
  255.             System.out.println("OBJECT REGISTERED");
  256.            
  257.             AP2 b= new AP2();
  258.             Naming.bind("modify", b);
  259.             System.out.println("OBJECT REGISTERED");
  260.            
  261.             AP2 c= new AP2();
  262.             Naming.bind("del", c);
  263.             System.out.println("OBJECT REGISTERED");
  264.            
  265.             AP2 d= new AP2();
  266.             Naming.bind("display", d);
  267.             System.out.println("OBJECT REGISTERED");            
  268.         }
  269.         catch(Exception ex)
  270.         {
  271.             System.out.println("EXCEPTION OCCURED "+ex);
  272.         }
  273.     }
  274. }
  275.  
  276.  
  277. Output:
  278. -------------------------------------
  279.  
  280. server
  281.  
  282. Microsoft Windows [Version 6.3.9600]
  283. (c) 2013 Microsoft Corporation. All rights reserved.
  284.  
  285. C:\Users\intel>cd C:\Program Files\Java\jdk1.8.0_25\bin
  286.  
  287. C:\Program Files\Java\jdk1.8.0_25\bin>start rmiregistry
  288.  
  289. C:\Program Files\Java\jdk1.8.0_25\bin>java APServer
  290. OBJECT REGISTERED
  291. OBJECT REGISTERED
  292. OBJECT REGISTERED
  293. OBJECT REGISTERED
  294.  
  295. CONNECTION ESTABLISHED
  296. CONNECTION ESTABLISHED
  297. CONNECTION ESTABLISHED
  298. CONNECTION ESTABLISHED
  299. CONNECTION ESTABLISHED
  300. CONNECTION ESTABLISHED
  301.  
  302. ---------------------------------------------------------------------------------
  303. client
  304.  
  305. Microsoft Windows [Version 6.3.9600]
  306. (c) 2013 Microsoft Corporation. All rights reserved.
  307.  
  308. C:\Users\intel>cd C:\Program Files\Java\jdk1.8.0_25\bin
  309.  
  310. C:\Program Files\Java\jdk1.8.0_25\bin>java APClient
  311.  
  312. 1.INSERT
  313. 2.MODIFY
  314. 3.DELETE
  315. 4.DISPLAY
  316. ENTER YOUR CHOICE: 4
  317.  
  318. DISPLAY
  319. ID  NAME  T1  T2  TOTAL
  320. 1  A XYZ  15  13   28
  321. 2  B XYZ  14  12   26
  322. 3  C XYZ  12  15   27
  323. 4  D XYZ  12  12   24
  324. 5  E XYZ  14  14   28
  325. 6  F XYZ  13  15   28
  326. 99  APPY  15  15   30
  327. C:\Program Files\Java\jdk1.8.0_25\bin>java APClient
  328.  
  329. 1.INSERT
  330. 2.MODIFY
  331. 3.DELETE
  332. 4.DISPLAY
  333. ENTER YOUR CHOICE: 2
  334.  
  335. UPDATE
  336. ENTER ROLLNO.: 1
  337.  
  338. WHAT DO U WANT TO UPDATE? : 1.NAME 2. T1 3. T2 : 1
  339.  
  340. ENTER NEW VALUE: apurva
  341.  
  342. C:\Program Files\Java\jdk1.8.0_25\bin>java APClient
  343.  
  344. 1.INSERT
  345. 2.MODIFY
  346. 3.DELETE
  347. 4.DISPLAY
  348. ENTER YOUR CHOICE: 4
  349.  
  350. DISPLAY
  351. ID  NAME  T1  T2  TOTAL
  352. 1  apurva  15  13   28
  353. 2  B XYZ  14  12   26
  354. 3  C XYZ  12  15   27
  355. 4  D XYZ  12  12   24
  356. 5  E XYZ  14  14   28
  357. 6  F XYZ  13  15   28
  358. 99  APPY  15  15   30
  359. C:\Program Files\Java\jdk1.8.0_25\bin>java APClient
  360.  
  361. 1.INSERT
  362. 2.MODIFY
  363. 3.DELETE
  364. 4.DISPLAY
  365. ENTER YOUR CHOICE: 3
  366.  
  367. DELETE
  368. ENTER ROLL NO.: 99
  369.  
  370. C:\Program Files\Java\jdk1.8.0_25\bin>java APClient
  371.  
  372. 1.INSERT
  373. 2.MODIFY
  374. 3.DELETE
  375. 4.DISPLAY
  376. ENTER YOUR CHOICE: 4
  377.  
  378. DISPLAY
  379. ID  NAME  T1  T2  TOTAL
  380. 1  apurva  15  13   28
  381. 2  B XYZ  14  12   26
  382. 3  C XYZ  12  15   27
  383. 4  D XYZ  12  12   24
  384. 5  E XYZ  14  14   28
  385. 6  F XYZ  13  15   28
  386. C:\Program Files\Java\jdk1.8.0_25\bin>java APClient
  387.  
  388. 1.INSERT
  389. 2.MODIFY
  390. 3.DELETE
  391. 4.DISPLAY
  392. ENTER YOUR CHOICE: 4
  393.  
  394. DISPLAY
  395. ID  NAME  T1  T2  TOTAL
  396. 1  apurva  15  13   28
  397. 2  B XYZ  14  12   26
  398. 3  C XYZ  12  15   27
  399. 4  D XYZ  12  12   24
  400. 5  E XYZ  14  14   28
  401. 6  F XYZ  13  15   28
  402. C:\Program Files\Java\jdk1.8.0_25\bin>
Add Comment
Please, Sign In to add comment