Guest User

Untitled

a guest
Dec 23rd, 2018
110
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.05 KB | None | 0 0
  1. `import java.io.IOException;
  2. import javax.websocket.OnClose;
  3. import javax.websocket.OnMessage;
  4. import javax.websocket.OnOpen;
  5. import javax.websocket.Session;
  6. import javax.websocket.server.ServerEndpoint;
  7. import java.sql.*;
  8. @ServerEndpoint("/websockett")
  9. public class Websocket{
  10. static String m;
  11. public static void main(String args[]){
  12. try{
  13. Class.forName("com.mysql.jdbc.Driver");
  14. Connection con=DriverManager.getConnection(
  15. "jdbc:mysql://localhost:3306/cc","root","");
  16. Statement stmt=con.createStatement();
  17. ResultSet rs=stmt.executeQuery("select * from emp");
  18. while(rs.next()) {
  19. m=rs.getString(2);}
  20. con.close();
  21. }catch(Exception e){ System.out.println(e);}
  22. }
  23. @OnMessage
  24. public void onMessage(String messag, Session session)
  25. throws IOException, InterruptedException {
  26. System.out.println("Received: " + messag);
  27. session.getBasicRemote().sendText(m);
  28. }
  29. @OnOpen
  30. public void onOpen() {
  31. System.out.println("Client connected");
  32. }
  33. @OnClose
  34. public void onClose() {
  35. System.out.println("Connection closed");
  36. }}
Add Comment
Please, Sign In to add comment