import java.awt.Color;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.ItemEvent;
import java.awt.event.ItemListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.ParseException;
import java.util.*;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.ButtonGroup;
import javax.swing.JButton;
import javax.swing.JRadioButton;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.LineBorder;


class Server extends Thread
{
	static int port = 5000;
 	String address = "127.0.0.1";
 	static ServerSocket ss;

	@Override
	public void run()
	{
	 BufferedReader in = null;
     PrintWriter out = null;
     Connection con = null;
     PreparedStatement stmt = null;
     Socket s = null;

     while(true)
     {
    	 try
    	 {
    		 System.out.println("poczatek");
    		 if(!ss.isBound())
    		 {
    			 s = ss.accept();
    		 }
    		 else
    		 {
    			 Server thread2 = new Server();
    			 thread2.start();
    		 }
    		 System.out.println("polaczylem sie z klientem");
    		 in = new BufferedReader(new InputStreamReader(s.getInputStream())); //wejsciowy
    		 out = new PrintWriter(s.getOutputStream(), true); //wyjsciowy
    		 String line = in.readLine();

    		 if(line.matches("\\d.*"))  // sygnal bazodanowy
    		 {
    			 System.out.println("Odebralem działanie: "+line);
    			 if(line.startsWith("1"))
    			 {
    				 line = line.substring(1,line.length());
    				 String login = line.split(" ")[0];
    				 String haslo = line.split(" ")[1];
    				 System.out.println("login: "+ login +" haslo: " + haslo);

    				 try
    				 {
    					 System.out.println("lalala");
			             con = DriverManager.getConnection("jdbc:mysql://localhost:3306/komunikator","root","local");
			             stmt = con.prepareStatement("INSERT INTO user(login,password) VALUES (?,?)");
			             stmt.setString(1, login);
			             stmt.setString(2, haslo);
			             stmt.executeUpdate();
			             out.println("1created");

    				 }
    				 catch (SQLException ex)
    				 {
    					 if (ex.getSQLState().startsWith("23"))
    					 {
    						 out.println("1error1");
    					 }
    					 else
    					 {
    						 out.println("1error2");
    					 }
    					 ex.printStackTrace();
    				 }
    				 finally
    				 { // zwalnianie zasobow
    					 if (stmt != null)
    					 {
    						 try
    						 {
    							 stmt.close();
    						 }
    						 catch (SQLException sqlEx) { }
    						 stmt = null;
    					 }
    					 if(con != null)
    					 {
    						 try
    						 {
    							 con.close();
    						 }
    						 catch (SQLException sqlEx) { }
    						 con = null;
    					 }
    				 }

    			 }
    			 else if(line.startsWith("2"))
    			 {

    			 }
    		 }
    		 else
    		 {
    			 out.println("Serwer nie obsluguje "+line);
    		 	 System.out.println("Dostalem: "+line +" i to nie jest obsługiwane dzialanie");
    		 }
          }
          catch(Exception e)
          {
              System.out.println("Problem z połączeniem TCP");
              e.printStackTrace();
              System.exit(1);
          }
     }
	}

	public static void main(String [] args)
	{
 		try
 		{
	 		ss = new ServerSocket(Integer.valueOf(port));

	 		Server thread1 = new Server();
	 		thread1.start();
 		}
 		catch(Exception e)
 		{
	 		System.out.println("Problem z socketem serwera");
 			e.printStackTrace();
 		}
	}
}