gallois/Clavardage
2
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

dbb

Browse source
This commit is contained in:
LMAGallois 2020-12-15 17:41:52 +01:00
parent fc16e1a74e
commit c0731ba406
4 changed files with 17 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
Application/Clavardage/src/controller/Historique.java
View file

@ -1,4 +1,7 @@
package controller;
import java.sql.Connection; import java.sql.Connection;
import java.sql.Date; import java.sql.Date;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.ResultSet; import java.sql.ResultSet;
@ -8,7 +11,7 @@ import java.sql.Statement;
import java.util.Calendar; import java.util.Calendar;
public class Historique { public class Historique {
private Database bdd; private model.Database bdd;
private ResultSet rs_received; private ResultSet rs_received;
private ResultSet rs_sent; private ResultSet rs_sent;
private ResultSetMetaData rsmd_received; private ResultSetMetaData rsmd_received;
@ -43,12 +46,12 @@ public class Historique {
return this.rsmd_sent; return this.rsmd_sent;
} }
public void saveMessage(User user1, RemoteUser user2, String input, String date) { public void saveMessage(model.User ctr1, model.RemoteUser ctr2, String input, String date) {
System.out.println("coucou"); System.out.println("coucou");
int nb_changed_rows=0; int nb_changed_rows=0;
try { try {
nb_changed_rows = this.bdd.getStatement().executeUpdate("INSERT INTO chat values ("+user1.getIPcode()+","+user2.addIP+","+input+","+date+")"); nb_changed_rows = this.bdd.getStatement().executeUpdate("INSERT INTO chat values ("+ctr1.getIPcode()+","+ctr2.getIPcode()+","+input+","+date+")");
} catch (SQLException e) { } catch (SQLException e) {
System.out.println("insertion pas établit"); System.out.println("insertion pas établit");
e.printStackTrace(); e.printStackTrace();
@ -59,7 +62,7 @@ public class Historique {
} }
} }
public String retrieveMessage(User user1, RemoteUser user2) throws SQLException { public String retrieveMessage(model.User user1, model.RemoteUser user2) throws SQLException {
this.setRSSent(this.bdd.getStatement().executeQuery("SELECT"+user1.getIPcode()+","+user2.getIPcode()+",? ,? FROM table")); this.setRSSent(this.bdd.getStatement().executeQuery("SELECT"+user1.getIPcode()+","+user2.getIPcode()+",? ,? FROM table"));
this.setRSReceived(this.bdd.getStatement().executeQuery("SELECT"+user2.getIPcode()+","+user1.getIPcode()+",?, ? FROM table")); this.setRSReceived(this.bdd.getStatement().executeQuery("SELECT"+user2.getIPcode()+","+user1.getIPcode()+",?, ? FROM table"));
//this.setRSMDSent(this.getRSSent().getMetaData()); //this.setRSMDSent(this.getRSSent().getMetaData());
@ -108,7 +111,7 @@ public class Historique {
//MAIN //MAIN
public void Historique() { public void Historique() {
this.bdd=new Database(); this.bdd=new model.Database();
System.out.println("coucoudb"); System.out.println("coucoudb");

1
Application/Clavardage/src/controller/ListeningThreadTCPConnection.java
View file

@ -29,7 +29,6 @@ public class ListeningThreadTCPConnection extends ListeningThread{
threadtcpchat.start(); threadtcpchat.start();
threadtcpchat.interrupt(); threadtcpchat.interrupt();
} }
/* run /* run

3
Application/Clavardage/src/model/Database.java
View file

@ -1,4 +1,7 @@
package model;
import java.sql.Connection; import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;

6
Application/Clavardage/src/model/User.java
View file

@ -26,6 +26,7 @@ public abstract class User {
protected String pseudo; protected String pseudo;
protected InetAddress addIP; protected InetAddress addIP;
protected int portTCP; protected int portTCP;
protected int IPcode;
/** /**
* Constructor of User (local) * Constructor of User (local)
@ -42,10 +43,14 @@ public abstract class User {
this.pseudo = pseudo; this.pseudo = pseudo;
this.addIP=addIP; this.addIP=addIP;
this.portTCP=portTCP; this.portTCP=portTCP;
this.IPcode=addIP.hashCode();
} }
/*** GETTERS ***/ /*** GETTERS ***/
public int getIPcode() {
return IPcode;
}
public String getPseudo() { public String getPseudo() {
return pseudo; return pseudo;
} }
@ -56,6 +61,7 @@ public abstract class User {
return portTCP; return portTCP;
} }
/*** SETTERS ***/ /*** SETTERS ***/
public void setPseudo(String pseudo) { public void setPseudo(String pseudo) {
this.pseudo = pseudo; this.pseudo = pseudo;