Compare commits
No commits in common. "22143615ba26e30e006860379b29f15755d67b38" and "c4eccf38a97401ec0ae04cce52e731b04b9e26ba" have entirely different histories.
22143615ba
...
c4eccf38a9
3 changed files with 27 additions and 142 deletions
|
@ -8,15 +8,15 @@ chatapp/Model/Historique.java
|
||||||
chatapp.Model.Historique
|
chatapp.Model.Historique
|
||||||
chatapp/Model/MessageHorodate.java
|
chatapp/Model/MessageHorodate.java
|
||||||
chatapp.Model.MessageHorodate
|
chatapp.Model.MessageHorodate
|
||||||
chatapp/View/View_Menu.java
|
chatapp/Model/DataBase.java
|
||||||
chatapp.View.View_Menu
|
chatapp.Model.DataBase
|
||||||
chatapp/Protocol/RunnerEcouteTCP.java
|
chatapp/Protocol/RunnerEcouteTCP.java
|
||||||
chatapp.Protocol.RunnerEcouteTCP
|
chatapp.Protocol.RunnerEcouteTCP
|
||||||
chatapp/View/FenetreSession.java
|
chatapp/View/FenetreSession.java
|
||||||
chatapp.View.FenetreSession
|
chatapp.View.FenetreSession
|
||||||
chatapp.View.FenetreSession$1
|
chatapp.View.FenetreSession$1
|
||||||
chatapp/View/DemarrerSession.java
|
chatapp/Controller/ChatApp.java
|
||||||
chatapp.View.DemarrerSession
|
chatapp.Controller.ChatApp
|
||||||
chatapp/View/ChangementPseudo.java
|
chatapp/View/ChangementPseudo.java
|
||||||
chatapp.View.ChangementPseudo
|
chatapp.View.ChangementPseudo
|
||||||
chatapp/Protocol/RunnerEcouteUDP.java
|
chatapp/Protocol/RunnerEcouteUDP.java
|
||||||
|
@ -39,7 +39,7 @@ chatapp/View/ConnexionScreen.java
|
||||||
chatapp.View.ConnexionScreen
|
chatapp.View.ConnexionScreen
|
||||||
chatapp/View/View_Utilisateurs.java
|
chatapp/View/View_Utilisateurs.java
|
||||||
chatapp.View.View_Utilisateurs
|
chatapp.View.View_Utilisateurs
|
||||||
chatapp/Controller/ChatApp.java
|
chatapp/View/View_Menu.java
|
||||||
chatapp.Controller.ChatApp
|
chatapp.View.View_Menu
|
||||||
chatapp/Model/DataBase.java
|
chatapp/View/DemarrerSession.java
|
||||||
chatapp.Model.DataBase
|
chatapp.View.DemarrerSession
|
||||||
|
|
|
@ -48,7 +48,7 @@ public class ChatApp implements PropertyChangeListener {
|
||||||
this.actifUsers.addList(getMe());
|
this.actifUsers.addList(getMe());
|
||||||
|
|
||||||
this.main = main;
|
this.main = main;
|
||||||
this.db= DataBase.getInstance();
|
//this.db= DataBase.getInstance();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static synchronized ChatApp getInstance(String pseudo, Integer port, Application main){
|
public static synchronized ChatApp getInstance(String pseudo, Integer port, Application main){
|
||||||
|
|
|
@ -176,38 +176,11 @@ public class DataBase {
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Methode permettant d'ajouter un utilisateur dans la base de donnée si celui-ci n'existe pas deja
|
* Methode permettant de mettre a jour le pseudo d'un utilisateur en fonction de son ID dans la base de donnee
|
||||||
* @param ID Id de l'utilisateur que l'on veut rajouter
|
* @param ID Id de l'utilisateur qui vient de se connecter pour la premiere fois
|
||||||
* @param Pseudo pseudo actuelle de l'utilisateur
|
* @param Pseudo pseudo actuelle de l'utilisateur
|
||||||
*/
|
*/
|
||||||
public void ajoutUtilisateurs(String ID , String Pseudo ) {
|
public void ajoutUtilisateurs(String ID , String Pseudo ) {
|
||||||
// Verification que l'utilisateur n'existe pas
|
|
||||||
String existe= "SELECT Pseudo FROM Customers WHERE ID = " + ID;
|
|
||||||
Statement stmt = null;
|
|
||||||
ResultSet rs = null ;
|
|
||||||
try {
|
|
||||||
stmt = this.connection.createStatement();
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
rs = stmt.executeQuery(existe);
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
String P = "" ;
|
|
||||||
try {
|
|
||||||
P = rs.getString("Pseudo");
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
if( !P.equals("") ) {
|
|
||||||
// L'utilisateur existe deja
|
|
||||||
if (!P.equals(Pseudo)){
|
|
||||||
this.majPseudo(ID,Pseudo); // On met a jour le nouveau pseudo
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
String requete= "INSERT INTO `Utilisateurs` (`ID`, `Pseudo`, `Actif`) VALUES ( ? , ? , '1')";
|
String requete= "INSERT INTO `Utilisateurs` (`ID`, `Pseudo`, `Actif`) VALUES ( ? , ? , '1')";
|
||||||
PreparedStatement Ps = null ;
|
PreparedStatement Ps = null ;
|
||||||
//Statement est utilisé pour envoyer une requete SQL à la base de donnee
|
//Statement est utilisé pour envoyer une requete SQL à la base de donnee
|
||||||
|
@ -229,7 +202,6 @@ public class DataBase {
|
||||||
System.out.println(" Echec executeUpdate ");
|
System.out.println(" Echec executeUpdate ");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Methode permettant de mettre a jour les utilisateurs actuellement actif
|
* Methode permettant de mettre a jour les utilisateurs actuellement actif
|
||||||
|
@ -259,91 +231,4 @@ public class DataBase {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
* Methode permettant de recuperer les N derniers messages envoyés entre 2 utilisateurs
|
|
||||||
* @param ID Utilisateur associé a ChatApp
|
|
||||||
* @param destinataire Celui avec qui correspond ID
|
|
||||||
* @return Les N derniers Messages
|
|
||||||
*/
|
|
||||||
public String recupNMsg(String ID, String IDdestinataire, int N) {
|
|
||||||
String Msg = "" ;
|
|
||||||
String petit;
|
|
||||||
String grand;
|
|
||||||
int comparaison = ID.compareTo(IDdestinataire);
|
|
||||||
if (comparaison < 0) {
|
|
||||||
petit = ID;
|
|
||||||
grand = IDdestinataire;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
petit = ID;
|
|
||||||
grand = IDdestinataire ;
|
|
||||||
}
|
|
||||||
String nomTable = "Chat_" + petit + "_" + grand ;
|
|
||||||
String requete= "SELECT * FROM nomTable";
|
|
||||||
Statement stmt = null;
|
|
||||||
ResultSet rs = null ;
|
|
||||||
try {
|
|
||||||
stmt = this.connection.createStatement();
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
rs = stmt.executeQuery(requete);
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
|
|
||||||
for(int i = 0 ; i < N; i++){
|
|
||||||
try {
|
|
||||||
if( rs.next()){
|
|
||||||
String IDSource = rs.getString("Source");
|
|
||||||
String Envoi = rs.getTimestamp("Envoi").toString();
|
|
||||||
String Message = rs.getString("Message");
|
|
||||||
if (IDSource.equals(ID)){
|
|
||||||
Msg += ( "Moi (" + Envoi + ") : " + Message ) ;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
String PseudoSource = getPseudo(IDSource) ;
|
|
||||||
Msg += ( PseudoSource + "(" + Envoi + ") : " + Message );
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return Msg ;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Methode permettant de recuperer le pseudo actuel d'un utilisateur en fonction de son ID
|
|
||||||
* @param ID Id de l'utilsateur dont on veut connaitre le pseudo
|
|
||||||
* @return Pseudo
|
|
||||||
*/
|
|
||||||
private String getPseudo(String idSource) {
|
|
||||||
String Pseudo = "" ;
|
|
||||||
String requete= "SELECT * FROM `Utilisateurs` WHERE ID = " + idSource;
|
|
||||||
Statement stmt = null;
|
|
||||||
ResultSet rs = null ;
|
|
||||||
try {
|
|
||||||
stmt = this.connection.createStatement();
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
rs = stmt.executeQuery(requete);
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
if (! rs.getString("Pseudo").equals(null) ){
|
|
||||||
Pseudo = rs.getString("Pseudo") ;
|
|
||||||
}
|
|
||||||
} catch (SQLException throwables) {
|
|
||||||
throwables.printStackTrace();
|
|
||||||
}
|
|
||||||
return Pseudo ;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue