package dao;

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

public class dbCommunicatie {
	private Connection connection;
	private PreparedStatement preparedStatement;
	private ResultSet resultSet;
	private String host;
	private String db;
	private String user;
	private String password;
	private String url;

	//	String url = "jdbc:mysql://145.76.18.71/s145989?user=s145989&password=syrhe";
	public dbCommunicatie() {
		connection = null;
		preparedStatement = null;
		resultSet = null;

		//Database gegevens
		host = "145.76.18.71";
		db = "s145989";
		user = "s145989";
		password ="syrhe";

		url = "jdbc:mysql://" + host + "/" + db + "?user=" + user
				+ "&password=" + password;
	}

	public void maakVerbinding() {

		// Laad eerst de driver.
		try {
			Class.forName("com.mysql.jdbc.Driver");
			//System.out.println("Laden van de driver is gelukt.");
		} catch (ClassNotFoundException e) {
			System.err.println("Kan de driver niet in de classpath vinden.");
			e.printStackTrace();
			return;
		}

		try {
			// Verkrijg de connectie.
			connection = DriverManager.getConnection(url);

		} catch (SQLException e) {
			e.printStackTrace();
		}

	}

	public Connection getConnection(){
		return connection;
	}

	public Statement getPreparedStatement(){
		return preparedStatement;
	}

	public ResultSet getResultSet(){
		return resultSet;
	}

	public ResultSet selectQuery(String query) {
		maakVerbinding();
		try {
			PreparedStatement pstmt = getConnection().prepareStatement(query);
			resultSet = pstmt.executeQuery();
		} catch (SQLException e) {
			System.out.println("Uitvoeren van Select Query is mislukt");
			e.printStackTrace();
		}
		return resultSet;
	}

	public int insertQuery(String query){
		maakVerbinding();
		int aangepasteRijen = 0;
		try {
			PreparedStatement pstmt = getConnection().prepareStatement(query);
			aangepasteRijen = pstmt.executeUpdate(query);
		}
		catch (SQLException e){
			System.out.println("Uitvoeren van Insert Query is mislukt");
			e.printStackTrace();
		}
		close(resultSet);
		close(preparedStatement);
		close(connection);

		return aangepasteRijen;
	}

	public int updateQuery(String query){
		maakVerbinding();
		int aangepasteRijen = 0;
		try {
			PreparedStatement pstmt = getConnection().prepareStatement(query);
			aangepasteRijen = pstmt.executeUpdate(query);
		}
		catch (SQLException e){
			System.out.println("Uitvoeren van Update Query is mislukt");
			e.printStackTrace();
		}
		close(resultSet);
		close(preparedStatement);
		close(connection);

		return aangepasteRijen;
	}

	public int deleteQuery(String query){
		maakVerbinding();
		int aangepasteRijen = 0;
		try {
			PreparedStatement pstmt = getConnection().prepareStatement(query);
			aangepasteRijen = pstmt.executeUpdate(query);
		}
		catch (SQLException e){
			System.out.println("Uitvoeren van Delete Query is mislukt");
			e.printStackTrace();
		}
		close(resultSet);
		close(preparedStatement);
		close(connection);

		return aangepasteRijen;
	}

	 public void close(Connection connection) {
	        if (connection != null) {
	            try {
	                connection.close();
	            } catch (SQLException e) {
	                // Niks aan te doen.
	                System.err.println("Kan de connectie niet sluiten.");
	                e.printStackTrace();
	            }
	        }
	    }

	    public void close(Statement preparedStatement) {
	        if (preparedStatement != null) {
	            try {
	                preparedStatement.close();
	            } catch (SQLException e) {
	                // Niks aan te doen.
	                System.err.println("Kan de statement niet sluiten.");
	                e.printStackTrace();
	            }
	        }
	    }

	    public void close(ResultSet resultSet) {
	        if (resultSet != null) {
	            try {
	                resultSet.close();
	            } catch (SQLException e) {
	                // Niks aan te doen.
	                System.err.println("Kan de resultset niet sluiten.");
	                e.printStackTrace();
	            }
	        }
	    }
}