package bookingsystem;

import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.PreparedStatement;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2007</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class Customer {


    private int cno;
    private String cname;
    private String phone;
    Connection cn = ConnectionDB.getCon();
    Statement st = null;
    ResultSet rs = null;

    public Customer(int cno)
    {
        try {
            existCustomerByCno(cno);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }

    public Customer(String name,String phone) throws SQLException {
        this.cname = name;
        this.phone = phone;
        ResultSet rs = existCustomerByCname();
        if(rs.wasNull())
        {
            addNewCustomer();
            existCustomerByCname();
        }

    }

    public ResultSet existCustomerByCname() throws SQLException {
        String sql = "select CNO,CNAME,PHONE" +" "+
        "FROM CUSTOMER where CNAME = '" + this.cname +"' AND PHONE = '"+this.phone+"'"  ;
        st =cn.createStatement();
        rs = st.executeQuery(sql);
        while(rs.next())
        {
            this.cno = rs.getInt("CNO");
        }
        return rs;

    }

    public ResultSet existCustomerByCno(int cno) throws SQLException {
        String sql = "select CNO,CNAME,PHONE" +" "+
        "FROM CUSTOMER where CNO = " + cno ;
        st =cn.createStatement();
        rs = st.executeQuery(sql);
        while(rs.next())
        {
            this.cno = rs.getInt("CNO");
            this.cname = rs.getString("CNAME");
            this.phone = rs.getString("phone");
        }
        return rs;

    }

    public void addNewCustomer() throws SQLException {
        String insertSql = "INSERT INTO CUSTOMER ('CNAME','PHONE') VALUES ('"+this.cname+"','"+this.phone+"')";
        PreparedStatement ps = cn.prepareStatement(insertSql);
        ps.executeUpdate();


    }

    public int getCno()
    {
        return this.cno;
    }
    public String getcname()
    {
        return cname;
    }
    public String getphone()
    {
       return phone;
    }

    public void setname(String name)
    {
        this.cname = cname;
    }
    public void setphone(String phone)
    {
        this.phone = phone;
    }
}