package DAO;
import BD.*;
import Bean.*;
import oracle.jdbc.OracleTypes;

import java.sql.*;

public class DAOTravail {

	private SessionOracle s;

	public DAOTravail(SessionOracle ss)
	{
		this.s = ss;
	}



	public void create(Travail em) {
		try {
		String insertTableEmploye = "insert into romain_travail values(" + em.getNuempl()+ ",'" + em.getNuproj()+ "'," + em.getDuree() + ")";
		Statement stmt = this.s.getConnection().createStatement();
		System.out.println(insertTableEmploye);
		stmt.executeUpdate(insertTableEmploye);
		}
		catch (SQLException erreur) {
			System.out.println(erreur.getMessage() + " " +erreur.getErrorCode());
		}
	}


	public void delete(Travail e)
	{
		try {
			String deleteTableEmploye = "DELETE FROM romain_travail WHERE  nuempl = "+e.getNuempl()+" and nuproj = " + e.getNuproj()+")";
			PreparedStatement ps = this.s.getConnection().prepareStatement(deleteTableEmploye) ;

			ps.executeUpdate();

		}
		catch (SQLException erreur) {
			System.out.println(erreur.getMessage() + "" +erreur.getErrorCode());
		}

	}

	public void update(Travail e)
	{
		try {
			String updateTableEmploye = "update romain_travail set nuproj = " + "'" + e.getNuproj()+ "', duree = " + e.getDuree();
			PreparedStatement ps = this.s.getConnection().prepareStatement(updateTableEmploye) ;

			ps.executeUpdate();

		}
		catch (SQLException erreur) {
			System.out.println(erreur.getMessage() + " " +erreur.getErrorCode());
		}
	}


	public void read() {
		try {
			String selectTableEmploye = "select * from romain_travail";
			Statement stmt = this.s.getConnection().createStatement();
			ResultSet resultat = stmt.executeQuery(selectTableEmploye);
				while (resultat.next()){
				Travail em = new Travail(resultat.getInt(1), resultat.getInt(2), resultat.getInt(3));
				System.out.println(em.toString());
				}
		}
		catch (SQLException erreur) {
			System.out.println(erreur.getMessage() + " " +erreur.getErrorCode());
		}
	}
}