/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
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";
                ResultSet rs,rs2;
                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);
                //rs2 = stm.executeQuery("select * from TK where ID = '"+ID+"' and Password ='"+Pass+"'");

                //rs = stm.executeQuery("select * from TK where ID = '"+ID+"'");

               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();
            }
        }
    }

}