Advertisement
Guest User

Untitled

a guest
Apr 27th, 2017
122
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.95 KB | None | 0 0
  1. private static StringBuilder sb4 = new StringBuilder();
  2.  
  3.   System.out.println("Waiting.");
  4.         SocketChannel socketChannel
  5.                 = serverSocketChannel.accept();
  6.         sb4.delete(0, sb4.length());
  7.  
  8.         System.out.println("Opened connection.");
  9.        
  10.  
  11.           ByteBuffer b = ByteBuffer.allocate(9999);
  12. System.out.println("Init");
  13.         b = ByteBuffer.allocate(9999);
  14.         b.clear();
  15.         b.put("K".toString().getBytes());
  16.         b.flip();
  17.         while (b.hasRemaining()) {
  18.           socketChannel.write(b);
  19.         }
  20.        
  21.       Boolean taken = false;
  22.         StringBuilder msg = new StringBuilder();
  23.         String tmp;
  24.         int cnt = 0;
  25.         b.clear();
  26.         cnt = socketChannel.read(b);
  27.         while (cnt > 0) {
  28.           b.flip();
  29.           tmp = new String(b.array()).substring(0, cnt);
  30.           msg.append(tmp);
  31.           b.clear();
  32.           if (msg.toString().endsWith("]"))
  33.             break;
  34.           cnt = socketChannel.read(b);
  35.         }
  36.    
  37.      
  38.         System.out.println("New message got [ " + msg + " ] ");
  39.         String[] array=msg.toString().split("§");
  40.          String url = "jdbc:mysql://localhost:3306/chat";
  41.         String name = "root";
  42.         String pass = "1111";
  43.         try {
  44.             Connection con = DriverManager.getConnection(url, name, pass);
  45.            
  46.             Statement s = con.createStatement();
  47.             ResultSet r = s.executeQuery("select * from user");
  48.             while (r.next()) {
  49.            
  50.             String username = r.getString("name");
  51.            
  52.                        
  53.  
  54.            
  55.        
  56.                 System.out.println(username);
  57.                 if(array[0].equals(username)) {
  58.                 taken=true;
  59.                        
  60.                
  61.                 }
  62.             }
  63.         } catch (SQLException ex) {
  64.         }
  65.           System.out.println(taken);
  66.     if(taken) {
  67.     sb4.delete(0, sb4.length());
  68. sb4.append("F");
  69.     }
  70.     else {
  71.      
  72.                     Connection con;
  73.             try {
  74.                 con = DriverManager.getConnection(url, name, pass);
  75.                         Statement statement = con.createStatement();
  76. statement.executeUpdate("INSERT INTO user " + "VALUES ('"+array[0]+"','"+array[1]+"')");
  77.  
  78.                
  79.             } catch (SQLException ex) {
  80.                 Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
  81.             }
  82.  
  83.  
  84.  
  85.     sb4.delete(0, sb4.length());
  86. sb4.append("O");
  87.     }
  88.         System.out.println("Returning result");
  89.         b = ByteBuffer.allocate(9999);
  90.         b.clear();
  91.         b.put(sb4.toString().getBytes());
  92.         b.flip();
  93.         while (b.hasRemaining()) {
  94.           socketChannel.write(b);
  95.         }
  96.  
  97.         System.out.println("Done, waiting for next one.");
  98.      
  99.  
  100.        
  101.       } catch (IOException ex) {
  102.         System.out.println("Failed to communicate. " + ex.getMessage());
  103.       }
  104.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement