/*
 client gui ID va Pass cho server
neu ID sai >> tai khoan k ton tai
neu ID dung + pass sai >> pass sai
neu dung ID va Pass >> show ra so tien
 */
package CNTT_cuoiky;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

/**
 *
 * @author Nham
 */
public class B1_Server_jdbc {
   public static void GuiServer(String x, DatagramPacket nhan, DatagramSocket sv) throws IOException
    {
        byte m[] = x.getBytes();
        InetAddress dc = nhan.getAddress();
        int port  = nhan.getPort();

        DatagramPacket gui = new DatagramPacket(m, m.length, dc, port);
        sv.send(gui);
    }

     public static void GuiServer(int x, DatagramPacket nhan, DatagramSocket sv) throws IOException
    {
        String tam = String.valueOf(x);
        byte m[] = tam.getBytes();
        InetAddress dc = nhan.getAddress();
        int port  = nhan.getPort();

        DatagramPacket gui = new DatagramPacket(m, m.length, dc, port);
        sv.send(gui);
    }
    public static DatagramPacket NhanServer( DatagramSocket sv) throws IOException
    {
        byte m[] = new byte[256];
        DatagramPacket nhan = new DatagramPacket(m, m.length);
        sv.receive(nhan);
        return nhan;
    }
    public static String NhanStringServer(DatagramSocket sv) throws IOException
    {
        byte m[] = new byte[256];
        DatagramPacket nhan = new DatagramPacket(m, m.length);
        sv.receive(nhan);
        String dl = new String(nhan.getData()).trim();
        return dl;
    }
   public static void main(String[] args) throws ClassNotFoundException, IOException
   {
           Connection conn = null;
           DatagramSocket sv = new DatagramSocket(1234);

            // nhan ID pass ben CLient
            DatagramPacket tt = NhanServer(sv);
            String ID = new String(tt.getData()).trim();
            String Pass = NhanStringServer(sv);
            try {
                String user = "sa";
                String pass = "123456";

                String url = "jdbc:sqlserver://localhost:1433;databaseName=CNTT_TAIKHOAN;";
                conn = DriverManager.getConnection(url,user,pass);
                System.out.println(ID + "  " + Pass);
                Statement stm = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
                try (ResultSet re = stm.executeQuery("select * from TK"))
                {
                    //re.beforeFirst();
                    while(re.next())
                    {
                        String temp_ID = re.getString("ID").trim();
                        if(ID.compareTo(temp_ID)==0)
                        {
                         try (ResultSet rePass = stm.executeQuery("select * from TK where ID = '"+ID+"'"))
                            {
                               // rePass.beforeFirst();
                                while(rePass.next())
                                {
                                    String temp_pass = rePass.getString("Password");
                                    if(Pass.compareTo(temp_pass)==0)
                                    {
                                        GuiServer("Tai Khoan " +rePass.getString("ID")+ " co so tien: "+rePass.getString("Balance"),tt,sv);
                                        return;
                                    }
                                }
                            }
                            GuiServer("Sai MK", tt,sv);
                            return;
                        }
                    }
                }
            GuiServer("tai khoan khong ton tai", tt,sv);
            sv.close();

            } catch (SQLException ex) {
                ex.printStackTrace();
            }
//            finally {
//            try {
//                if (conn != null && !conn.isClosed()) {
//                    conn.close();
//
//                }
//            } catch (SQLException ex) {
//                ex.printStackTrace();
//            }
        //}
    }

}