/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package application;

import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 *
 * @author USER
 */
public class BDD {
    //les decalration
    Connection connection;
    Statement statement;
    String SQL;
    String url;
    String username;
    String password;
    Socket client;
    int Port;
    String Host;
    
public BDD(String url,String username,String password,String Host, int Port){
        this.url=url;
        this.username=username;
        this.password=password;
        this.Host=Host;
        this.Port=Port;
     }  
//fonction pour faire connection  base de donnée
public Connection connexionDatabase(){
    try{
            Class.forName("com.mysql.Driver");
            connection=DriverManager.getConnection(url,username,password);
            System.out.println("username");
        } catch(Exception e){System.err.println(e);//e.getMessage set pour se trouve le problem exactement err pour afficher l'erreur
        }
    return connection;
 }
//fonction pour fermer la base de donnée
public Connection closeconnexion(){
    try{
        connection.close();
    }catch(Exception e){System.err.println();
    }
    return connection;
} 
//pour l'execution de requete 
public ResultSet exécutionQuery(String sql){
    connexionDatabase();
    ResultSet resultSet=null;
    try{
        statement=connection.createStatement();
        resultSet=statement.executeQuery(sql);
        System.out.println(sql);
    }catch(SQLException ex){
        System.err.println("ex");
    }
    return resultSet;
}
//pour execution de requete update
public String exécutionUpdate(String sql){
        connexionDatabase();
        String result="";
        try{
            statement=connection.createStatement();
            statement.executeQuery(sql);
            result=sql;
        }catch(SQLException ex){
            result=ex.toString();
        }return result;
    }
//fonction pour afficher Tous
public ResultSet querySelectAll(String nomTable){
    connexionDatabase();
    SQL="SELECTE*FROM" + nomTable;
    System.out.println(SQL);
    return this.exécutionQuery(SQL);
}
//
 public ResultSet querySelectAll(String nomTable,String état){
     connexionDatabase();
     SQL="SELECTE*FROM" + nomTable + "WHERE" + état;
     return this.exécutionQuery(SQL);
 }
 // 
 public ResultSet querySelect(String[]nomColonne,String nomTable){
     connexionDatabase();
     int i;
     SQL="SELECT";
     for(i=0;i<=nomColonne.length-1;i++){
         SQL+=nomColonne[i];
         if(i<nomColonne.length-1){
             SQL+=",";
         }
     }
         SQL +="FROM" + nomTable;
         return this.exécutionQuery(SQL);
        }
 //
 public ResultSet foSelectCommande(String[]nomColonne,String nomTable,String état){
     connexionDatabase();
     int i;
     SQL="SELECT";
     for(i=0;i<=nomColonne.length-1;i++){
         SQL+=nomColonne[i];
         if(i<nomColonne.length-1){
             SQL+=",";
         }
     }
     SQL+="FROM" + nomTable + "WHERE" + état;
     return this.exécutionQuery(SQL);
   }
 //fonction d'insertion de donnée
 public String queryInsert(String nomTable,String[] contenuTableau){
     connexionDatabase();
     int i;
     SQL ="INSERT INTO" + nomTable + "VALUES(";
     for(i=0;i<=contenuTableau.length-1;i++){
         SQL += "'" + contenuTableau[i] + "'";
         if(i<contenuTableau.length-1){
             SQL+=",";
         }
     }
     SQL+=")";
     return this.exécutionUpdate(SQL);
 }
    //
 public String queryInsert(String nomTable,String[]nomColonne,String[]contenuTableau){
     connexionDatabase();
     int i;
     SQL="INSERT INTO" + nomTable +"(";
     for(i=0;1<=nomColonne.length-1;i++){
         SQL +=nomColonne[i];
         if(i<nomColonne.length-1){
             SQL += ","; 
         }
     }
     SQL +=")VALUES(";
     for(i=0;i<=contenuTableau.length-1;i++){
         SQL += "'" + contenuTableau[i] + "'";
         if(i< contenuTableau.length-1){
             SQL +=",";
         }
     }
     SQL +=")";
     return this.exécutionUpdate(SQL);
 }
 
 //
 public String queryUpdate(String nomTable,String[]nomColonne,String[] contenuTableau,String état){
     connexionDatabase();
     int i;
     SQL="UPDATE"+ nomTable + "SET";
     for(i=0;i<= nomColonne.length-1;i++){
         SQL += nomColonne[i] + "='" + contenuTableau[i] + "'";
         if(i<nomColonne.length-1){
             SQL +=",";
         }
     }
     SQL +="WHERE" + état;
     return this.exécutionUpdate(SQL);
    }
 //fonction pour la requete supprimer sans parameter
 public String queryDelete(String nomTable){
     connexionDatabase();
     SQL="DELETE FROM" + nomTable;
     return this.exécutionUpdate(SQL);
 }
 //fonction pour requete supprimer avec parameter
 public String queryDelete(String nomTable, String état){
     connexionDatabase();
     SQL="DELETE FROM" + nomTable + "wHERE" + état;
     return this.exécutionUpdate(SQL);
 }
 
 
 }