package ajax;

import java.io.*;
import java.sql.*;
import javax.naming.InitialContext;
import javax.servlet.*;
import javax.servlet.http.*;


public class FormValidationServlet extends HttpServlet {
    public void doGet(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
        try {
            //Obtain value of Catalog Id field to ve validated.
            String catalogId = request.getParameter("catalogId");

            //Obtain Connection
            InitialContext initialContext = new InitialContext();
            javax.sql.DataSource ds = (javax.sql.DataSource) initialContext.lookup(
                    "java:comp/env/jdbc/DBConnection1DS");
            java.sql.Connection conn = ds.getConnection();

            //Obtain result set
            Statement stmt = conn.createStatement();
     String query = "SELECT * from OE.Catalog WHERE catalogId=" + "'" +
                catalogId + "'";
            ResultSet rs = stmt.executeQuery(query);

            // set headers before accessing the Writer
            response.setContentType("text/xml");
            response.setHeader("Cache-Control", "no-cache");

            PrintWriter out = response.getWriter();

            // then write the response
            //If result set is empty set valid element to true
            if (rs.next()) {
       out.println("<catalog>" + "<valid>false</valid>" + "<journal>" +
                    rs.getString(2) + "</journal>" + "<publisher>" +
                    rs.getString(3) + "</publisher>" + "<edition>" +
                    rs.getString(4) + "</edition>" + "<title>" +
                    rs.getString(5) + "</title>" + "<author>" +
                    rs.getString(6) + "</author>" + "</catalog>");
            } else {
                out.println("<valid>true</valid>");
            }

            rs.close();
           stmt.close();
           conn.close();

        } catch (javax.naming.NamingException e) {
        } catch (SQLException e) {
        }
    }

    public void doPost(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
        try {
            //Obtain Connection
            InitialContext initialContext = new InitialContext();
            javax.sql.DataSource ds = (javax.sql.DataSource) initialContext.lookup(
                    "java:comp/env/jdbc/DBConnection1DS");
            java.sql.Connection conn = ds.getConnection();

            String catalogId = request.getParameter("catalogId");
            String journal = request.getParameter("journal");
            String publisher = request.getParameter("publisher");
            String edition = request.getParameter("edition");
            String title = request.getParameter("title");
            String author = request.getParameter("author");

            Statement stmt = conn.createStatement();
            String sql = "INSERT INTO Catalog VALUES(" + "\'" + catalogId +
                "\'" + "," + "\'" + journal + "\'" + "," + "\'" + publisher +
                "\'" + "," + "\'" + edition + "\'" + "," + "\'" + title + "\'" +
                "," + "\'" + author + "\'" + ")";

            stmt.execute(sql);

            response.sendRedirect("catalog.jsp");
            
           stmt.close();
           conn.close();

        } catch (javax.naming.NamingException e) {
            response.sendRedirect("error.jsp");
        } catch (SQLException e) {
            response.sendRedirect("error.jsp");
        }
    }
}