package tel.servlets;

import java.io.IOException;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import tel.beans.UserData;

public class ProcessUser extends HttpServlet {

	private static final String ACTION_PARAM = "action";
	private static final String INSERT = "insert";
	private static final String SHOWALL = "showall";
	private static final String SELECTUSER = "selectuser";


	private static final String FORWARD_PARAM = "forward";
	private static final String ERROR_PAGE = "error.jsp";

	private static final String USER_BEAN ="user";
	private static final String ALLUSER_BEAN ="allusers";

	private Connection connection;



	protected void doGet(HttpServletRequest request, HttpServletResponse response)
	throws IOException {

		HttpSession session = request.getSession();
		UserData user = (UserData) session.getAttribute(USER_BEAN);

		String forward = request.getParameter(FORWARD_PARAM);
		try {
		if(forward == null){
			forward = ERROR_PAGE;
		}

		if(INSERT.equals(request.getParameter(ACTION_PARAM))){
			//User überprüfen
			System.out.println("INSERT");

			if(user != null && !"".equals(user.getLogin().trim()))
			{
				insert(user);
			} else {
				forward = ERROR_PAGE;
				//forward = "userform.jsp";
			}

		}else if(SELECTUSER.equals(request.getParameter(ACTION_PARAM))){
			//User in DB suchen
			System.out.println("SELECTUSER");
		}

		else if(SHOWALL.equals(request.getParameter(ACTION_PARAM))){
			//Auslesen aller User
			System.out.println("SHOWALL");
		}
		else{
			//weitere actions implementieren
			System.out.println(request.getParameter(ACTION_PARAM));

		}
	} catch( SQLException e) {
		e.printStackTrace();
		forward = ERROR_PAGE;
	}


		response.sendRedirect(forward);

		/*if( user == null ) {
			user = new UserData();
			session.setAttribute("user", user);
		}

		// Benutzereingaben validieren
		if( user.getFirstname() != null && !"".equals(user.getFirstname().trim()) &&
			user.getLastname() != null && !"".equals(user.getLastname().trim()) ) {

			// Benutzer in DB schreiben oder updaten

			response.sendRedirect("showuser.jsp");

		} else {
			// Eingaben nicht korrekt

			response.sendRedirect("userform.jsp");
		}
		 */

	}

	protected void doPost(HttpServletRequest request, HttpServletResponse response)
	throws IOException {
		doGet(request, response);
	}

	public void init(){

		String dbschema = getInitParameter("dbschema");

		String dburl= getServletContext().getInitParameter("dburl");
		String dbuser =getServletContext().getInitParameter("dbuser");
		String dbpwd=getServletContext().getInitParameter("dbpwd");

		System.out.println("init started");

		try{
			Class.forName("com.mysql.jdbc.Driver");

			connection = DriverManager.getConnection(dburl+dbschema, dbuser, dbpwd);
			System.out.println("connection started");

		}catch(ClassNotFoundException e){
			System.out.println("driver not found");

			throw new RuntimeException(e);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}
	public void destroy() {
		if(connection != null){
			try {
			connection.close();
			} catch (SQLException e){
			e.printStackTrace();
		}
		}
	}

	private void insert(UserData user) throws SQLException {
		String query = "INSERT INTO user (firstname, lastname, email, login, pwd) VALUES ('" + user.getFirstname() + "', '" +
		user.getLastname() + "', '" + user.getEmail() + "', '" + user.getLogin() + "', '" + user.getPassword() + "')";

		Statement statement = null;

		try{
		statement = connection.createStatement();
		statement.executeUpdate(query);
		} finally {
			if(statement != null)
				statement.close();
		}

	}

}