1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83
|
package utile;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Logger;
import controleur.Serveur;
/**
* Classe de connection a la base de donnees
* @author SBO
*/
public class ConnectBDD {
private String pilote=null;
private String hote=null;
private String base=null;
private String utilisateur=null;
private String mdp=null;
private Connection connec=null;
private Logger logException=null;
/**
* Constructeur de l'objet de connection a la base de donnees
* @param serveur
*/
public ConnectBDD(Serveur serveur){
try {
logException=serveur.getLoggerException();
pilote=serveur.getConfigServeur().getProperty("PiloteBDD");//"com.mysql.jdbc.Driver";
hote=serveur.getConfigServeur().getProperty("IpBDD");
base=serveur.getConfigServeur().getProperty("Base");
utilisateur=serveur.getConfigServeur().getProperty("Utilisateur");
mdp=serveur.getConfigServeur().getProperty("Mdp");
Class.forName(pilote);
connec=DriverManager.getConnection("jdbc:mysql://"+hote+"/"+base,utilisateur,mdp);
}catch(ClassNotFoundException cnfe){
logException.severe(cnfe.toString());
}catch (SQLException sqle){
logException.severe(sqle.toString());
}catch (NullPointerException npe){
logException.severe(npe.toString());
}
}
/**
* Fonction pour executer des requetes de type Select
* @param requete - La requete a executee
* @return Le resultat de l'execution de la requete
*/
public ResultSet exeSelect(String requete){
ResultSet resultatReq=null;
Statement instruction=null;
try {
instruction=connec.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
resultatReq=instruction.executeQuery(requete);
}
catch(SQLException sqle){
logException.severe(sqle.toString());
}
return resultatReq;
}
/**
* Fonction pour executer des requetes de type Update, Insert, Delete,...
* @param requete - La requete a executee
* @return Le nombre de ligne modifiee
*/
public int exeModif(String requete){
int resultatReq=-1;
Statement instruction=null;
try {
instruction=connec.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
resultatReq=instruction.executeUpdate(requete);
}
catch(SQLException sqle){
logException.severe(sqle.toString());
}
return resultatReq;
}
} |
Partager